diff --git a/test/case52/src/testcase52.c b/test/case52/src/testcase52.c index 768c8d7..8ad6ee1 100755 --- a/test/case52/src/testcase52.c +++ b/test/case52/src/testcase52.c @@ -57,13 +57,13 @@ struct sockaddr_in server_addr_case52; // #define MAP_SIZE_CASE52 1028096 // #define MAP_SIZE_ST_CASE52 4096 // 4096 -#define MAP_ADDR_TX_BASE_CASE52 0x84C00000 // TX 数据位起始 +// #define MAP_ADDR_TX_BASE_CASE52 0x84C00000 // TX 数据位起始 #define MAP_ADDR_RX_BASE_CASE52 0x85001000 // RX 数据位起始 #define MAP_ADDR_RXFLAG_DATA_CASE52 0x85000000 // wr 计数起始位 int mem_fd_case52; // 统一文件描述符 ssize_t send_len; -void *map_base_tx_case52; // TX映射地址 20块 +// void *map_base_tx_case52; // TX映射地址 20块 void *map_base_rx_case52; // RX映射地址 8块 void *map_base_rxf_case52; // wr 计数映射地址 uint8_t w_idx, r_idx; // RX 信号 @@ -111,22 +111,22 @@ void *handleUdpTransmission(void *arg) exit(EXIT_FAILURE); } // TX - printf("[mmap]:/*************** mmap_tx ***************/\n"); - map_base_tx_case52 = mmap(NULL, MAP_SIZE_CASE52, PROT_READ | PROT_WRITE, MAP_SHARED, mem_fd_case52, MAP_ADDR_TX_BASE_CASE52); - if (map_base_tx_case52 == MAP_FAILED) { - printf("[mmap]: tx mapping failed!\n"); - perror("mmap tx error"); - close(mem_fd_case52); - exit(EXIT_FAILURE); - } - printf("[mmap]: tx ready\n"); + // printf("[mmap]:/*************** mmap_tx ***************/\n"); + // map_base_tx_case52 = mmap(NULL, MAP_SIZE_CASE52, PROT_READ | PROT_WRITE, MAP_SHARED, mem_fd_case52, MAP_ADDR_TX_BASE_CASE52); + // if (map_base_tx_case52 == MAP_FAILED) { + // printf("[mmap]: tx mapping failed!\n"); + // perror("mmap tx error"); + // close(mem_fd_case52); + // exit(EXIT_FAILURE); + // } + // printf("[mmap]: tx ready\n"); // RX printf("[mmap]:/*************** mmap_rx ***************/\n"); 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 + // munmap(map_base_tx_case52, MAP_SIZE_CASE52); // clean TX close(mem_fd_case52); exit(EXIT_FAILURE); } @@ -137,7 +137,7 @@ void *handleUdpTransmission(void *arg) 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_tx_case52, MAP_SIZE_CASE52); // clean TX munmap(map_base_rx_case52, MAP_SIZE_CASE52); // clean RX close(mem_fd_case52); exit(EXIT_FAILURE); @@ -149,51 +149,51 @@ void *handleUdpTransmission(void *arg) printf("[store]: r_idx ready == 0\n"); // rd txt /************************************************************************************** */ - printf("[rd txt]:/************** FILE ***************/\n"); - FILE *data_txt_fd; - //const char *path = "/path/to/data.txt"; - data_txt_fd = fopen("/opt/data.txt","r"); // 此处应为绝对路径 - if (data_txt_fd == NULL) - { - printf("[txt_fd]:data_txt_fd error! :(\n"); - perror("open txt error!"); - exit(EXIT_FAILURE); - } - uint16_t txt_buffer[65535] = {0}; - for (int txt_num = 0; txt_num < 65535; txt_num++) - { - if (fscanf(data_txt_fd, "%hu", &txt_buffer[txt_num]) != 1) - { - fprintf(stderr, "[Error] Failed to read number at position %d :(\n", txt_num); - fclose(data_txt_fd); - exit(EXIT_FAILURE); - } - } - fclose(data_txt_fd); - printf("[rd txt]: txt_buffer ready\n"); + // printf("[rd txt]:/************** FILE ***************/\n"); + // FILE *data_txt_fd; + // //const char *path = "/path/to/data.txt"; + // data_txt_fd = fopen("/opt/data.txt","r"); // 此处应为绝对路径 + // if (data_txt_fd == NULL) + // { + // printf("[txt_fd]:data_txt_fd error! :(\n"); + // perror("open txt error!"); + // exit(EXIT_FAILURE); + // } + // uint16_t txt_buffer[65535] = {0}; + // for (int txt_num = 0; txt_num < 65535; txt_num++) + // { + // if (fscanf(data_txt_fd, "%hu", &txt_buffer[txt_num]) != 1) + // { + // fprintf(stderr, "[Error] Failed to read number at position %d :(\n", txt_num); + // fclose(data_txt_fd); + // exit(EXIT_FAILURE); + // } + // } + // fclose(data_txt_fd); + // printf("[rd txt]: txt_buffer ready\n"); /************************************************************************************** */ - printf("[tx]:wr...\n"); - size_t wr_cunt = 0; - uint16_t udp_data_buffer[8008]; - printf("[tx]:先写入10块数据...\n"); - size_t data_index = 0; - for (int ready_num = 0; ready_num < 10; ready_num++) - { - for (int arr_cunt = 0; arr_cunt < 8008; ++arr_cunt) { - // 偏移 - size_t tx_data_offset = wr_cunt * 16016 + arr_cunt * 2; - // cpy - memcpy((char*)map_base_tx_case52 + tx_data_offset, &txt_buffer[data_index], 2);//65536 - // 更新数据索引 - data_index = (data_index + 1) % 65535; - } - // 更新地址块索引 - wr_cunt = (wr_cunt + 1) % 20; - } - printf("[tx]:初始10块写入完成，当前地址块=%zu，数据索引=%zu\n", wr_cunt, data_index); - printf("[while(1)]:/*************************************/\n"); - size_t current_pos = 0; - uint16_t value_mem = 0; + // printf("[tx]:wr...\n"); + // size_t wr_cunt = 0; + // uint16_t udp_data_buffer[8008]; + // printf("[tx]:先写入10块数据...\n"); + // size_t data_index = 0; + // for (int ready_num = 0; ready_num < 10; ready_num++) + // { + // for (int arr_cunt = 0; arr_cunt < 8008; ++arr_cunt) { + // // 偏移 + // size_t tx_data_offset = wr_cunt * 16016 + arr_cunt * 2; + // // cpy + // memcpy((char*)map_base_tx_case52 + tx_data_offset, &txt_buffer[data_index], 2);//65536 + // // 更新数据索引 + // data_index = (data_index + 1) % 65535; + // } + // // 更新地址块索引 + // wr_cunt = (wr_cunt + 1) % 20; + // } + // printf("[tx]:初始10块写入完成，当前地址块=%zu，数据索引=%zu\n", wr_cunt, data_index); + // printf("[while(1)]:/*************************************/\n"); + // size_t current_pos = 0; + // uint16_t value_mem = 0; uint8_t block_n = 0; uint8_t cut_i = 0; while (1) @@ -205,14 +205,14 @@ void *handleUdpTransmission(void *arg) slot_ind_flag = 0; /************************************************************************************** */ // wr 16016*20(byte),一次while循环会写入 1/20 的数据，触发条件为slot_ind_flag - current_pos = wr_cunt * 16016; + // current_pos = wr_cunt * 16016; - for (int i = 0; i < 8008; ++i) { - value_mem = txt_buffer[(data_index + i) % 65535]; - memcpy((char*)map_base_tx_case52 + current_pos + i*2, &value_mem, 2); - } - data_index = (data_index + 8008) % 65535; - wr_cunt = (wr_cunt + 1) % 20; + // for (int i = 0; i < 8008; ++i) { + // value_mem = txt_buffer[(data_index + i) % 65535]; + // memcpy((char*)map_base_tx_case52 + current_pos + i*2, &value_mem, 2); + // } + // data_index = (data_index + 8008) % 65535; + // wr_cunt = (wr_cunt + 1) % 20; /************************************************************************************** */ // 更新生产者计数 w_idx = __atomic_load_n(