diff options
| author | Evgeny Ermakov <22344340+unspecd@users.noreply.github.com> | 2021-01-02 04:09:55 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-01-02 01:09:55 -0800 |
| commit | 44b8e23f39e4753ba8e9b7999dd5158adaecb5dc (patch) | |
| tree | 4ef7a61c40332be2520610a004b75983f329ac64 | |
| parent | ed542ac45e00c9b2faa0b41f3c00de6e291e5678 (diff) | |
| download | nng-44b8e23f39e4753ba8e9b7999dd5158adaecb5dc.tar.gz nng-44b8e23f39e4753ba8e9b7999dd5158adaecb5dc.tar.bz2 nng-44b8e23f39e4753ba8e9b7999dd5158adaecb5dc.zip | |
Fix compilation errors when NNG_ELIDE_DEPRECATED is ON (#1392)
| -rw-r--r-- | CMakeLists.txt | 2 | ||||
| -rw-r--r-- | src/compat/nanomsg/nn.c | 32 | ||||
| -rw-r--r-- | src/tools/nngcat/nngcat.c | 8 | ||||
| -rw-r--r-- | src/tools/perf/pubdrop.c | 6 |
4 files changed, 24 insertions, 24 deletions
diff --git a/CMakeLists.txt b/CMakeLists.txt index acd2a7f0..ebcce7f3 100644 --- a/CMakeLists.txt +++ b/CMakeLists.txt @@ -94,7 +94,7 @@ add_library(nng_private INTERFACE) target_compile_definitions(nng_private INTERFACE NNG_PRIVATE) if (NNG_ELIDE_DEPRECATED) - target_compile_definitions(nng, NNG_ELIDE_DEPRECATED) + target_compile_definitions(nng PRIVATE NNG_ELIDE_DEPRECATED) endif() diff --git a/src/compat/nanomsg/nn.c b/src/compat/nanomsg/nn.c index b6af8233..7c5d2383 100644 --- a/src/compat/nanomsg/nn.c +++ b/src/compat/nanomsg/nn.c @@ -238,7 +238,7 @@ nn_socket(int domain, int protocol) } // Legacy sockets have nodelay disabled. - (void) nng_setopt_bool(sock, NNG_OPT_TCP_NODELAY, false); + (void) nng_socket_set_bool(sock, NNG_OPT_TCP_NODELAY, false); return ((int) sock.id); } @@ -683,7 +683,7 @@ nn_getdomain(nng_socket s, void *valp, size_t *szp) bool b; int rv; - if ((rv = nng_getopt_bool(s, NNG_OPT_RAW, &b)) != 0) { + if ((rv = nng_socket_get_bool(s, NNG_OPT_RAW, &b)) != 0) { nn_seterror(rv); return (-1); } @@ -704,7 +704,7 @@ nn_getfd(nng_socket s, void *valp, size_t *szp, const char *opt) int rv; SOCKET sfd; - if ((rv = nng_getopt_int(s, opt, &ifd)) != 0) { + if ((rv = nng_socket_get_int(s, opt, &ifd)) != 0) { nn_seterror(rv); return (-1); } @@ -799,7 +799,7 @@ nn_settcpnodelay(nng_socket s, const void *valp, size_t sz) return (-1); } - if ((rv = nng_setopt_bool(s, NNG_OPT_TCP_NODELAY, val)) != 0) { + if ((rv = nng_socket_set_bool(s, NNG_OPT_TCP_NODELAY, val)) != 0) { nn_seterror(rv); return (-1); } @@ -813,7 +813,7 @@ nn_gettcpnodelay(nng_socket s, void *valp, size_t *szp) int ival; int rv; - if ((rv = nng_getopt_bool(s, NNG_OPT_TCP_NODELAY, &val)) != 0) { + if ((rv = nng_socket_get_bool(s, NNG_OPT_TCP_NODELAY, &val)) != 0) { nn_seterror(rv); return (-1); } @@ -829,7 +829,7 @@ nn_getrcvbuf(nng_socket s, void *valp, size_t *szp) int cnt; int rv; - if ((rv = nng_getopt_int(s, NNG_OPT_RECVBUF, &cnt)) != 0) { + if ((rv = nng_socket_get_int(s, NNG_OPT_RECVBUF, &cnt)) != 0) { nn_seterror(rv); return (-1); } @@ -855,7 +855,7 @@ nn_setrcvbuf(nng_socket s, const void *valp, size_t sz) // estimate, and assumes messages are 1kB on average. cnt += 1023; cnt /= 1024; - if ((rv = nng_setopt_int(s, NNG_OPT_RECVBUF, cnt)) != 0) { + if ((rv = nng_socket_set_int(s, NNG_OPT_RECVBUF, cnt)) != 0) { nn_seterror(rv); return (-1); } @@ -868,7 +868,7 @@ nn_getsndbuf(nng_socket s, void *valp, size_t *szp) int cnt; int rv; - if ((rv = nng_getopt_int(s, NNG_OPT_SENDBUF, &cnt)) != 0) { + if ((rv = nng_socket_get_int(s, NNG_OPT_SENDBUF, &cnt)) != 0) { nn_seterror(rv); return (-1); } @@ -894,7 +894,7 @@ nn_setsndbuf(nng_socket s, const void *valp, size_t sz) // estimate, and assumes messages are 1kB on average. cnt += 1023; cnt /= 1024; - if ((rv = nng_setopt_int(s, NNG_OPT_SENDBUF, cnt)) != 0) { + if ((rv = nng_socket_set_int(s, NNG_OPT_SENDBUF, cnt)) != 0) { nn_seterror(rv); return (-1); } @@ -923,7 +923,7 @@ nn_setrcvmaxsz(nng_socket s, const void *valp, size_t sz) errno = EINVAL; return (-1); } - if ((rv = nng_setopt_size(s, NNG_OPT_RECVMAXSZ, val)) != 0) { + if ((rv = nng_socket_set_size(s, NNG_OPT_RECVMAXSZ, val)) != 0) { nn_seterror(rv); return (-1); } @@ -937,7 +937,7 @@ nn_getrcvmaxsz(nng_socket s, void *valp, size_t *szp) int rv; size_t val; - if ((rv = nng_getopt_size(s, NNG_OPT_RECVMAXSZ, &val)) != 0) { + if ((rv = nng_socket_get_size(s, NNG_OPT_RECVMAXSZ, &val)) != 0) { nn_seterror(rv); return (-1); } @@ -1104,7 +1104,7 @@ nn_getsockopt(int s, int nnlevel, int nnopt, void *valp, size_t *szp) return (-1); } - if ((rv = nng_getopt(sid, name, valp, szp)) != 0) { + if ((rv = nng_socket_get(sid, name, valp, szp)) != 0) { nn_seterror(rv); return (-1); } @@ -1141,7 +1141,7 @@ nn_setsockopt(int s, int nnlevel, int nnopt, const void *valp, size_t sz) return (-1); } - if ((rv = nng_setopt(sid, name, valp, sz)) != 0) { + if ((rv = nng_socket_set(sid, name, valp, sz)) != 0) { nn_seterror(rv); return (-1); } @@ -1234,7 +1234,7 @@ nn_poll(struct nn_pollfd *fds, int nfds, int timeout) if (fds[i].events & NN_POLLIN) { nng_socket s; s.id = fds[i].fd; - if ((rv = nng_getopt_int(s, NNG_OPT_RECVFD, &fd)) != + if ((rv = nng_socket_get_int(s, NNG_OPT_RECVFD, &fd)) != 0) { nn_seterror(rv); NNI_FREE_STRUCTS(pfd, nfds * 2); @@ -1251,7 +1251,7 @@ nn_poll(struct nn_pollfd *fds, int nfds, int timeout) if (fds[i].events & NN_POLLOUT) { nng_socket s; s.id = fds[i].fd; - if ((rv = nng_getopt_int(s, NNG_OPT_SENDFD, &fd)) != + if ((rv = nng_socket_get_int(s, NNG_OPT_SENDFD, &fd)) != 0) { nn_seterror(rv); NNI_FREE_STRUCTS(pfd, nfds * 2); @@ -1317,7 +1317,7 @@ nn_term(void) // all sockets in the process, including those // in use by libraries, etc. Accordingly, do not use this // in a library -- only e.g. atexit() and similar. - nng_closeall(); + nni_sock_closeall(); } uint64_t diff --git a/src/tools/nngcat/nngcat.c b/src/tools/nngcat/nngcat.c index 9e106069..90a97d09 100644 --- a/src/tools/nngcat/nngcat.c +++ b/src/tools/nngcat/nngcat.c @@ -1105,7 +1105,7 @@ main(int ac, char **av) fatal("Unable to create dialer for %s: %s", a->val, nng_strerror(rv)); } - rv = nng_dialer_getopt_ptr( + rv = nng_dialer_get_ptr( d, NNG_OPT_TLS_CONFIG, (void **) &tls); if (rv == 0) { configtls(tls); @@ -1127,7 +1127,7 @@ main(int ac, char **av) char ustr[256]; size_t sz; sz = sizeof(ustr); - if (nng_dialer_getopt( + if (nng_dialer_get( d, NNG_OPT_URL, ustr, &sz) == 0) { printf("Connected to: %s\n", ustr); } @@ -1141,7 +1141,7 @@ main(int ac, char **av) fatal("Unable to create listener for %s: %s", a->val, nng_strerror(rv)); } - rv = nng_listener_getopt_ptr( + rv = nng_listener_get_ptr( l, NNG_OPT_TLS_CONFIG, (void **) &tls); if (rv == 0) { configtls(tls); @@ -1163,7 +1163,7 @@ main(int ac, char **av) char ustr[256]; size_t sz; sz = sizeof(ustr); - if (nng_listener_getopt( + if (nng_listener_get( l, NNG_OPT_URL, ustr, &sz) == 0) { printf("Listening at: %s\n", ustr); } diff --git a/src/tools/perf/pubdrop.c b/src/tools/perf/pubdrop.c index be51bb2f..41ac5ba0 100644 --- a/src/tools/perf/pubdrop.c +++ b/src/tools/perf/pubdrop.c @@ -202,13 +202,13 @@ sub_client(void *arg) if ((rv = nng_dial(sock, pa->addr, NULL, 0)) != 0) { die("Cannot listen: %s", nng_strerror(rv)); } - if ((rv = nng_setopt_ms(sock, NNG_OPT_RECONNMINT, 51)) != 0) { + if ((rv = nng_socket_set_ms(sock, NNG_OPT_RECONNMINT, 51)) != 0) { die("setopt: %s", nng_strerror(rv)); } - if ((rv = nng_setopt(sock, NNG_OPT_SUB_SUBSCRIBE, "", 0)) != 0) { + if ((rv = nng_socket_set(sock, NNG_OPT_SUB_SUBSCRIBE, "", 0)) != 0) { die("setopt: %s", nng_strerror(rv)); } - if ((rv = nng_setopt_ms(sock, NNG_OPT_RECVTIMEO, 10000)) != 0) { + if ((rv = nng_socket_set_ms(sock, NNG_OPT_RECVTIMEO, 10000)) != 0) { die("setopt: %s", nng_strerror(rv)); } |
