diff options
Diffstat (limited to 'src/protocol/pubsub0/pub_test.c')
| -rw-r--r-- | src/protocol/pubsub0/pub_test.c | 260 |
1 files changed, 124 insertions, 136 deletions
diff --git a/src/protocol/pubsub0/pub_test.c b/src/protocol/pubsub0/pub_test.c index 94d5c333..a430b610 100644 --- a/src/protocol/pubsub0/pub_test.c +++ b/src/protocol/pubsub0/pub_test.c @@ -7,18 +7,7 @@ // found online at https://opensource.org/licenses/MIT. // -#include <string.h> - -#include <nng/nng.h> -#include <nng/protocol/pubsub0/pub.h> -#include <nng/protocol/pubsub0/sub.h> - -#include <acutest.h> -#include <testutil.h> - -#ifndef NNI_PROTO -#define NNI_PROTO(x, y) (((x) << 4u) | (y)) -#endif +#include <nuts.h> static void test_pub_identity(void) @@ -27,18 +16,18 @@ test_pub_identity(void) int p; char * n; - TEST_NNG_PASS(nng_pub0_open(&s)); - TEST_NNG_PASS(nng_getopt_int(s, NNG_OPT_PROTO, &p)); - TEST_CHECK(p == NNI_PROTO(2u, 0u)); // 32 - TEST_NNG_PASS(nng_getopt_int(s, NNG_OPT_PEER, &p)); - TEST_CHECK(p == NNI_PROTO(2u, 1u)); // 33 - TEST_NNG_PASS(nng_getopt_string(s, NNG_OPT_PROTONAME, &n)); - TEST_CHECK(strcmp(n, "pub") == 0); + NUTS_PASS(nng_pub0_open(&s)); + NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p)); + NUTS_TRUE(p == NUTS_PROTO(2u, 0u)); // 32 + NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p)); + NUTS_TRUE(p == NUTS_PROTO(2u, 1u)); // 33 + NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n)); + NUTS_MATCH(n, "pub"); nng_strfree(n); - TEST_NNG_PASS(nng_getopt_string(s, NNG_OPT_PEERNAME, &n)); - TEST_CHECK(strcmp(n, "sub") == 0); + NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n)); + NUTS_MATCH(n, "sub"); nng_strfree(n); - TEST_NNG_PASS(nng_close(s)); + NUTS_CLOSE(s); } static void @@ -46,9 +35,9 @@ test_pub_cannot_recv(void) { nng_socket pub; - TEST_NNG_PASS(nng_pub0_open(&pub)); - TEST_NNG_FAIL(nng_recv(pub, "", 0, 0), NNG_ENOTSUP); - TEST_NNG_PASS(nng_close(pub)); + NUTS_PASS(nng_pub0_open(&pub)); + NUTS_FAIL(nng_recv(pub, "", 0, 0), NNG_ENOTSUP); + NUTS_CLOSE(pub); } static void @@ -57,9 +46,9 @@ test_pub_no_context(void) nng_socket pub; nng_ctx ctx; - TEST_NNG_PASS(nng_pub0_open(&pub)); - TEST_NNG_FAIL(nng_ctx_open(&ctx, pub), NNG_ENOTSUP); - TEST_NNG_PASS(nng_close(pub)); + NUTS_PASS(nng_pub0_open(&pub)); + NUTS_FAIL(nng_ctx_open(&ctx, pub), NNG_ENOTSUP); + NUTS_CLOSE(pub); } static void @@ -68,9 +57,9 @@ test_pub_not_readable(void) int fd; nng_socket pub; - TEST_NNG_PASS(nng_pub0_open(&pub)); - TEST_NNG_FAIL(nng_getopt_int(pub, NNG_OPT_RECVFD, &fd), NNG_ENOTSUP); - TEST_NNG_PASS(nng_close(pub)); + NUTS_PASS(nng_pub0_open(&pub)); + NUTS_FAIL(nng_socket_get_int(pub, NNG_OPT_RECVFD, &fd), NNG_ENOTSUP); + NUTS_CLOSE(pub); } static void @@ -80,25 +69,24 @@ test_pub_poll_writeable(void) nng_socket pub; nng_socket sub; - TEST_NNG_PASS(nng_sub0_open(&sub)); - TEST_NNG_PASS(nng_pub0_open(&pub)); - TEST_NNG_PASS(nng_getopt_int(pub, NNG_OPT_SENDFD, &fd)); - TEST_CHECK(fd >= 0); + NUTS_PASS(nng_sub0_open(&sub)); + NUTS_PASS(nng_pub0_open(&pub)); + NUTS_PASS(nng_socket_get_int(pub, NNG_OPT_SENDFD, &fd)); + NUTS_TRUE(fd >= 0); // Pub is *always* writeable - TEST_CHECK(testutil_pollfd(fd) == true); + NUTS_TRUE(nuts_poll_fd(fd)); // Even after connect (no message yet) - TEST_NNG_PASS(testutil_marry(pub, sub)); - TEST_CHECK(testutil_pollfd(fd) == true); + NUTS_MARRY(pub, sub); + NUTS_TRUE(nuts_poll_fd(fd)); - // But once we send messages, it is. - // We have to send a request, in order to send a reply. - TEST_NNG_SEND_STR(pub, "abc"); - TEST_CHECK(testutil_pollfd(fd) == true); + // Even if we send messages. + NUTS_SEND(pub, "abc"); + NUTS_TRUE(nuts_poll_fd(fd)); - TEST_NNG_PASS(nng_close(pub)); - TEST_NNG_PASS(nng_close(sub)); + NUTS_CLOSE(pub); + NUTS_CLOSE(sub); } static void @@ -106,10 +94,10 @@ test_pub_send_no_pipes(void) { nng_socket pub; - TEST_NNG_PASS(nng_pub0_open(&pub)); - TEST_NNG_SEND_STR(pub, "DROP1"); - TEST_NNG_SEND_STR(pub, "DROP2"); - TEST_NNG_PASS(nng_close(pub)); + NUTS_PASS(nng_pub0_open(&pub)); + NUTS_SEND(pub, "DROP1"); + NUTS_SEND(pub, "DROP2"); + NUTS_CLOSE(pub); } void @@ -118,28 +106,28 @@ test_pub_validate_peer(void) nng_socket s1, s2; nng_stat * stats; nng_stat * reject; - char addr[64]; + char *addr; - testutil_scratch_addr("inproc", sizeof(addr), addr); + NUTS_ADDR(addr, "inproc"); - TEST_NNG_PASS(nng_pub0_open(&s1)); - TEST_NNG_PASS(nng_pub0_open(&s2)); + NUTS_PASS(nng_pub0_open(&s1)); + NUTS_PASS(nng_pub0_open(&s2)); - TEST_NNG_PASS(nng_listen(s1, addr, NULL, 0)); - TEST_NNG_PASS(nng_dial(s2, addr, NULL, NNG_FLAG_NONBLOCK)); + NUTS_PASS(nng_listen(s1, addr, NULL, 0)); + NUTS_PASS(nng_dial(s2, addr, NULL, NNG_FLAG_NONBLOCK)); - testutil_sleep(100); - TEST_NNG_PASS(nng_stats_get(&stats)); + NUTS_SLEEP(100); + NUTS_PASS(nng_stats_get(&stats)); - TEST_CHECK(stats != NULL); - TEST_CHECK((reject = nng_stat_find_socket(stats, s1)) != NULL); - TEST_CHECK((reject = nng_stat_find(reject, "reject")) != NULL); + NUTS_TRUE(stats != NULL); + NUTS_TRUE((reject = nng_stat_find_socket(stats, s1)) != NULL); + NUTS_TRUE((reject = nng_stat_find(reject, "reject")) != NULL); - TEST_CHECK(nng_stat_type(reject) == NNG_STAT_COUNTER); - TEST_CHECK(nng_stat_value(reject) > 0); + NUTS_TRUE(nng_stat_type(reject) == NNG_STAT_COUNTER); + NUTS_TRUE(nng_stat_value(reject) > 0); - TEST_NNG_PASS(nng_close(s1)); - TEST_NNG_PASS(nng_close(s2)); + NUTS_CLOSE(s1); + NUTS_CLOSE(s2); nng_stats_free(stats); } @@ -152,26 +140,26 @@ test_pub_send_queued(void) // MB: What we really need is a mock so that we can send harder // than we receive -- we need a way to apply back-pressure for this // test to be really meaningful. - TEST_NNG_PASS(nng_pub0_open(&pub)); - TEST_NNG_PASS(nng_sub0_open(&sub)); - TEST_NNG_PASS(nng_setopt(sub, NNG_OPT_SUB_SUBSCRIBE, "", 0)); - TEST_NNG_PASS(nng_setopt_int(pub, NNG_OPT_SENDBUF, 10)); - TEST_NNG_PASS(nng_setopt_int(sub, NNG_OPT_RECVBUF, 10)); - TEST_NNG_PASS(nng_setopt_ms(pub, NNG_OPT_SENDTIMEO, 1000)); - TEST_NNG_PASS(nng_setopt_ms(sub, NNG_OPT_RECVTIMEO, 1000)); - TEST_NNG_PASS(testutil_marry(pub, sub)); - TEST_NNG_SEND_STR(pub, "first"); - TEST_NNG_SEND_STR(pub, "second"); - TEST_NNG_SEND_STR(pub, "three musketeers"); - TEST_NNG_SEND_STR(pub, "four"); - testutil_sleep(50); - TEST_NNG_RECV_STR(sub, "first"); - TEST_NNG_RECV_STR(sub, "second"); - TEST_NNG_RECV_STR(sub, "three musketeers"); - TEST_NNG_RECV_STR(sub, "four"); - - TEST_NNG_PASS(nng_close(pub)); - TEST_NNG_PASS(nng_close(sub)); + NUTS_PASS(nng_pub0_open(&pub)); + NUTS_PASS(nng_sub0_open(&sub)); + NUTS_PASS(nng_socket_set(sub, NNG_OPT_SUB_SUBSCRIBE, "", 0)); + NUTS_PASS(nng_socket_set_int(pub, NNG_OPT_SENDBUF, 10)); + NUTS_PASS(nng_socket_set_int(sub, NNG_OPT_RECVBUF, 10)); + NUTS_PASS(nng_socket_set_ms(pub, NNG_OPT_SENDTIMEO, 1000)); + NUTS_PASS(nng_socket_set_ms(sub, NNG_OPT_RECVTIMEO, 1000)); + NUTS_MARRY(pub, sub); + NUTS_SEND(pub, "first"); + NUTS_SEND(pub, "second"); + NUTS_SEND(pub, "three musketeers"); + NUTS_SEND(pub, "four"); + NUTS_SLEEP(50); + NUTS_RECV(sub, "first"); + NUTS_RECV(sub, "second"); + NUTS_RECV(sub, "three musketeers"); + NUTS_RECV(sub, "four"); + + NUTS_CLOSE(pub); + NUTS_CLOSE(sub); } static void test_sub_recv_ctx_closed(void) @@ -179,15 +167,15 @@ test_sub_recv_ctx_closed(void) nng_socket sub; nng_ctx ctx; nng_aio * aio; - TEST_NNG_PASS(nng_sub0_open(&sub)); - TEST_NNG_PASS(nng_ctx_open(&ctx, sub)); - TEST_NNG_PASS(nng_aio_alloc(&aio, NULL, NULL)); + 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); - TEST_NNG_FAIL(nng_aio_result(aio), NNG_ECLOSED); + NUTS_FAIL(nng_aio_result(aio), NNG_ECLOSED); nng_aio_free(aio); - TEST_NNG_PASS(nng_close(sub)); + NUTS_CLOSE(sub); } static void @@ -197,16 +185,16 @@ test_sub_ctx_recv_aio_stopped(void) nng_ctx ctx; nng_aio * aio; - TEST_NNG_PASS(nng_sub0_open(&sub)); - TEST_NNG_PASS(nng_aio_alloc(&aio, NULL, NULL)); - TEST_NNG_PASS(nng_ctx_open(&ctx, sub)); + 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); - TEST_NNG_FAIL(nng_aio_result(aio), NNG_ECANCELED); - TEST_NNG_PASS(nng_ctx_close(ctx)); - TEST_NNG_PASS(nng_close(sub)); + NUTS_FAIL(nng_aio_result(aio), NNG_ECANCELED); + NUTS_PASS(nng_ctx_close(ctx)); + NUTS_CLOSE(sub); nng_aio_free(aio); } @@ -217,16 +205,16 @@ test_sub_close_context_recv(void) nng_ctx ctx; nng_aio * aio; - TEST_NNG_PASS(nng_sub0_open(&sub)); - TEST_NNG_PASS(nng_ctx_open(&ctx, sub)); - TEST_NNG_PASS(nng_aio_alloc(&aio, NULL, NULL)); + 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); - TEST_NNG_PASS(nng_ctx_close(ctx)); + NUTS_PASS(nng_ctx_close(ctx)); nng_aio_wait(aio); - TEST_NNG_FAIL(nng_aio_result(aio), NNG_ECLOSED); + NUTS_FAIL(nng_aio_result(aio), NNG_ECLOSED); - TEST_NNG_PASS(nng_close(sub)); + NUTS_CLOSE(sub); nng_aio_free(aio); } @@ -237,16 +225,16 @@ test_sub_ctx_recv_nonblock(void) nng_ctx ctx; nng_aio * aio; - TEST_NNG_PASS(nng_sub0_open(&sub)); - TEST_NNG_PASS(nng_ctx_open(&ctx, sub)); - TEST_NNG_PASS(nng_aio_alloc(&aio, NULL, NULL)); + 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); - TEST_NNG_FAIL(nng_aio_result(aio), NNG_ETIMEDOUT); - TEST_NNG_PASS(nng_close(sub)); + NUTS_FAIL(nng_aio_result(aio), NNG_ETIMEDOUT); + NUTS_CLOSE(sub); nng_aio_free(aio); } @@ -257,17 +245,17 @@ test_sub_ctx_recv_cancel(void) nng_ctx ctx; nng_aio * aio; - TEST_NNG_PASS(nng_sub0_open(&sub)); - TEST_NNG_PASS(nng_ctx_open(&ctx, sub)); - TEST_NNG_PASS(nng_aio_alloc(&aio, NULL, NULL)); + 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); - TEST_NNG_FAIL(nng_aio_result(aio), NNG_ECANCELED); - TEST_NNG_PASS(nng_close(sub)); + NUTS_FAIL(nng_aio_result(aio), NNG_ECANCELED); + NUTS_CLOSE(sub); nng_aio_free(aio); } @@ -280,28 +268,28 @@ test_pub_send_buf_option(void) size_t sz; const char *opt = NNG_OPT_SENDBUF; - TEST_NNG_PASS(nng_pub0_open(&pub)); + NUTS_PASS(nng_pub0_open(&pub)); - TEST_NNG_PASS(nng_setopt_int(pub, opt, 1)); - TEST_NNG_FAIL(nng_setopt_int(pub, opt, 0), NNG_EINVAL); - TEST_NNG_FAIL(nng_setopt_int(pub, opt, -1), NNG_EINVAL); - TEST_NNG_FAIL(nng_setopt_int(pub, opt, 1000000), NNG_EINVAL); - TEST_NNG_PASS(nng_setopt_int(pub, opt, 3)); - TEST_NNG_PASS(nng_getopt_int(pub, opt, &v)); - TEST_CHECK(v == 3); + NUTS_PASS(nng_socket_set_int(pub, opt, 1)); + NUTS_FAIL(nng_socket_set_int(pub, opt, 0), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(pub, opt, -1), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(pub, opt, 1000000), NNG_EINVAL); + NUTS_PASS(nng_socket_set_int(pub, opt, 3)); + NUTS_PASS(nng_socket_get_int(pub, opt, &v)); + NUTS_TRUE(v == 3); v = 0; sz = sizeof(v); - TEST_NNG_PASS(nng_getopt(pub, opt, &v, &sz)); - TEST_CHECK(v == 3); - TEST_CHECK(sz == sizeof(v)); + NUTS_PASS(nng_socket_get(pub, opt, &v, &sz)); + NUTS_TRUE(v == 3); + NUTS_TRUE(sz == sizeof(v)); - TEST_NNG_FAIL(nng_setopt(pub, opt, "", 1), NNG_EINVAL); + NUTS_FAIL(nng_socket_set(pub, opt, "", 1), NNG_EINVAL); sz = 1; - TEST_NNG_FAIL(nng_getopt(pub, opt, &v, &sz), NNG_EINVAL); - TEST_NNG_FAIL(nng_setopt_bool(pub, opt, true), NNG_EBADTYPE); - TEST_NNG_FAIL(nng_getopt_bool(pub, opt, &b), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_get(pub, opt, &v, &sz), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_bool(pub, opt, true), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_get_bool(pub, opt, &b), NNG_EBADTYPE); - TEST_NNG_PASS(nng_close(pub)); + NUTS_CLOSE(pub); } static void @@ -310,20 +298,20 @@ test_pub_cooked(void) nng_socket s; bool b; - TEST_NNG_PASS(nng_pub0_open(&s)); - TEST_NNG_PASS(nng_getopt_bool(s, NNG_OPT_RAW, &b)); - TEST_CHECK(!b); - TEST_NNG_FAIL(nng_setopt_bool(s, NNG_OPT_RAW, true), NNG_EREADONLY); - TEST_NNG_PASS(nng_close(s)); + NUTS_PASS(nng_pub0_open(&s)); + NUTS_PASS(nng_socket_get_bool(s, NNG_OPT_RAW, &b)); + NUTS_TRUE(!b); + NUTS_FAIL(nng_socket_set_bool(s, NNG_OPT_RAW, true), NNG_EREADONLY); + NUTS_PASS(nng_close(s)); // raw pub only differs in the option setting - TEST_NNG_PASS(nng_pub0_open_raw(&s)); - TEST_NNG_PASS(nng_getopt_bool(s, NNG_OPT_RAW, &b)); - TEST_CHECK(b); - TEST_NNG_PASS(nng_close(s)); + NUTS_PASS(nng_pub0_open_raw(&s)); + NUTS_PASS(nng_socket_get_bool(s, NNG_OPT_RAW, &b)); + NUTS_TRUE(b); + NUTS_CLOSE(s); } -TEST_LIST = { +NUTS_TESTS = { { "pub identity", test_pub_identity }, { "pub cannot recv", test_pub_cannot_recv }, { "put no context", test_pub_no_context }, |