From aa2f3b2a9968bb4928463bdae05fb026d16b60bb Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期五, 04 十二月 2020 19:07:01 +0800
Subject: [PATCH] 固定bus key
---
test_socket/dgram_mod_survey.c | 16 ++++++++--------
1 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/test_socket/dgram_mod_survey.c b/test_socket/dgram_mod_survey.c
index a492637..da3260f 100644
--- a/test_socket/dgram_mod_survey.c
+++ b/test_socket/dgram_mod_survey.c
@@ -1,5 +1,5 @@
#include "dgram_mod_socket.h"
-#include "shm_mm.h"
+#include "shm_mm_wraper.h"
#include "usg_common.h"
@@ -12,7 +12,7 @@
void sigint_handler(int sig) {
//dgram_mod_close_socket(server_socket);
printf("===Catch sigint======================\n");
- shm_destroy();
+ shm_mm_wrapper_destroy();
exit(0);
}
@@ -25,7 +25,7 @@
int rv;
int remote_port;
while (true) {
- if ((rv = dgram_mod_recvfrom_timeout(socket, &recvbuf, &size, &remote_port, 5, 0) ) == 0) {
+ if ((rv = dgram_mod_recvfrom_timeout(socket, &recvbuf, &size, &remote_port, 15, 0) ) == 0) {
printf( "RECEIVED HREARTBEAT FROM %d: %s\n", remote_port, recvbuf);
free(recvbuf);
}
@@ -43,7 +43,7 @@
sprintf(sendbuf, "%d", i);
printf("SEND HEART:%s\n", sendbuf);
dgram_mod_sendto(socket, sendbuf, strlen(sendbuf) + 1, port);
- // sleep(1);
+ // sleep(1);
i++;
}
dgram_mod_close_socket(socket);
@@ -63,7 +63,7 @@
sprintf(sendbuf, "%d", i);
printf("%d SEND HEART:%s\n", targ->id, sendbuf);
dgram_mod_sendto(socket, sendbuf, strlen(sendbuf) + 1, port);
- // sleep(1);
+ sleep(1);
i++;
}
@@ -106,7 +106,7 @@
}
int main(int argc, char *argv[]) {
- shm_init(512);
+ shm_mm_wrapper_init(512);
int port;
if (argc < 3) {
fprintf(stderr, "Usage: reqrep %s|%s <PORT> ...\n", "server", "client");
@@ -122,6 +122,6 @@
if (strcmp("client", argv[1]) == 0)
client(port);
- shm_destroy();
+ shm_mm_wrapper_destroy();
return 0;
-}
\ No newline at end of file
+}
--
Gitblit v1.8.0