feat: 🔥 去掉频繁打印的终端输出
This commit is contained in:
parent
5e81e37e70
commit
e799a80021
@ -108,23 +108,35 @@ void *handleUdpTransmission(void *arg)
|
|||||||
}
|
}
|
||||||
|
|
||||||
// RX
|
// 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) {
|
if (map_base_rx_case52 == MAP_FAILED) {
|
||||||
printf("[mmap]: rx mapping failed!\n");
|
printf("[mmap]: rx mapping failed!\n");
|
||||||
perror("mmap rx error");
|
perror("mmap rx error");
|
||||||
// munmap(map_base_tx_case52, MAP_SIZE_CASE52); // clean TX
|
|
||||||
close(mem_fd_case52);
|
close(mem_fd_case52);
|
||||||
exit(EXIT_FAILURE);
|
exit(EXIT_FAILURE);
|
||||||
}
|
}
|
||||||
printf("[ mmap ]: rx ready\n");
|
printf("[ mmap ]: rx ready\n");
|
||||||
|
|
||||||
// RX_FLAG
|
// 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) {
|
if (map_base_rxf_case52 == MAP_FAILED) {
|
||||||
printf("[mmap]: RX_FLAG mapping failed!\n");
|
printf("[mmap]: RX_FLAG mapping failed!\n");
|
||||||
perror("mmap RX_FLAG error");
|
perror("mmap RX_FLAG error");
|
||||||
// munmap(map_base_tx_case52, MAP_SIZE_CASE52); // clean TX
|
munmap(map_base_rx_case52, MAP_SIZE_CASE52);
|
||||||
munmap(map_base_rx_case52, MAP_SIZE_CASE52); // clean RX
|
|
||||||
close(mem_fd_case52);
|
close(mem_fd_case52);
|
||||||
exit(EXIT_FAILURE);
|
exit(EXIT_FAILURE);
|
||||||
}
|
}
|
||||||
@ -148,8 +160,14 @@ void *handleUdpTransmission(void *arg)
|
|||||||
|
|
||||||
// udp_ctrl
|
// udp_ctrl
|
||||||
char *ctrl_message = "ready";
|
char *ctrl_message = "ready";
|
||||||
sendto(sockfd_case52, ctrl_message, strlen(ctrl_message), 0,
|
sendto(
|
||||||
(struct sockaddr *)&server_addr_case52, sizeof(server_addr_case52));
|
sockfd_case52,
|
||||||
|
ctrl_message,
|
||||||
|
strlen(ctrl_message),
|
||||||
|
0,
|
||||||
|
(struct sockaddr *)&server_addr_case52,
|
||||||
|
sizeof(server_addr_case52)
|
||||||
|
);
|
||||||
printf("[udp.sendto]: %s\n", ctrl_message);
|
printf("[udp.sendto]: %s\n", ctrl_message);
|
||||||
|
|
||||||
char ctrl_buffer[CTRL_BUFFER_SIZE];
|
char ctrl_buffer[CTRL_BUFFER_SIZE];
|
||||||
@ -160,12 +178,17 @@ void *handleUdpTransmission(void *arg)
|
|||||||
|
|
||||||
while (strcmp_flag)
|
while (strcmp_flag)
|
||||||
{
|
{
|
||||||
recv_len = recvfrom(sockfd_case52, ctrl_buffer, CTRL_BUFFER_SIZE, 0,
|
recv_len = recvfrom(
|
||||||
(struct sockaddr *)&from_addr, &from_addr_len);
|
sockfd_case52,
|
||||||
|
ctrl_buffer,
|
||||||
|
CTRL_BUFFER_SIZE,
|
||||||
|
0,
|
||||||
|
(struct sockaddr *)&from_addr,
|
||||||
|
&from_addr_len
|
||||||
|
);
|
||||||
if (recv_len < 0) {
|
if (recv_len < 0) {
|
||||||
printf("[udp_ctrl]:recv_len < 0\n");
|
printf("[udp_ctrl]:recv_len < 0\n");
|
||||||
}
|
}
|
||||||
|
|
||||||
ctrl_buffer[recv_len] = '\0';
|
ctrl_buffer[recv_len] = '\0';
|
||||||
printf("[ udp.recv ]: %s\n", ctrl_buffer);
|
printf("[ udp.recv ]: %s\n", ctrl_buffer);
|
||||||
if (strcmp(ctrl_buffer, "ok") == 0) {
|
if (strcmp(ctrl_buffer, "ok") == 0) {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user