diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-01-06 08:18:50 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-01-06 08:21:09 -0800 |
| commit | a2801adffebb6a3679e41789b38ba925ed32832b (patch) | |
| tree | 8e3a743301fedb04d19d9af3e30f5622b737c337 /src/nng.c | |
| parent | 601d7a6ca95678613ca576258314f50a6e5e742c (diff) | |
| download | nng-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.c | 37 |
1 files changed, 19 insertions, 18 deletions
@@ -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)); } |
