diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-08-14 15:27:38 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-08-14 15:27:38 -0700 |
| commit | 63479c2938cbc80c1aac9367cb95564f6e7540e1 (patch) | |
| tree | 495584b637f73b593d25f01577eeaa944477f159 /tests/trantest.h | |
| parent | 343417234aa3fd86e8ae0b56ae500a1ed3411cfc (diff) | |
| download | nng-63479c2938cbc80c1aac9367cb95564f6e7540e1.tar.gz nng-63479c2938cbc80c1aac9367cb95564f6e7540e1.tar.bz2 nng-63479c2938cbc80c1aac9367cb95564f6e7540e1.zip | |
fixes #63 NNG_FLAG_SYNCH should be the default
Also enables creating endpoints that are idle (first part of
endpoint options API) and shutting down endpoints.
Diffstat (limited to 'tests/trantest.h')
| -rw-r--r-- | tests/trantest.h | 19 |
1 files changed, 8 insertions, 11 deletions
diff --git a/tests/trantest.h b/tests/trantest.h index 639d0632..84b54e34 100644 --- a/tests/trantest.h +++ b/tests/trantest.h @@ -84,11 +84,9 @@ trantest_conn_refused(trantest *tt) Convey("Connection refused works", { nng_dialer d = 0; - So(nng_dial(tt->reqsock, tt->addr, &d, NNG_FLAG_SYNCH) == - NNG_ECONNREFUSED); + So(nng_dial(tt->reqsock, tt->addr, &d, 0) == NNG_ECONNREFUSED); So(d == 0); - So(nng_dial(tt->repsock, tt->addr, &d, NNG_FLAG_SYNCH) == - NNG_ECONNREFUSED); + So(nng_dial(tt->repsock, tt->addr, &d, 0) == NNG_ECONNREFUSED); So(d == 0); }) } @@ -98,11 +96,10 @@ trantest_duplicate_listen(trantest *tt) { Convey("Duplicate listen rejected", { nng_listener l; - So(nng_listen(tt->repsock, tt->addr, &l, NNG_FLAG_SYNCH) == 0); + So(nng_listen(tt->repsock, tt->addr, &l, 0) == 0); So(l != 0); l = 0; - So(nng_listen(tt->reqsock, tt->addr, &l, NNG_FLAG_SYNCH) == - NNG_EADDRINUSE); + So(nng_listen(tt->reqsock, tt->addr, &l, 0) == NNG_EADDRINUSE); So(l == 0); }) } @@ -113,11 +110,11 @@ trantest_listen_accept(trantest *tt) Convey("Listen and accept", { nng_listener l; nng_dialer d; - So(nng_listen(tt->repsock, tt->addr, &l, NNG_FLAG_SYNCH) == 0); + So(nng_listen(tt->repsock, tt->addr, &l, 0) == 0); So(l != 0); d = 0; - So(nng_dial(tt->reqsock, tt->addr, &d, NNG_FLAG_SYNCH) == 0); + So(nng_dial(tt->reqsock, tt->addr, &d, 0) == 0); So(d != 0); }) } @@ -132,9 +129,9 @@ trantest_send_recv(trantest *tt) nng_msg * recv; size_t len; - So(nng_listen(tt->repsock, tt->addr, &l, NNG_FLAG_SYNCH) == 0); + So(nng_listen(tt->repsock, tt->addr, &l, 0) == 0); So(l != 0); - So(nng_dial(tt->reqsock, tt->addr, &d, NNG_FLAG_SYNCH) == 0); + So(nng_dial(tt->reqsock, tt->addr, &d, 0) == 0); So(d != 0); send = NULL; |