diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-08-14 11:58:38 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-08-14 13:43:01 -0700 |
| commit | 4fb81f024e5f32a186cd5538574f8e5796980e36 (patch) | |
| tree | e8fedc5f01c9f381e590f3de8986515093d63699 /tests/compat_reqttl.c | |
| parent | 827aed05d352c470c8b4b8a7e232e21e1cd19313 (diff) | |
| download | nng-4fb81f024e5f32a186cd5538574f8e5796980e36.tar.gz nng-4fb81f024e5f32a186cd5538574f8e5796980e36.tar.bz2 nng-4fb81f024e5f32a186cd5538574f8e5796980e36.zip | |
REP drops peers a little too aggressively.
We noticed that certain failure modes were exposed in tests that were
caused by us closing the underlying pipe when certain messaging errors
occurred. Discarding the pipe is the wrong answer; instead we should
discard the message and keep the pipe open (unless the message is so
malformed that the remote party cannot be trusted.)
Diffstat (limited to 'tests/compat_reqttl.c')
| -rw-r--r-- | tests/compat_reqttl.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/tests/compat_reqttl.c b/tests/compat_reqttl.c index ad9ec71a..c758f92e 100644 --- a/tests/compat_reqttl.c +++ b/tests/compat_reqttl.c @@ -57,8 +57,8 @@ int main (int argc, const char *argv[]) int port = get_test_port(argc, argv); - test_addr_from(socket_address_a, "inproc", "127.0.0.1", port); - test_addr_from(socket_address_b, "inproc", "127.0.0.1", port + 1); + test_addr_from(socket_address_a, "tcp", "127.0.0.1", port); + test_addr_from(socket_address_b, "tcp", "127.0.0.1", port + 1); /* Intialise the device sockets. */ dev0 = test_socket (AF_SP_RAW, NN_REP); @@ -78,13 +78,13 @@ int main (int argc, const char *argv[]) test_connect (end1, socket_address_b); /* Wait for TCP to establish. */ - nn_sleep (200); + nn_sleep (100); /* Pass a message between endpoints. */ /* Set up max receive timeout. */ - timeo = 500; + timeo = 100; test_setsockopt (end0, NN_SOL_SOCKET, NN_RCVTIMEO, &timeo, sizeof (timeo)); - timeo = 500; + timeo = 100; test_setsockopt (end1, NN_SOL_SOCKET, NN_RCVTIMEO, &timeo, sizeof (timeo)); /* Test default TTL is 8. */ |