| /NetX-Duo-v6.2.1/test/regression/bsd_test/ |
| D | netx_bsd_tcp_accept_blocking_test.c | 128 int message_id; member
138 int sockfd, message_id; in bsd_server_helper_thread_entry() local
142 message_id = client_data[thread_input].message_id; in bsd_server_helper_thread_entry()
149 … if((ret != (int)strlen(requests[message_id & 3])) || strncmp(buf, requests[message_id & 3], ret)) in bsd_server_helper_thread_entry()
153 ret = send(sockfd, response[message_id & 3], strlen(response[message_id & 3]), 0); in bsd_server_helper_thread_entry()
154 if(ret != (int)strlen(response[message_id & 3])) in bsd_server_helper_thread_entry()
233 client_data[i].message_id = i; in test_tcp_server4()
|
| D | netx_bsd_tcp_getsockname_test.c | 121 int message_id; member
132 int sockfd, message_id; in bsd_server_helper_thread_entry() local
136 message_id = client_data[thread_input].message_id; in bsd_server_helper_thread_entry()
145 …if((ret != (int)strlen(requests[message_id & 3])) || (strncmp(buf, requests[message_id & 3], ret))) in bsd_server_helper_thread_entry()
149 ret = send(sockfd, response[message_id & 3], strlen(response[message_id & 3]), 0); in bsd_server_helper_thread_entry()
150 if(ret != (int)strlen(response[message_id & 3])) in bsd_server_helper_thread_entry()
292 client_data[j * 2 + i].message_id = i; in tcp_server_entry()
|
| D | netx_bsd_tcp_accept_blocking_timeout_test.c | 129 int message_id; member
139 int sockfd, message_id; in bsd_server_helper_thread_entry() local
143 message_id = client_data[thread_input].message_id; in bsd_server_helper_thread_entry()
150 … if((ret != (int)strlen(requests[message_id & 3])) || strncmp(buf, requests[message_id & 3], ret)) in bsd_server_helper_thread_entry()
154 ret = send(sockfd, response[message_id & 3], strlen(response[message_id & 3]), 0); in bsd_server_helper_thread_entry()
155 if(ret != (int)strlen(response[message_id & 3])) in bsd_server_helper_thread_entry()
235 client_data[i].message_id = i; in test_tcp_server4()
|
| D | netx_bsd_tcp_accept_nonblocking_timeout_test.c | 126 int message_id; member
136 int sockfd, message_id; in bsd_server_helper_thread_entry() local
142 message_id = client_data[thread_input].message_id; in bsd_server_helper_thread_entry()
165 … if((ret != (int)strlen(requests[message_id & 3])) || strncmp(buf, requests[message_id & 3], ret)) in bsd_server_helper_thread_entry()
169 ret = send(sockfd, response[message_id & 3], strlen(response[message_id & 3]), 0); in bsd_server_helper_thread_entry()
170 if(ret != (int)strlen(response[message_id & 3])) in bsd_server_helper_thread_entry()
270 client_data[i].message_id = i; in test_tcp_server4()
|
| D | netx_bsd_tcp_accept_noselect_test.c | 126 int message_id; member
136 int sockfd, message_id; in bsd_server_helper_thread_entry() local
142 message_id = client_data[thread_input].message_id; in bsd_server_helper_thread_entry()
165 … if((ret != (int)strlen(requests[message_id & 3])) || strncmp(buf, requests[message_id & 3], ret)) in bsd_server_helper_thread_entry()
169 ret = send(sockfd, response[message_id & 3], strlen(response[message_id & 3]), 0); in bsd_server_helper_thread_entry()
170 if(ret != (int)strlen(response[message_id & 3])) in bsd_server_helper_thread_entry()
252 client_data[i].message_id = i; in test_tcp_server4()
|
| D | netx_bsd_tcp_accept_nonblocking_test.c | 126 int message_id; member
136 int sockfd, message_id; in bsd_server_helper_thread_entry() local
142 message_id = client_data[thread_input].message_id; in bsd_server_helper_thread_entry()
165 … if((ret != (int)strlen(requests[message_id & 3])) || strncmp(buf, requests[message_id & 3], ret)) in bsd_server_helper_thread_entry()
169 ret = send(sockfd, response[message_id & 3], strlen(response[message_id & 3]), 0); in bsd_server_helper_thread_entry()
170 if(ret != (int)strlen(response[message_id & 3])) in bsd_server_helper_thread_entry()
270 client_data[i].message_id = i; in test_tcp_server4()
|
| D | netx_bsd_tcp_multiple_accept_test.c | 148 int message_id; member
165 int sockfd, message_id; in bsd_server_helper_thread_entry() local
169 message_id = client_data[thread_input].message_id; in bsd_server_helper_thread_entry()
180 …if((ret != (int)strlen(requests[message_id & 3])) || (strncmp(buf, requests[message_id & 3], ret))) in bsd_server_helper_thread_entry()
186 ret = send(sockfd, response[message_id & 3], strlen(response[message_id & 3]), 0); in bsd_server_helper_thread_entry()
187 if(ret != (int)strlen(response[message_id & 3])) in bsd_server_helper_thread_entry()
381 client_data[index].message_id = i; in tcp_server_entry()
|
| D | netx_bsd_ioctl_nonblocking_test.c | 132 int message_id; member
149 int sockfd, message_id; in bsd_server_blocking_helper_thread_entry() local
153 message_id = client_data[thread_input].message_id; in bsd_server_blocking_helper_thread_entry()
159 if((ret != (int)strlen(requests[message_id&3])) || strncmp(buf, requests[message_id&3], ret)) in bsd_server_blocking_helper_thread_entry()
163 ret = send(sockfd, response[message_id&3], strlen(response[message_id&3]), 0); in bsd_server_blocking_helper_thread_entry()
164 if(ret != (int)strlen(response[message_id&3])) in bsd_server_blocking_helper_thread_entry()
181 int sockfd, message_id; in bsd_server_helper_thread_entry() local
187 message_id = client_data[thread_input].message_id; in bsd_server_helper_thread_entry()
212 … if((ret != (int)strlen(requests[message_id&3])) || strncmp(buf, requests[message_id&3], ret)) in bsd_server_helper_thread_entry()
216 ret = send(sockfd, response[message_id&3], strlen(response[message_id&3]), 0); in bsd_server_helper_thread_entry()
[all …]
|
| D | netx_bsd_tcp_fionread_test.c | 126 int message_id; member
136 int sockfd, message_id; in bsd_server_helper_thread_entry() local
141 message_id = client_data.message_id; in bsd_server_helper_thread_entry()
221 client_data.message_id = 0; in test_tcp_server4()
|
| D | netx_bsd_tcp_basic_blocking_test.c | 136 int message_id; member
149 int sockfd, message_id; in bsd_server_helper_thread_entry() local
161 message_id = client_data[thread_input].message_id; in bsd_server_helper_thread_entry()
163 if(message_id == 2) in bsd_server_helper_thread_entry()
203 … if((ret != (int)strlen(requests[message_id & 3])) || strncmp(buf, requests[message_id & 3], ret)) in bsd_server_helper_thread_entry()
212 … if((ret != (int)strlen(requests[message_id & 3])) || strncmp(buf, requests[message_id & 3], ret)) in bsd_server_helper_thread_entry()
230 ret = send(sockfd, response[message_id & 3], strlen(response[message_id & 3]), 0); in bsd_server_helper_thread_entry()
231 if(ret != (int)strlen(response[message_id & 3])) in bsd_server_helper_thread_entry()
411 client_data[i].message_id = i; in test_tcp_server4()
555 client_data[i].message_id = i; in test_tcp_server6()
|
| D | netx_bsd_tcp_rcvbuf_test.c | 135 int message_id; member
148 int sockfd, message_id; in bsd_server_helper_thread_entry() local
160 message_id = client_data[thread_input].message_id; in bsd_server_helper_thread_entry()
162 if(message_id == 2) in bsd_server_helper_thread_entry()
202 … if((ret != (int)strlen(requests[message_id & 3])) || strncmp(buf, requests[message_id & 3], ret)) in bsd_server_helper_thread_entry()
211 … if((ret != (int)strlen(requests[message_id & 3])) || strncmp(buf, requests[message_id & 3], ret)) in bsd_server_helper_thread_entry()
229 ret = send(sockfd, response[message_id & 3], strlen(response[message_id & 3]), 0); in bsd_server_helper_thread_entry()
230 if(ret != (int)strlen(response[message_id & 3])) in bsd_server_helper_thread_entry()
420 client_data[i].message_id = i; in test_tcp_server4()
574 client_data[i].message_id = i; in test_tcp_server6()
|
| D | netx_bsd_getaddrinfo_test.c | 187 int message_id; member
200 int sockfd, message_id; in bsd_server_helper_thread_entry() local
212 message_id = client_data[thread_input].message_id; in bsd_server_helper_thread_entry()
214 if(message_id == 2) in bsd_server_helper_thread_entry()
254 … if((ret != (int)strlen(requests[message_id & 3])) || strncmp(buf, requests[message_id & 3], ret)) in bsd_server_helper_thread_entry()
263 … if((ret != (int)strlen(requests[message_id & 3])) || strncmp(buf, requests[message_id & 3], ret)) in bsd_server_helper_thread_entry()
281 ret = send(sockfd, response[message_id & 3], strlen(response[message_id & 3]), 0); in bsd_server_helper_thread_entry()
282 if(ret != (int)strlen(response[message_id & 3])) in bsd_server_helper_thread_entry()
470 client_data[i].message_id = i; in test_tcp_server4()
625 client_data[i].message_id = i; in test_tcp_server6()
|
| D | netx_bsd_tcp_basic_nonblocking_test.c | 132 int message_id; member
145 int sockfd, message_id; in bsd_server_helper_thread_entry() local
151 message_id = client_data[thread_input].message_id; in bsd_server_helper_thread_entry()
174 … if((ret != (int)strlen(requests[message_id&3])) || strncmp(buf, requests[message_id&3], ret)) in bsd_server_helper_thread_entry()
178 ret = send(sockfd, response[message_id&3], strlen(response[message_id&3]), 0); in bsd_server_helper_thread_entry()
179 if(ret != (int)strlen(response[message_id&3])) in bsd_server_helper_thread_entry()
281 client_data[i].message_id = i; in test_tcp_server4()
393 client_data[i].message_id = i; in test_tcp_server6()
|
| D | netx_bsd_tcp_bind_test.c | 159 int message_id; member
283 client_data[index].message_id = 0xFFFF; in bsd_server4_helper_thread_test_2()
373 client_data[index].message_id = 0xFFFF; in bsd_server6_helper_thread_test_2()
457 int sockfd, message_id; in bsd_server_helper_thread_entry() local
461 message_id = client_data[thread_input].message_id; in bsd_server_helper_thread_entry()
482 if(message_id == 0xFFFF) in bsd_server_helper_thread_entry()
|
