| | |
| | | int rv; |
| | | int remote_port; |
| | | while ( (rv = dgram_mod_recvfrom(socket, &recvbuf, &size, &remote_port) ) == 0) { |
| | | printf( "收到来自%d注册信息: %s", remote_port, recvbuf); |
| | | printf( "RECEIVED HREARTBEAT FROM %d: %s\n", remote_port, recvbuf); |
| | | free(recvbuf); |
| | | } |
| | | dgram_mod_close_socket(socket); |
| | |
| | | int size; |
| | | void *recvbuf; |
| | | char sendbuf[512]; |
| | | long i = 0; |
| | | while (true) { |
| | | printf("request: "); |
| | | scanf("%s", sendbuf); |
| | | dgram_mod_send(socket, sendbuf, strlen(sendbuf) + 1, port, &recvbuf, &size); |
| | | printf("reply: %s\n", (char *)recvbuf); |
| | | sprintf(sendbuf, "%d", i); |
| | | printf("SEND HEART:%s\n", sendbuf); |
| | | dgram_mod_sendto(socket, sendbuf, strlen(sendbuf) + 1, port); |
| | | free(recvbuf); |
| | | sleep(1); |
| | | i++; |
| | | } |
| | | dgram_mod_close_socket(socket); |
| | | } |