aio: introduce NNG_ESTOPPED

This error code results when an AIO is stopped permanently, as a result
of nni_aio_close or nni_aio_stop.  The associated AIO object cannot be
used again.  This discrimantes against a file being closed, or a temporary
cancellation which might allow the aio to be reused.

Consumers must check for this error status in their callbacks, and not
resubmit an operation that failed with this error.  Doing so, will result
in an infinite loop of submit / errors.

1 files changed, 0 insertions, 102 deletions

diff --git a/src/sp/protocol/pubsub0/pub_test.c b/src/sp/protocol/pubsub0/pub_test.c
index a2a20dd7..8b3a5d78 100644
--- a/src/sp/protocol/pubsub0/pub_test.c
+++ b/src/sp/protocol/pubsub0/pub_test.c
@@ -160,103 +160,6 @@ test_pub_send_queued(void)
 	NUTS_CLOSE(pub);
 	NUTS_CLOSE(sub);
 }
-static void
-test_sub_recv_ctx_closed(void)
-{
-	nng_socket sub;
-	nng_ctx    ctx;
-	nng_aio   *aio;
-	NUTS_PASS(nng_sub0_open(&sub));
-	NUTS_PASS(nng_ctx_open(&ctx, sub));
-	NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL));
-	nng_ctx_close(ctx);
-	nng_ctx_recv(ctx, aio);
-	nng_aio_wait(aio);
-	NUTS_FAIL(nng_aio_result(aio), NNG_ECLOSED);
-	nng_aio_free(aio);
-	NUTS_CLOSE(sub);
-}
-
-static void
-test_sub_ctx_recv_aio_stopped(void)
-{
-	nng_socket sub;
-	nng_ctx    ctx;
-	nng_aio   *aio;
-
-	NUTS_PASS(nng_sub0_open(&sub));
-	NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL));
-	NUTS_PASS(nng_ctx_open(&ctx, sub));
-
-	nng_aio_stop(aio);
-	nng_ctx_recv(ctx, aio);
-	nng_aio_wait(aio);
-	NUTS_FAIL(nng_aio_result(aio), NNG_ECANCELED);
-	NUTS_PASS(nng_ctx_close(ctx));
-	NUTS_CLOSE(sub);
-	nng_aio_free(aio);
-}
-
-static void
-test_sub_close_context_recv(void)
-{
-	nng_socket sub;
-	nng_ctx    ctx;
-	nng_aio   *aio;
-
-	NUTS_PASS(nng_sub0_open(&sub));
-	NUTS_PASS(nng_ctx_open(&ctx, sub));
-	NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL));
-	nng_aio_set_timeout(aio, 1000);
-	nng_ctx_recv(ctx, aio);
-	NUTS_PASS(nng_ctx_close(ctx));
-	nng_aio_wait(aio);
-	NUTS_FAIL(nng_aio_result(aio), NNG_ECLOSED);
-
-	NUTS_CLOSE(sub);
-	nng_aio_free(aio);
-}
-
-static void
-test_sub_ctx_recv_nonblock(void)
-{
-	nng_socket sub;
-	nng_ctx    ctx;
-	nng_aio   *aio;
-
-	NUTS_PASS(nng_sub0_open(&sub));
-	NUTS_PASS(nng_ctx_open(&ctx, sub));
-	NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL));
-
-	nng_aio_set_timeout(aio, 0); // Instant timeout
-	nng_ctx_recv(ctx, aio);
-
-	nng_aio_wait(aio);
-	NUTS_FAIL(nng_aio_result(aio), NNG_ETIMEDOUT);
-	NUTS_CLOSE(sub);
-	nng_aio_free(aio);
-}
-
-static void
-test_sub_ctx_recv_cancel(void)
-{
-	nng_socket sub;
-	nng_ctx    ctx;
-	nng_aio   *aio;
-
-	NUTS_PASS(nng_sub0_open(&sub));
-	NUTS_PASS(nng_ctx_open(&ctx, sub));
-	NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL));
-
-	nng_aio_set_timeout(aio, 1000);
-	nng_ctx_recv(ctx, aio);
-	nng_aio_abort(aio, NNG_ECANCELED);
-
-	nng_aio_wait(aio);
-	NUTS_FAIL(nng_aio_result(aio), NNG_ECANCELED);
-	NUTS_CLOSE(sub);
-	nng_aio_free(aio);
-}
 
 static void
 test_pub_send_buf_option(void)
@@ -308,11 +211,6 @@ NUTS_TESTS = {
 	{ "pub validate peer", test_pub_validate_peer },
 	{ "pub send queued", test_pub_send_queued },
 	{ "pub send no pipes", test_pub_send_no_pipes },
-	{ "sub recv ctx closed", test_sub_recv_ctx_closed },
-	{ "sub recv aio ctx stopped", test_sub_ctx_recv_aio_stopped },
-	{ "sub close context recv", test_sub_close_context_recv },
-	{ "sub context recv nonblock", test_sub_ctx_recv_nonblock },
-	{ "sub context recv cancel", test_sub_ctx_recv_cancel },
 	{ "pub send buf option", test_pub_send_buf_option },
 	{ "pub cooked", test_pub_cooked },
 	{ NULL, NULL },