summaryrefslogtreecommitdiff
path: root/src/nng.c
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2017-01-06 08:18:50 -0800
committerGarrett D'Amore <garrett@damore.org>2017-01-06 08:21:09 -0800
commita2801adffebb6a3679e41789b38ba925ed32832b (patch)
tree8e3a743301fedb04d19d9af3e30f5622b737c337 /src/nng.c
parent601d7a6ca95678613ca576258314f50a6e5e742c (diff)
downloadnng-a2801adffebb6a3679e41789b38ba925ed32832b.tar.gz
nng-a2801adffebb6a3679e41789b38ba925ed32832b.tar.bz2
nng-a2801adffebb6a3679e41789b38ba925ed32832b.zip
Message API was awkward.
The use of a single function to get both size and length actually turned out to be awkward to use; better to have separate functions to get each. While here, disable some of the initialization/fork checks, because it turns out they aren't needed.
Diffstat (limited to 'src/nng.c')
-rw-r--r--src/nng.c37
1 files changed, 19 insertions, 18 deletions
diff --git a/src/nng.c b/src/nng.c
index db2233d2..9a25b285 100644
--- a/src/nng.c
+++ b/src/nng.c
@@ -237,7 +237,7 @@ nng_pipe_close(nng_pipe *pipe)
int
nng_msg_alloc(nng_msg **msgp, size_t size)
{
- NNI_INIT_INT();
+ NNI_INIT_VOID();
return (nni_msg_alloc(msgp, size));
}
@@ -245,7 +245,6 @@ nng_msg_alloc(nng_msg **msgp, size_t size)
int
nng_msg_realloc(nng_msg *msg, size_t sz)
{
- NNI_INIT_INT();
return (nni_msg_realloc(msg, sz));
}
@@ -253,31 +252,41 @@ nng_msg_realloc(nng_msg *msg, size_t sz)
void
nng_msg_free(nng_msg *msg)
{
- NNI_INIT_VOID();
return (nni_msg_free(msg));
}
void *
-nng_msg_body(nng_msg *msg, size_t *szp)
+nng_msg_body(nng_msg *msg)
{
- NNI_INIT_VOID();
- return (nni_msg_body(msg, szp));
+ return (nni_msg_body(msg));
+}
+
+
+size_t
+nng_msg_len(nng_msg *msg)
+{
+ return (nni_msg_len(msg));
}
void *
-nng_msg_header(nng_msg *msg, size_t *szp)
+nng_msg_header(nng_msg *msg)
{
- NNI_INIT_VOID();
- return (nni_msg_header(msg, szp));
+ return (nni_msg_header(msg));
+}
+
+
+size_t
+nng_msg_header_len(nng_msg *msg)
+{
+ return (nni_msg_header_len(msg));
}
int
nng_msg_append(nng_msg *msg, const void *data, size_t sz)
{
- NNI_INIT_INT();
return (nni_msg_append(msg, data, sz));
}
@@ -285,7 +294,6 @@ nng_msg_append(nng_msg *msg, const void *data, size_t sz)
int
nng_msg_prepend(nng_msg *msg, const void *data, size_t sz)
{
- NNI_INIT_INT();
return (nni_msg_prepend(msg, data, sz));
}
@@ -293,7 +301,6 @@ nng_msg_prepend(nng_msg *msg, const void *data, size_t sz)
int
nng_msg_append_header(nng_msg *msg, const void *data, size_t sz)
{
- NNI_INIT_INT();
return (nni_msg_append_header(msg, data, sz));
}
@@ -301,7 +308,6 @@ nng_msg_append_header(nng_msg *msg, const void *data, size_t sz)
int
nng_msg_prepend_header(nng_msg *msg, const void *data, size_t sz)
{
- NNI_INIT_INT();
return (nni_msg_prepend_header(msg, data, sz));
}
@@ -309,7 +315,6 @@ nng_msg_prepend_header(nng_msg *msg, const void *data, size_t sz)
int
nng_msg_trim(nng_msg *msg, size_t sz)
{
- NNI_INIT_INT();
return (nni_msg_trim(msg, sz));
}
@@ -317,7 +322,6 @@ nng_msg_trim(nng_msg *msg, size_t sz)
int
nng_msg_trunc(nng_msg *msg, size_t sz)
{
- NNI_INIT_INT();
return (nni_msg_trunc(msg, sz));
}
@@ -325,7 +329,6 @@ nng_msg_trunc(nng_msg *msg, size_t sz)
int
nng_msg_trim_header(nng_msg *msg, size_t sz)
{
- NNI_INIT_INT();
return (nni_msg_trim_header(msg, sz));
}
@@ -333,7 +336,6 @@ nng_msg_trim_header(nng_msg *msg, size_t sz)
int
nng_msg_trunc_header(nng_msg *msg, size_t sz)
{
- NNI_INIT_INT();
return (nni_msg_trunc_header(msg, sz));
}
@@ -341,7 +343,6 @@ nng_msg_trunc_header(nng_msg *msg, size_t sz)
int
nng_msg_getopt(nng_msg *msg, int opt, void *ptr, size_t *szp)
{
- NNI_INIT_INT();
return (nni_msg_getopt(msg, opt, ptr, szp));
}