| | |
|---|
| | | |
|---|
| | | if (fgets(content, MAXLINE, stdin) != NULL) { |
|---|
| | | // 收到消息的节点即使没有对应的信息， 也要回复一个表示无的消息,否则会一直等待 |
|---|
| | | n = net_mod_socket_sendandrecv(client, node_arr, node_arr_size, content, strlen(content), &recv_arr, &recv_arr_size); |
|---|
| | | // n = net_mod_socket_sendandrecv(client, node_arr, node_arr_size, content, strlen(content), &recv_arr, &recv_arr_size); |
|---|
| | | n = net_mod_socket_sendandrecv_timeout(client, node_arr, node_arr_size, content, strlen(content), &recv_arr, &recv_arr_size, 1000); |
|---|
| | | printf(" %d nodes reply\n", n); |
|---|
| | | for(i=0; i<recv_arr_size; i++) { |
|---|
| | | printf("host:%s, port: %d, key:%d, content: %s\n", |
|---|
