From 27a32410481fc10e789315b3a1dab88a33020270 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期二, 16 六月 2020 15:45:37 +0800
Subject: [PATCH] finished bipc
---
bipc/test_survey.c | 46 +++++++++++++++++++++++-----------------------
1 files changed, 23 insertions(+), 23 deletions(-)
diff --git a/bipc/test_survey.c b/bipc/test_survey.c
index 40d6ad0..b4ee7e7 100644
--- a/bipc/test_survey.c
+++ b/bipc/test_survey.c
@@ -26,35 +26,35 @@
int
server(const char *url)
{
- bipc_socket_t sock;
- int rv;
+ bipc_socket_t sock;
+ int rv;
-
- if ((rv = bipc_listen(&sock, url, SURVEY)) != 0) {
- fatal("nng_listen", rv);
+
+ if ((rv = bipc_listen(&sock, url, SURVEY)) != 0) {
+ fatal("nng_listen", rv);
+ }
+ for (;;) {
+ printf("SERVER: SENDING DATE SURVEY REQUEST\n");
+ if ((rv = bipc_send(&sock, DATE, strlen(DATE) + 1)) != 0) {
+ fatal("nng_send", rv);
}
+
for (;;) {
- printf("SERVER: SENDING DATE SURVEY REQUEST\n");
- if ((rv = bipc_send(&sock, DATE, strlen(DATE) + 1)) != 0) {
- fatal("nng_send", rv);
+ char *buf = NULL;
+ size_t sz;
+ rv = bipc_recv(&sock, &buf, &sz);
+ if (rv == BIPC_ETIMEDOUT) {
+ break;
}
-
- for (;;) {
- char *buf = NULL;
- size_t sz;
- rv = bipc_recv(&sock, &buf, &sz);
- if (rv == BIPC_ETIMEDOUT) {
- break;
- }
- if (rv != 0) {
- fatal("nng_recv", rv);
- }
- printf("SERVER: RECEIVED \"%s\" SURVEY RESPONSE\n", buf);
- bipc_free(buf, sz);
+ if (rv != 0) {
+ fatal("nng_recv", rv);
}
-
- printf("SERVER: SURVEY COMPLETE\n");
+ printf("SERVER: RECEIVED \"%s\" SURVEY RESPONSE\n", buf);
+ bipc_free(buf, sz);
}
+
+ printf("SERVER: SURVEY COMPLETE\n");
+ }
}
int
--
Gitblit v1.8.0