Move option helpers to their own file.

1 files changed, 114 insertions, 0 deletions

diff --git a/src/core/options.c b/src/core/options.c
new file mode 100644
index 00000000..b970a0e7
--- /dev/null
+++ b/src/core/options.c
@@ -0,0 +1,114 @@
+//
+// Copyright 2016 Garrett D'Amore <garrett@damore.org>
+//
+// This software is supplied under the terms of the MIT License, a
+// copy of which should be located in the distribution where this
+// file was obtained (LICENSE.txt).  A copy of the license may also be
+// found online at https://opensource.org/licenses/MIT.
+//
+
+#include "core/nng_impl.h"
+
+#include <string.h>
+
+int
+nni_setopt_duration(nni_duration *ptr, const void *val, size_t size)
+{
+	nni_duration dur;
+
+	if (size != sizeof (*ptr)) {
+		return (NNG_EINVAL);
+	}
+	memcpy(&dur, val, sizeof (dur));
+	if (dur < -1) {
+		return (NNG_EINVAL);
+	}
+	*ptr = dur;
+	return (0);
+}
+
+
+int
+nni_setopt_int(int *ptr, const void *val, size_t size, int minval, int maxval)
+{
+	int v;
+
+	if (size != sizeof (v)) {
+		return (NNG_EINVAL);
+	}
+	memcpy(&v, val, sizeof (v));
+	if (v > maxval) {
+		return (NNG_EINVAL);
+	}
+	if (v < minval) {
+		return (NNG_EINVAL);
+	}
+	*ptr = v;
+	return (0);
+}
+
+
+int
+nni_getopt_duration(nni_duration *ptr, void *val, size_t *sizep)
+{
+	size_t sz = sizeof (*ptr);
+
+	if (sz > *sizep) {
+		sz = *sizep;
+	}
+	*sizep = sizeof (*ptr);
+	memcpy(val, ptr, sz);
+	return (0);
+}
+
+
+int
+nni_getopt_int(int *ptr, void *val, size_t *sizep)
+{
+	size_t sz = sizeof (*ptr);
+
+	if (sz > *sizep) {
+		sz = *sizep;
+	}
+	*sizep = sizeof (*ptr);
+	memcpy(val, ptr, sz);
+	return (0);
+}
+
+
+int
+nni_setopt_buf(nni_msgqueue *mq, const void *val, size_t sz)
+{
+	int len;
+
+	if (sz < sizeof (len)) {
+		return (NNG_EINVAL);
+	}
+	memcpy(&len, val, sizeof (len));
+	if (len < 0) {
+		return (NNG_EINVAL);
+	}
+	if (len > 8192) {
+		// put a reasonable uppper limit on queue depth.
+		// This is a count in messages, so the total queue
+		// size could be quite large indeed in this case.
+		return (NNG_EINVAL);
+	}
+	return (nni_msgqueue_resize(mq, len));
+}
+
+
+int
+nni_getopt_buf(nni_msgqueue *mq, void *val, size_t *sizep)
+{
+	int len = nni_msgqueue_cap(mq);
+
+	int sz = *sizep;
+
+	if (sz > sizeof (len)) {
+		sz = sizeof (len);
+	}
+	memcpy(val, &len, sz);
+	*sizep = sizeof (len);
+	return (0);
+}