diff options
| author | Garrett D'Amore <garrett@damore.org> | 2024-10-06 22:44:25 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2024-10-06 22:44:25 -0700 |
| commit | 1a4d71cdd4ff80bb79d842c081296c298e7b2295 (patch) | |
| tree | 4801094c1fa80918677f7e29a0a9f3c7850d9a80 /src | |
| parent | 2592bfc8b7eb3dad7ca17bdd2e0c5ac7755dbab8 (diff) | |
| download | nng-1a4d71cdd4ff80bb79d842c081296c298e7b2295.tar.gz nng-1a4d71cdd4ff80bb79d842c081296c298e7b2295.tar.bz2 nng-1a4d71cdd4ff80bb79d842c081296c298e7b2295.zip | |
fix aio test failures on darwin
Actually this test appears to be broken everywhere, and the only
reason it ever worked is that we took > 50 ms to context switch.
Diffstat (limited to 'src')
| -rw-r--r-- | src/core/aio_test.c | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/src/core/aio_test.c b/src/core/aio_test.c index fb0f5c34..3e040fe1 100644 --- a/src/core/aio_test.c +++ b/src/core/aio_test.c @@ -101,7 +101,7 @@ test_provider_cancel(void) void test_consumer_cancel(void) { - nng_aio * a; + nng_aio *a; nng_socket s1; int done = 0; @@ -124,12 +124,12 @@ test_traffic(void) { nng_socket s1; nng_socket s2; - nng_aio * tx_aio; - nng_aio * rx_aio; + nng_aio *tx_aio; + nng_aio *rx_aio; int tx_done = 0; int rx_done = 0; - nng_msg * m; - char * addr = "inproc://traffic"; + nng_msg *m; + char *addr = "inproc://traffic"; NUTS_PASS(nng_pair1_open(&s1)); NUTS_PASS(nng_pair1_open(&s2)); @@ -176,7 +176,7 @@ void test_explicit_timeout(void) { nng_socket s; - nng_aio * a; + nng_aio *a; int done = 0; NUTS_PASS(nng_pair1_open(&s)); @@ -194,9 +194,9 @@ void test_explicit_expiration(void) { nng_socket s; - nng_aio * a; + nng_aio *a; int done = 0; - nng_time now; + nng_time now; NUTS_PASS(nng_pair1_open(&s)); NUTS_PASS(nng_aio_alloc(&a, cb_done, &done)); @@ -215,7 +215,7 @@ void test_inherited_timeout(void) { nng_socket s; - nng_aio * a; + nng_aio *a; int done = 0; NUTS_PASS(nng_pair1_open(&s)); @@ -233,7 +233,7 @@ void test_zero_timeout(void) { nng_socket s; - nng_aio * a; + nng_aio *a; int done = 0; NUTS_PASS(nng_pair1_open(&s)); @@ -264,14 +264,14 @@ test_aio_reap(void) } typedef struct sleep_loop { - nng_aio * aio; + nng_aio *aio; int limit; int count; int result; bool done; nng_duration interval; - nng_cv * cv; - nng_mtx * mx; + nng_cv *cv; + nng_mtx *mx; } sleep_loop; static void @@ -363,7 +363,7 @@ test_sleep_cancel(void) NUTS_PASS(nng_cv_alloc(&sl.cv, sl.mx)); start = nng_clock(); - nng_sleep_aio(100, sl.aio); + nng_sleep_aio(500, sl.aio); nng_msleep(150); nng_aio_cancel(sl.aio); nng_mtx_lock(sl.mx); @@ -386,7 +386,7 @@ test_sleep_cancel(void) } void - test_aio_busy(void) +test_aio_busy(void) { nng_aio *aio; NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); @@ -413,4 +413,4 @@ NUTS_TESTS = { { "sleep cancel", test_sleep_cancel }, { "aio busy", test_aio_busy }, { NULL, NULL }, -};
\ No newline at end of file +}; |