From 91ea20d03ebb5a8d20150d3ecc28a13c51ce93f1 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期五, 22 一月 2021 19:17:06 +0800
Subject: [PATCH] update
---
test_socket/bus_test.cpp | 24 ++++++++++++++++++++----
1 files changed, 20 insertions(+), 4 deletions(-)
diff --git a/test_socket/bus_test.cpp b/test_socket/bus_test.cpp
index b815476..a6d741e 100644
--- a/test_socket/bus_test.cpp
+++ b/test_socket/bus_test.cpp
@@ -24,15 +24,31 @@
void *recvbuf;
int size;
int key;
+ int rv;
ShmModSocket *sk = (ShmModSocket *)skptr;
- while ( true) {
- sk->recvfrom( &recvbuf, &size, &key);
- printf("鏀跺埌璁㈤槄娑堟伅:%s\n", recvbuf);
- free(recvbuf);
+printf("run_recv\n");
+ struct timespec timeout = {2, 0};
+ while (true) {
+ printf("run_recv before\n");
+
+ rv = sk->recvfrom_timeout( &recvbuf, &size, &key, &timeout);
+ if(rv == 0) {
+ printf("鏀跺埌璁㈤槄娑堟伅:%s\n", recvbuf);
+ free(recvbuf);
+ } else {
+ printf("recvfrom error %d\n", rv);
+ }
+
}
+ return NULL;
}
+void client2(int key) {
+ ShmModSocket *sk = new ShmModSocket();
+ run_recv((void *)sk);
+}
+
void client(int key) {
ShmModSocket *sk = new ShmModSocket();
--
Gitblit v1.8.0