| | |
| | | printf("%d: send %d nodes\n", l, n); |
| | | for(j=0; j < recv_arr_size; j++) { |
| | | |
| | | fprintf(fp, "%d send '%s' to %d. received from (host=%s, port= %d, key=%d) '%s'\n", |
| | | fprintf(stdout, "%d send '%s' to %d. received from (host=%s, port= %d, key=%d) '%s'\n", |
| | | net_mod_socket_get_key(client), |
| | | sendbuf, |
| | | targ->node->key, |
| | |
| | | |
| | | ); |
| | | |
| | | // printf( "%d send '%s' to %d. received from (host=%s, port= %d, key=%d) '%s'\n", |
| | | // net_mod_socket_get_key(client), |
| | | // sendbuf, |
| | | // targ->node->key, |
| | | // recv_arr[j].host, |
| | | // recv_arr[j].port, |
| | | // recv_arr[j].key, |
| | | // recv_arr[j].content |
| | | // ); |
| | | |
| | | |
| | | // assert(sscanf((const char *)recv_arr[j].content, reply_format, &rkey, &lkey, &rl) == 3); |
| | | // assert(targ->node->key == rkey); |
| | | // assert(net_mod_socket_get_key(client) == lkey); |
| | | // assert(rl == l); |
| | | |
| | | |
| | | assert(sscanf((const char *)recv_arr[j].content, reply_format, &remoteKey, &retPid, &retl) == 3); |
| | | assert(retPid == pid); |