aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/nng.c64
-rw-r--r--src/nng.h17
2 files changed, 77 insertions, 4 deletions
diff --git a/src/nng.c b/src/nng.c
index 7bf5bc9c..61aaa9c4 100644
--- a/src/nng.c
+++ b/src/nng.c
@@ -493,6 +493,70 @@ nng_msg_header_append(nng_msg *msg, const void *data, size_t sz)
}
int
+nng_msg_header_append_u32(nng_msg *msg, uint32_t val)
+{
+ return (nni_msg_header_append_u32(msg, val));
+}
+
+int
+nng_msg_header_insert_u32(nng_msg *msg, uint32_t val)
+{
+ return (nni_msg_header_insert_u32(msg, val));
+}
+
+int
+nng_msg_header_chop_u32(nng_msg *msg, uint32_t *valp)
+{
+ if (nni_msg_header_len(msg) < sizeof(uint32_t)) {
+ return (NNG_EINVAL);
+ }
+ *valp = nni_msg_header_chop_u32(msg);
+ return (0);
+}
+
+int
+nng_msg_header_trim_u32(nng_msg *msg, uint32_t *valp)
+{
+ if (nni_msg_header_len(msg) < sizeof(uint32_t)) {
+ return (NNG_EINVAL);
+ }
+ *valp = nni_msg_header_trim_u32(msg);
+ return (0);
+}
+
+int
+nng_msg_append_u32(nng_msg *msg, uint32_t val)
+{
+ return (nni_msg_append_u32(msg, val));
+}
+
+int
+nng_msg_insert_u32(nng_msg *msg, uint32_t val)
+{
+ return (nni_msg_insert_u32(msg, val));
+}
+
+int
+nng_msg_chop_u32(nng_msg *msg, uint32_t *valp)
+{
+ if (nni_msg_len(msg) < sizeof(uint32_t)) {
+ return (NNG_EINVAL);
+ }
+ *valp = nni_msg_chop_u32(msg);
+ return (0);
+}
+
+int
+nng_msg_trim_u32(nng_msg *msg, uint32_t *valp)
+{
+ if (nni_msg_len(msg) < sizeof(uint32_t)) {
+ return (NNG_EINVAL);
+ }
+ *valp = nni_msg_trim_u32(msg);
+ return (0);
+}
+
+int
nng_msg_header_insert(nng_msg *msg, const void *data, size_t sz)
{
return (nni_msg_header_insert(msg, data, sz));
diff --git a/src/nng.h b/src/nng.h
index 18912b4c..880614ea 100644
--- a/src/nng.h
+++ b/src/nng.h
@@ -263,10 +263,19 @@ NNG_DECL int nng_msg_header_append(nng_msg *, const void *, size_t);
NNG_DECL int nng_msg_header_insert(nng_msg *, const void *, size_t);
NNG_DECL int nng_msg_header_trim(nng_msg *, size_t);
NNG_DECL int nng_msg_header_chop(nng_msg *, size_t);
-NNG_DECL int nng_msg_dup(nng_msg **, const nng_msg *);
-NNG_DECL void nng_msg_clear(nng_msg *);
-NNG_DECL void nng_msg_header_clear(nng_msg *);
-NNG_DECL void nng_msg_set_pipe(nng_msg *, nng_pipe);
+NNG_DECL int nng_msg_header_append_u32(nng_msg *, uint32_t);
+NNG_DECL int nng_msg_header_insert_u32(nng_msg *, uint32_t);
+NNG_DECL int nng_msg_header_chop_u32(nng_msg *, uint32_t *);
+NNG_DECL int nng_msg_header_trim_u32(nng_msg *, uint32_t *);
+NNG_DECL int nng_msg_append_u32(nng_msg *, uint32_t);
+NNG_DECL int nng_msg_insert_u32(nng_msg *, uint32_t);
+NNG_DECL int nng_msg_chop_u32(nng_msg *, uint32_t *);
+NNG_DECL int nng_msg_trim_u32(nng_msg *, uint32_t *);
+
+NNG_DECL int nng_msg_dup(nng_msg **, const nng_msg *);
+NNG_DECL void nng_msg_clear(nng_msg *);
+NNG_DECL void nng_msg_header_clear(nng_msg *);
+NNG_DECL void nng_msg_set_pipe(nng_msg *, nng_pipe);
NNG_DECL nng_pipe nng_msg_get_pipe(const nng_msg *);
NNG_DECL int nng_msg_getopt(nng_msg *, int, void *, size_t *);