From 0bc7b3e2e454bef288bb0fad38b23fb589597ea8 Mon Sep 17 00:00:00 2001 From: yuanQie Date: Thu, 12 Jun 2025 21:58:50 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E2=9C=85=20=E6=81=A2=E5=A4=8Dudp?= =?UTF-8?q?=E4=BB=A3=E7=A0=81=EF=BC=8C=E7=BC=96=E8=AF=91=E6=B5=8B=E8=AF=95?= =?UTF-8?q?=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- test/case46/src/testcase46.c | 86 ++++++++++++++++++------------------ 1 file changed, 43 insertions(+), 43 deletions(-) diff --git a/test/case46/src/testcase46.c b/test/case46/src/testcase46.c index 9e4ab44..3d8e52f 100644 --- a/test/case46/src/testcase46.c +++ b/test/case46/src/testcase46.c @@ -133,54 +133,54 @@ void *handleUdpTransmission(void *arg) printf("[mmap]: wr_idx ready\n"); // ucp4008_ctrl_mmap_base - // ucp4008_ctrl_mmap_base = mmap( - // NULL, - // MAP_SIZE_ST_CASE52, - // PROT_READ | PROT_WRITE, - // MAP_SHARED, - // mem_fd_case52, - // UCP4008_CTRL_PHYSADDR - // ); - // if (ucp4008_ctrl_mmap_base == MAP_FAILED) { - // printf("[mmap]: ucp4008_ctrl mapping failed!\n"); - // perror("ucp4008_ctrl error"); - // close(mem_fd_case52); - // exit(EXIT_FAILURE); - // } + ucp4008_ctrl_mmap_base = mmap( + NULL, + MAP_SIZE_ST_CASE52, + PROT_READ | PROT_WRITE, + MAP_SHARED, + mem_fd_case52, + UCP4008_CTRL_PHYSADDR + ); + if (ucp4008_ctrl_mmap_base == MAP_FAILED) { + printf("[mmap]: ucp4008_ctrl mapping failed!\n"); + perror("ucp4008_ctrl error"); + close(mem_fd_case52); + exit(EXIT_FAILURE); + } // udp_ctrl - // char *ctrl_message = "ready"; - // sendto(sockfd_case52, ctrl_message, strlen(ctrl_message), 0, - // (struct sockaddr *)&server_addr_case52, sizeof(server_addr_case52)); - // printf("[sendto]:%s\n", ctrl_message); + char *ctrl_message = "ready"; + sendto(sockfd_case52, ctrl_message, strlen(ctrl_message), 0, + (struct sockaddr *)&server_addr_case52, sizeof(server_addr_case52)); + printf("[sendto]:%s\n", ctrl_message); - // char ctrl_buffer[CTRL_BUFFER_SIZE]; - // struct sockaddr_in from_addr; - // socklen_t from_addr_len = sizeof(from_addr); - // int recv_len; - // int strcmp_flag = 1; + char ctrl_buffer[CTRL_BUFFER_SIZE]; + struct sockaddr_in from_addr; + socklen_t from_addr_len = sizeof(from_addr); + int recv_len; + int strcmp_flag = 1; - // while (strcmp_flag) - // { - // recv_len = recvfrom(sockfd_case52, ctrl_buffer, CTRL_BUFFER_SIZE, 0, - // (struct sockaddr *)&from_addr, &from_addr_len); - // if (recv_len < 0) { - // printf("[recv_len]:recv_len < 0\n"); - // } + while (strcmp_flag) + { + recv_len = recvfrom(sockfd_case52, ctrl_buffer, CTRL_BUFFER_SIZE, 0, + (struct sockaddr *)&from_addr, &from_addr_len); + if (recv_len < 0) { + printf("[recv_len]:recv_len < 0\n"); + } - // ctrl_buffer[recv_len] = '\0'; - // printf("[recvfrom]:%s\n", ctrl_buffer); - // if (strcmp(ctrl_buffer, "ok") == 0) { - // //usleep(1000000); - // printf("[mmap]:wr...\n"); - // mapped_addr = (volatile uint32_t *)ucp4008_ctrl_mmap_base; - // *mapped_addr = 0xA5A55A5A; - // printf("[mmap]: wr 0xA5A55A5A done :) \n"); - // strcmp_flag = 0; - // } else { - // printf("[recvfrom]:strcmp no ok!\n"); - // } - // } + ctrl_buffer[recv_len] = '\0'; + printf("[recvfrom]:%s\n", ctrl_buffer); + if (strcmp(ctrl_buffer, "ok") == 0) { + //usleep(1000000); + printf("[mmap]:wr...\n"); + mapped_addr = (volatile uint32_t *)ucp4008_ctrl_mmap_base; + *mapped_addr = 0xA5A55A5A; + printf("[mmap]: wr 0xA5A55A5A done :) \n"); + strcmp_flag = 0; + } else { + printf("[recvfrom]:strcmp no ok!\n"); + } + } // 初始化消费者索引 r_idx = 0;