diff options
Diffstat (limited to 'src/sp/protocol')
| -rw-r--r-- | src/sp/protocol/pipeline0/pull_test.c | 4 | ||||
| -rw-r--r-- | src/sp/protocol/pubsub0/sub_test.c | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/src/sp/protocol/pipeline0/pull_test.c b/src/sp/protocol/pipeline0/pull_test.c index 8ed9cc0e..32134082 100644 --- a/src/sp/protocol/pipeline0/pull_test.c +++ b/src/sp/protocol/pipeline0/pull_test.c @@ -243,10 +243,10 @@ test_pull_recv_abort(void) nng_aio_set_timeout(aio, 1000); nng_socket_recv(s, aio); - nng_aio_abort(aio, NNG_EAMBIGUOUS); + nng_aio_abort(aio, NNG_ESTATE); nng_aio_wait(aio); - NUTS_FAIL(nng_aio_result(aio), NNG_EAMBIGUOUS); + NUTS_FAIL(nng_aio_result(aio), NNG_ESTATE); NUTS_CLOSE(s); nng_aio_free(aio); } diff --git a/src/sp/protocol/pubsub0/sub_test.c b/src/sp/protocol/pubsub0/sub_test.c index 13fc07bf..7f4e4480 100644 --- a/src/sp/protocol/pubsub0/sub_test.c +++ b/src/sp/protocol/pubsub0/sub_test.c @@ -301,10 +301,10 @@ test_sub_ctx_recv_abort(void) nng_aio_set_timeout(aio, 1000); nng_ctx_recv(ctx, aio); - nng_aio_abort(aio, NNG_EAMBIGUOUS); + nng_aio_abort(aio, NNG_EINTERNAL); nng_aio_wait(aio); - NUTS_FAIL(nng_aio_result(aio), NNG_EAMBIGUOUS); + NUTS_FAIL(nng_aio_result(aio), NNG_EINTERNAL); NUTS_CLOSE(sub); nng_aio_free(aio); } |