From e799a80021a22715d24da80edf7353456da81b33 Mon Sep 17 00:00:00 2001 From: yuanQie Date: Sat, 14 Jun 2025 17:48:19 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=F0=9F=94=A5=20=E5=8E=BB=E6=8E=89?= =?UTF-8?q?=E9=A2=91=E7=B9=81=E6=89=93=E5=8D=B0=E7=9A=84=E7=BB=88=E7=AB=AF?= =?UTF-8?q?=E8=BE=93=E5=87=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- test/case46/src/testcase46.c | 45 +++++++++++++++++++++++++++--------- 1 file changed, 34 insertions(+), 11 deletions(-) diff --git a/test/case46/src/testcase46.c b/test/case46/src/testcase46.c index a87caeb..cffb01f 100644 --- a/test/case46/src/testcase46.c +++ b/test/case46/src/testcase46.c @@ -108,23 +108,35 @@ void *handleUdpTransmission(void *arg) } // RX - map_base_rx_case52 = mmap(NULL, MAP_SIZE_CASE52, PROT_READ | PROT_WRITE, MAP_SHARED, mem_fd_case52, MAP_ADDR_RX_BASE_CASE52); + map_base_rx_case52 = mmap( + NULL, + MAP_SIZE_CASE52, + PROT_READ | PROT_WRITE, + MAP_SHARED, + mem_fd_case52, + MAP_ADDR_RX_BASE_CASE52 + ); if (map_base_rx_case52 == MAP_FAILED) { printf("[mmap]: rx mapping failed!\n"); perror("mmap rx error"); - // munmap(map_base_tx_case52, MAP_SIZE_CASE52); // clean TX close(mem_fd_case52); exit(EXIT_FAILURE); } printf("[ mmap ]: rx ready\n"); // RX_FLAG - map_base_rxf_case52 = mmap(NULL, MAP_SIZE_ST_CASE52, PROT_READ | PROT_WRITE, MAP_SHARED, mem_fd_case52, MAP_ADDR_RXFLAG_DATA_CASE52); + map_base_rxf_case52 = mmap( + NULL, + MAP_SIZE_ST_CASE52, + PROT_READ | PROT_WRITE, + MAP_SHARED, + mem_fd_case52, + MAP_ADDR_RXFLAG_DATA_CASE52 + ); if (map_base_rxf_case52 == MAP_FAILED) { printf("[mmap]: RX_FLAG mapping failed!\n"); perror("mmap RX_FLAG error"); - // munmap(map_base_tx_case52, MAP_SIZE_CASE52); // clean TX - munmap(map_base_rx_case52, MAP_SIZE_CASE52); // clean RX + munmap(map_base_rx_case52, MAP_SIZE_CASE52); close(mem_fd_case52); exit(EXIT_FAILURE); } @@ -148,8 +160,14 @@ void *handleUdpTransmission(void *arg) // udp_ctrl char *ctrl_message = "ready"; - sendto(sockfd_case52, ctrl_message, strlen(ctrl_message), 0, - (struct sockaddr *)&server_addr_case52, sizeof(server_addr_case52)); + sendto( + sockfd_case52, + ctrl_message, + strlen(ctrl_message), + 0, + (struct sockaddr *)&server_addr_case52, + sizeof(server_addr_case52) + ); printf("[udp.sendto]: %s\n", ctrl_message); char ctrl_buffer[CTRL_BUFFER_SIZE]; @@ -160,12 +178,17 @@ void *handleUdpTransmission(void *arg) while (strcmp_flag) { - recv_len = recvfrom(sockfd_case52, ctrl_buffer, CTRL_BUFFER_SIZE, 0, - (struct sockaddr *)&from_addr, &from_addr_len); + recv_len = recvfrom( + sockfd_case52, + ctrl_buffer, + CTRL_BUFFER_SIZE, + 0, + (struct sockaddr *)&from_addr, + &from_addr_len + ); if (recv_len < 0) { printf("[udp_ctrl]:recv_len < 0\n"); - } - + } ctrl_buffer[recv_len] = '\0'; printf("[ udp.recv ]: %s\n", ctrl_buffer); if (strcmp(ctrl_buffer, "ok") == 0) {