aboutsummaryrefslogtreecommitdiff
path: root/src/nng.c
diff options
context:
space:
mode:
authorJake Woltersdorf <jake@playruyi.com>2019-03-04 12:35:19 +0800
committerGarrett D'Amore <garrett@damore.org>2019-04-07 19:13:44 -0700
commitc3e062661388f70386d6766e3ce648030af340ee (patch)
treea6d247bd24a17e3201a75b1a164e75d16e37196c /src/nng.c
parent989c5e90d48066b12ad44ed903cfc163d8e89b29 (diff)
downloadnng-c3e062661388f70386d6766e3ce648030af340ee.tar.gz
nng-c3e062661388f70386d6766e3ce648030af340ee.tar.bz2
nng-c3e062661388f70386d6766e3ce648030af340ee.zip
fixes #901 shorter option get/set functions for all types
- Renamed internal nng_*_getx/setx methods with "nni" prefix - Moved stream get/set option definition macros to options.h and added "NNI_" prefix - "_PTR" variant of get/set option definition macros is for when first arg is passed as pointer (`nng_stream *s` vs `nng_pipe s`) - New get/set option functions for `nng_socket` are `nng_socket_get_X` eschewing the previous `nng_getopt` pattern - Macro-fy legacy getopt/setopt and implement in terms of "new" API - nng_setopt* use "new" shorter API. Add missing uint64 set functions. - Shorter get/set option functions get own man page and old getopt/setopt link to them - Built with -DNNG_ENABLE_DOC=ON and part of central libnng index - Update copyright
Diffstat (limited to 'src/nng.c')
-rw-r--r--src/nng.c417
1 files changed, 42 insertions, 375 deletions
diff --git a/src/nng.c b/src/nng.c
index abbf9c62..07adc64e 100644
--- a/src/nng.c
+++ b/src/nng.c
@@ -318,7 +318,7 @@ nng_ctx_send(nng_ctx cid, nng_aio *aio)
}
static int
-nng_ctx_getx(nng_ctx id, const char *n, void *v, size_t *szp, nni_type t)
+nni_ctx_getx(nng_ctx id, const char *n, void *v, size_t *szp, nni_type t)
{
nni_ctx *ctx;
int rv;
@@ -334,42 +334,8 @@ nng_ctx_getx(nng_ctx id, const char *n, void *v, size_t *szp, nni_type t)
return (rv);
}
-int
-nng_ctx_getopt(nng_ctx id, const char *name, void *val, size_t *szp)
-{
- return (nng_ctx_getx(id, name, val, szp, NNI_TYPE_OPAQUE));
-}
-
-int
-nng_ctx_getopt_bool(nng_ctx id, const char *name, bool *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_ctx_getx(id, name, vp, &sz, NNI_TYPE_BOOL));
-}
-
-int
-nng_ctx_getopt_int(nng_ctx id, const char *name, int *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_ctx_getx(id, name, vp, &sz, NNI_TYPE_INT32));
-}
-
-int
-nng_ctx_getopt_size(nng_ctx id, const char *name, size_t *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_ctx_getx(id, name, vp, &sz, NNI_TYPE_SIZE));
-}
-
-int
-nng_ctx_getopt_ms(nng_ctx id, const char *name, nng_duration *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_ctx_getx(id, name, vp, &sz, NNI_TYPE_DURATION));
-}
-
static int
-nng_ctx_setx(nng_ctx id, const char *n, const void *v, size_t sz, nni_type t)
+nni_ctx_setx(nng_ctx id, const char *n, const void *v, size_t sz, nni_type t)
{
nni_ctx *ctx;
int rv;
@@ -385,35 +351,8 @@ nng_ctx_setx(nng_ctx id, const char *n, const void *v, size_t sz, nni_type t)
return (rv);
}
-int
-nng_ctx_setopt(nng_ctx id, const char *name, const void *val, size_t sz)
-{
- return (nng_ctx_setx(id, name, val, sz, NNI_TYPE_OPAQUE));
-}
-
-int
-nng_ctx_setopt_bool(nng_ctx id, const char *name, bool v)
-{
- return (nng_ctx_setx(id, name, &v, sizeof(v), NNI_TYPE_BOOL));
-}
-
-int
-nng_ctx_setopt_int(nng_ctx id, const char *name, int v)
-{
- return (nng_ctx_setx(id, name, &v, sizeof(v), NNI_TYPE_INT32));
-}
-
-int
-nng_ctx_setopt_size(nng_ctx id, const char *name, size_t v)
-{
- return (nng_ctx_setx(id, name, &v, sizeof(v), NNI_TYPE_SIZE));
-}
-
-int
-nng_ctx_setopt_ms(nng_ctx id, const char *name, nng_duration v)
-{
- return (nng_ctx_setx(id, name, &v, sizeof(v), NNI_TYPE_DURATION));
-}
+NNI_LEGACY_DEFGETALL(ctx)
+NNI_LEGACY_DEFSETALL(ctx)
int
nng_dial(nng_socket sid, const char *addr, nng_dialer *dp, int flags)
@@ -559,7 +498,7 @@ nng_dialer_id(nng_dialer d)
}
static int
-nng_dialer_setx(
+nni_dialer_setx(
nng_dialer did, const char *n, const void *v, size_t sz, nni_type t)
{
nni_dialer *d;
@@ -577,7 +516,7 @@ nng_dialer_setx(
}
static int
-nng_dialer_getx(
+nni_dialer_getx(
nng_dialer did, const char *n, void *v, size_t *szp, nni_type t)
{
nni_dialer *d;
@@ -594,118 +533,11 @@ nng_dialer_getx(
return (rv);
}
-int
-nng_dialer_setopt(nng_dialer d, const char *name, const void *v, size_t sz)
-{
- return (nng_dialer_setx(d, name, v, sz, NNI_TYPE_OPAQUE));
-}
-
-int
-nng_dialer_setopt_bool(nng_dialer d, const char *name, bool v)
-{
- return (nng_dialer_setx(d, name, &v, sizeof(v), NNI_TYPE_BOOL));
-}
+NNI_LEGACY_DEFGETALL(dialer)
+NNI_LEGACY_DEFSETALL(dialer)
int
-nng_dialer_setopt_int(nng_dialer d, const char *name, int v)
-{
- return (nng_dialer_setx(d, name, &v, sizeof(v), NNI_TYPE_INT32));
-}
-
-int
-nng_dialer_setopt_size(nng_dialer d, const char *name, size_t v)
-{
- return (nng_dialer_setx(d, name, &v, sizeof(v), NNI_TYPE_SIZE));
-}
-
-int
-nng_dialer_setopt_ms(nng_dialer d, const char *name, nng_duration v)
-{
- return (nng_dialer_setx(d, name, &v, sizeof(v), NNI_TYPE_DURATION));
-}
-
-int
-nng_dialer_setopt_uint64(nng_dialer d, const char *name, uint64_t v)
-{
- return (nng_dialer_setx(d, name, &v, sizeof(v), NNI_TYPE_UINT64));
-}
-
-int
-nng_dialer_setopt_ptr(nng_dialer d, const char *name, void *v)
-{
- return (nng_dialer_setx(d, name, &v, sizeof(v), NNI_TYPE_POINTER));
-}
-
-int
-nng_dialer_setopt_string(nng_dialer d, const char *name, const char *v)
-{
- return (nng_dialer_setx(d, name, v, strlen(v) + 1, NNI_TYPE_STRING));
-}
-
-int
-nng_dialer_getopt(nng_dialer d, const char *name, void *val, size_t *szp)
-{
- return (nng_dialer_getx(d, name, val, szp, NNI_TYPE_OPAQUE));
-}
-
-int
-nng_dialer_getopt_bool(nng_dialer d, const char *name, bool *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_dialer_getx(d, name, vp, &sz, NNI_TYPE_BOOL));
-}
-
-int
-nng_dialer_getopt_int(nng_dialer d, const char *name, int *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_dialer_getx(d, name, vp, &sz, NNI_TYPE_INT32));
-}
-
-int
-nng_dialer_getopt_size(nng_dialer d, const char *name, size_t *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_dialer_getx(d, name, vp, &sz, NNI_TYPE_SIZE));
-}
-
-int
-nng_dialer_getopt_sockaddr(nng_dialer d, const char *name, nng_sockaddr *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_dialer_getx(d, name, vp, &sz, NNI_TYPE_SOCKADDR));
-}
-
-int
-nng_dialer_getopt_uint64(nng_dialer d, const char *name, uint64_t *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_dialer_getx(d, name, vp, &sz, NNI_TYPE_UINT64));
-}
-
-int
-nng_dialer_getopt_ptr(nng_dialer d, const char *name, void **vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_dialer_getx(d, name, vp, &sz, NNI_TYPE_POINTER));
-}
-
-int
-nng_dialer_getopt_string(nng_dialer d, const char *name, char **vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_dialer_getx(d, name, vp, &sz, NNI_TYPE_STRING));
-}
-
-int
-nng_dialer_getopt_ms(nng_dialer d, const char *name, nng_duration *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_dialer_getx(d, name, vp, &sz, NNI_TYPE_DURATION));
-}
-
-int
-nng_listener_setx(
+nni_listener_setx(
nng_listener lid, const char *name, const void *v, size_t sz, nni_type t)
{
nni_listener *l;
@@ -723,55 +555,7 @@ nng_listener_setx(
}
int
-nng_listener_setopt(nng_listener l, const char *name, const void *v, size_t sz)
-{
- return (nng_listener_setx(l, name, v, sz, NNI_TYPE_OPAQUE));
-}
-
-int
-nng_listener_setopt_bool(nng_listener l, const char *name, bool v)
-{
- return (nng_listener_setx(l, name, &v, sizeof(v), NNI_TYPE_BOOL));
-}
-
-int
-nng_listener_setopt_int(nng_listener l, const char *name, int v)
-{
- return (nng_listener_setx(l, name, &v, sizeof(v), NNI_TYPE_INT32));
-}
-
-int
-nng_listener_setopt_size(nng_listener l, const char *name, size_t v)
-{
- return (nng_listener_setx(l, name, &v, sizeof(v), NNI_TYPE_SIZE));
-}
-
-int
-nng_listener_setopt_ms(nng_listener l, const char *name, nng_duration v)
-{
- return (nng_listener_setx(l, name, &v, sizeof(v), NNI_TYPE_DURATION));
-}
-
-int
-nng_listener_setopt_uint64(nng_listener l, const char *name, uint64_t v)
-{
- return (nng_listener_setx(l, name, &v, sizeof(v), NNI_TYPE_UINT64));
-}
-
-int
-nng_listener_setopt_ptr(nng_listener l, const char *name, void *v)
-{
- return (nng_listener_setx(l, name, &v, sizeof(v), NNI_TYPE_POINTER));
-}
-
-int
-nng_listener_setopt_string(nng_listener l, const char *n, const char *v)
-{
- return (nng_listener_setx(l, n, v, strlen(v) + 1, NNI_TYPE_STRING));
-}
-
-int
-nng_listener_getx(
+nni_listener_getx(
nng_listener lid, const char *name, void *v, size_t *szp, nni_type t)
{
nni_listener *l;
@@ -788,68 +572,8 @@ nng_listener_getx(
return (rv);
}
-int
-nng_listener_getopt(nng_listener l, const char *name, void *v, size_t *szp)
-{
- return (nng_listener_getx(l, name, v, szp, NNI_TYPE_OPAQUE));
-}
-
-int
-nng_listener_getopt_bool(nng_listener l, const char *name, bool *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_listener_getx(l, name, vp, &sz, NNI_TYPE_BOOL));
-}
-
-int
-nng_listener_getopt_int(nng_listener l, const char *name, int *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_listener_getx(l, name, vp, &sz, NNI_TYPE_INT32));
-}
-
-int
-nng_listener_getopt_size(nng_listener l, const char *name, size_t *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_listener_getx(l, name, vp, &sz, NNI_TYPE_SIZE));
-}
-
-int
-nng_listener_getopt_sockaddr(
- nng_listener l, const char *name, nng_sockaddr *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_listener_getx(l, name, vp, &sz, NNI_TYPE_SOCKADDR));
-}
-
-int
-nng_listener_getopt_uint64(nng_listener l, const char *name, uint64_t *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_listener_getx(l, name, vp, &sz, NNI_TYPE_UINT64));
-}
-
-int
-nng_listener_getopt_ptr(nng_listener l, const char *name, void **vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_listener_getx(l, name, vp, &sz, NNI_TYPE_POINTER));
-}
-
-int
-nng_listener_getopt_string(nng_listener l, const char *name, char **vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_listener_getx(l, name, vp, &sz, NNI_TYPE_STRING));
-}
-
-int
-nng_listener_getopt_ms(nng_listener l, const char *name, nng_duration *vp)
-{
- size_t sz = sizeof(*vp);
- return (nng_listener_getx(l, name, vp, &sz, NNI_TYPE_DURATION));
-}
+NNI_LEGACY_DEFGETALL(listener)
+NNI_LEGACY_DEFSETALL(listener)
int
nng_dialer_close(nng_dialer did)
@@ -878,7 +602,7 @@ nng_listener_close(nng_listener lid)
}
static int
-nng_setx(
+nni_socket_setx(
nng_socket s, const char *name, const void *val, size_t sz, nni_type t)
{
nni_sock *sock;
@@ -898,11 +622,11 @@ nng_setx(
int
nng_setopt(nng_socket s, const char *name, const void *val, size_t sz)
{
- return (nng_setx(s, name, val, sz, NNI_TYPE_OPAQUE));
+ return (nng_socket_set(s, name, val, sz));
}
static int
-nng_getx(nng_socket s, const char *name, void *val, size_t *szp, nni_type t)
+nni_socket_getx(nng_socket s, const char *name, void *val, size_t *szp, nni_type t)
{
nni_sock *sock;
int rv;
@@ -921,99 +645,92 @@ nng_getx(nng_socket s, const char *name, void *val, size_t *szp, nni_type t)
int
nng_getopt(nng_socket s, const char *name, void *val, size_t *szp)
{
- return (nng_getx(s, name, val, szp, NNI_TYPE_OPAQUE));
+ return (nng_socket_get(s, name, val, szp));
}
// Convenience option wrappers.
int
nng_setopt_int(nng_socket s, const char *name, int val)
{
- return (nng_setx(s, name, &val, sizeof(val), NNI_TYPE_INT32));
+ return (nng_socket_set_int(s, name, val));
}
int
nng_setopt_bool(nng_socket s, const char *name, bool val)
{
- return (nng_setx(s, name, &val, sizeof(val), NNI_TYPE_BOOL));
+ return (nng_socket_set_bool(s, name, val));
}
int
nng_setopt_size(nng_socket s, const char *name, size_t val)
{
- return (nng_setx(s, name, &val, sizeof(val), NNI_TYPE_SIZE));
+ return (nng_socket_set_size(s, name, val));
}
int
nng_setopt_ms(nng_socket s, const char *name, nng_duration val)
{
- return (nng_setx(s, name, &val, sizeof(val), NNI_TYPE_DURATION));
+ return (nng_socket_set_ms(s, name, val));
}
int
nng_setopt_uint64(nng_socket s, const char *name, uint64_t val)
{
- return (nng_setx(s, name, &val, sizeof(val), NNI_TYPE_UINT64));
+ return (nng_socket_set_uint64(s, name, val));
}
int
nng_setopt_ptr(nng_socket s, const char *name, void *val)
{
- return (nng_setx(s, name, &val, sizeof(val), NNI_TYPE_POINTER));
+ return (nng_socket_set_ptr(s, name, val));
}
int
nng_setopt_string(nng_socket s, const char *name, const char *val)
{
- return (nng_setx(s, name, val, strlen(val) + 1, NNI_TYPE_STRING));
+ return (nng_socket_set_string(s, name, val));
}
int
nng_getopt_bool(nng_socket s, const char *name, bool *valp)
{
- size_t sz = sizeof(*valp);
- return (nng_getx(s, name, valp, &sz, NNI_TYPE_BOOL));
+ return (nng_socket_get_bool(s, name, valp));
}
int
nng_getopt_int(nng_socket s, const char *name, int *valp)
{
- size_t sz = sizeof(*valp);
- return (nng_getx(s, name, valp, &sz, NNI_TYPE_INT32));
+ return (nng_socket_get_int(s, name, valp));
}
int
nng_getopt_size(nng_socket s, const char *name, size_t *valp)
{
- size_t sz = sizeof(*valp);
- return (nng_getx(s, name, valp, &sz, NNI_TYPE_SIZE));
+ return (nng_socket_get_size(s, name, valp));
}
int
nng_getopt_uint64(nng_socket s, const char *name, uint64_t *valp)
{
- size_t sz = sizeof(*valp);
- return (nng_getx(s, name, valp, &sz, NNI_TYPE_UINT64));
+ return (nng_socket_get_uint64(s, name, valp));
}
int
nng_getopt_ms(nng_socket s, const char *name, nng_duration *valp)
{
- size_t sz = sizeof(*valp);
- return (nng_getx(s, name, valp, &sz, NNI_TYPE_DURATION));
+ return (nng_socket_get_ms(s, name, valp));
}
int
nng_getopt_ptr(nng_socket s, const char *name, void **valp)
{
- size_t sz = sizeof(*valp);
- return (nng_getx(s, name, valp, &sz, NNI_TYPE_DURATION));
+ return (nng_socket_get_ptr(s, name, valp));
}
int
nng_getopt_string(nng_socket s, const char *name, char **valp)
{
- size_t sz = sizeof(*valp);
- return (nng_getx(s, name, valp, &sz, NNI_TYPE_STRING));
+ return (nng_socket_get_string(s, name, valp));
}
int
@@ -1132,7 +849,7 @@ nng_strerror(int num)
}
static int
-nng_pipe_getx(nng_pipe p, const char *name, void *val, size_t *szp, nni_type t)
+nni_pipe_getx(nng_pipe p, const char *name, void *val, size_t *szp, nni_type t)
{
int rv;
nni_pipe *pipe;
@@ -1148,67 +865,7 @@ nng_pipe_getx(nng_pipe p, const char *name, void *val, size_t *szp, nni_type t)
return (rv);
}
-int
-nng_pipe_getopt(nng_pipe p, const char *name, void *val, size_t *szp)
-{
- return (nng_pipe_getx(p, name, val, szp, NNI_TYPE_OPAQUE));
-}
-
-int
-nng_pipe_getopt_bool(nng_pipe p, const char *name, bool *valp)
-{
- size_t sz = sizeof(*valp);
- return (nng_pipe_getx(p, name, valp, &sz, NNI_TYPE_BOOL));
-}
-
-int
-nng_pipe_getopt_int(nng_pipe p, const char *name, int *valp)
-{
- size_t sz = sizeof(*valp);
- return (nng_pipe_getx(p, name, valp, &sz, NNI_TYPE_INT32));
-}
-
-int
-nng_pipe_getopt_size(nng_pipe p, const char *name, size_t *valp)
-{
- size_t sz = sizeof(*valp);
- return (nng_pipe_getx(p, name, valp, &sz, NNI_TYPE_SIZE));
-}
-
-int
-nng_pipe_getopt_uint64(nng_pipe p, const char *name, uint64_t *valp)
-{
- size_t sz = sizeof(*valp);
- return (nng_pipe_getx(p, name, valp, &sz, NNI_TYPE_UINT64));
-}
-
-int
-nng_pipe_getopt_ms(nng_pipe p, const char *name, nng_duration *valp)
-{
- size_t sz = sizeof(*valp);
- return (nng_pipe_getx(p, name, valp, &sz, NNI_TYPE_DURATION));
-}
-
-int
-nng_pipe_getopt_ptr(nng_pipe p, const char *name, void **valp)
-{
- size_t sz = sizeof(*valp);
- return (nng_pipe_getx(p, name, valp, &sz, NNI_TYPE_POINTER));
-}
-
-int
-nng_pipe_getopt_sockaddr(nng_pipe p, const char *name, nng_sockaddr *sap)
-{
- size_t sz = sizeof(*sap);
- return (nng_pipe_getx(p, name, sap, &sz, NNI_TYPE_SOCKADDR));
-}
-
-int
-nng_pipe_getopt_string(nng_pipe p, const char *name, char **valp)
-{
- size_t sz = sizeof(*valp);
- return (nng_pipe_getx(p, name, valp, &sz, NNI_TYPE_STRING));
-}
+NNI_LEGACY_DEFGETALL(pipe)
nng_socket
nng_pipe_socket(nng_pipe p)
@@ -1267,6 +924,16 @@ nng_pipe_id(nng_pipe p)
return (((int) p.id > 0) ? (int) p.id : -1);
}
+NNI_DEFSETALL(ctx)
+NNI_DEFGETALL(ctx)
+NNI_DEFSETALL(dialer)
+NNI_DEFGETALL(dialer)
+NNI_DEFSETALL(listener)
+NNI_DEFGETALL(listener)
+NNI_DEFSETALL(socket)
+NNI_DEFGETALL(socket)
+NNI_DEFGETALL(pipe)
+
// Message handling.
int
nng_msg_alloc(nng_msg **msgp, size_t size)