| | |
|---|
| | | sprintf(sendbuf, "thread(%d) %d", targ->id, i); |
|---|
| | | fprintf(fp, "requst:%s\n", sendbuf); |
|---|
| | | // n = net_mod_socket_sendandrecv(client, node_arr, node_arr_size, sendbuf, strlen(sendbuf) + 1, &recv_arr, &recv_arr_size); |
|---|
| | | n = net_mod_socket_sendandrecv_timeout(client, node_arr, node_arr_size, sendbuf, strlen(sendbuf) + 1, &recv_arr, &recv_arr_size, 1000); |
|---|
| | | printf("send %d nodes\n", n); |
|---|
| | | n = net_mod_socket_sendandrecv_timeout(client, node_arr, node_arr_size, sendbuf, strlen(sendbuf) + 1, &recv_arr, &recv_arr_size, 1000); |
|---|
| | | printf("%d: send %d nodes\n", i, n); |
|---|
| | | for(j=0; j < recv_arr_size; j++) { |
|---|
| | | fprintf(fp, "reply: host:%s, port: %d, key:%d, content: %s\n", |
|---|
| | | recv_arr[j].host, |
|---|
