diff options
| -rw-r--r-- | src/sp/protocol/reqrep0/rep_test.c | 1 | ||||
| -rw-r--r-- | src/sp/protocol/reqrep0/req_test.c | 1 | ||||
| -rw-r--r-- | src/sp/protocol/survey0/respond_test.c | 1 | ||||
| -rw-r--r-- | src/sp/protocol/survey0/survey_test.c | 1 |
4 files changed, 4 insertions, 0 deletions
diff --git a/src/sp/protocol/reqrep0/rep_test.c b/src/sp/protocol/reqrep0/rep_test.c index 6ca8fbca..579f795c 100644 --- a/src/sp/protocol/reqrep0/rep_test.c +++ b/src/sp/protocol/reqrep0/rep_test.c @@ -164,6 +164,7 @@ test_rep_double_recv(void) nng_aio_wait(aio2); NUTS_FAIL(nng_aio_result(aio2), NNG_ESTATE); NUTS_CLOSE(s1); + nng_aio_wait(aio1); NUTS_FAIL(nng_aio_result(aio1), NNG_ECLOSED); nng_aio_free(aio1); nng_aio_free(aio2); diff --git a/src/sp/protocol/reqrep0/req_test.c b/src/sp/protocol/reqrep0/req_test.c index 71e08877..d1c615d1 100644 --- a/src/sp/protocol/reqrep0/req_test.c +++ b/src/sp/protocol/reqrep0/req_test.c @@ -934,6 +934,7 @@ test_req_ctx_recv_close_socket(void) nng_ctx_recv(ctx, aio); nng_close(req); + nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECLOSED); nng_aio_free(aio); NUTS_CLOSE(rep); diff --git a/src/sp/protocol/survey0/respond_test.c b/src/sp/protocol/survey0/respond_test.c index 15061cc2..0260dc30 100644 --- a/src/sp/protocol/survey0/respond_test.c +++ b/src/sp/protocol/survey0/respond_test.c @@ -164,6 +164,7 @@ test_resp_double_recv(void) nng_aio_wait(aio2); NUTS_FAIL(nng_aio_result(aio2), NNG_ESTATE); NUTS_CLOSE(s1); + nng_aio_wait(aio1); NUTS_FAIL(nng_aio_result(aio1), NNG_ECLOSED); nng_aio_free(aio1); nng_aio_free(aio2); diff --git a/src/sp/protocol/survey0/survey_test.c b/src/sp/protocol/survey0/survey_test.c index 6a5574c0..3f122abb 100644 --- a/src/sp/protocol/survey0/survey_test.c +++ b/src/sp/protocol/survey0/survey_test.c @@ -504,6 +504,7 @@ test_surv_ctx_recv_close_socket(void) nng_ctx_recv(ctx, aio); nng_close(surv); + nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECLOSED); nng_aio_free(aio); NUTS_CLOSE(resp); |