Added more plumbing to facilitate test writing & compatibility.

Also, while here fixed a bug for the PAIR protocol in compat mode.
It should now be possible to import more of the nanomsg tests directly
with little or no modification.

1 files changed, 38 insertions, 0 deletions

diff --git a/src/nng_compat.c b/src/nng_compat.c
index 04759e01..3192a5f7 100644
--- a/src/nng_compat.c
+++ b/src/nng_compat.c
@@ -727,3 +727,41 @@ nn_cmsg_next(struct nn_msghdr *mh, struct nn_cmsghdr *first)
 	}
 	return (first);
 }
+
+
+// Internal test support routines.
+
+void
+nn_sleep(uint64_t msec)
+{
+	nng_usleep(msec / 1000);
+}
+
+
+uint64_t
+nn_clock(void)
+{
+	return (nng_clock());
+}
+
+
+extern void nni_panic(const char *, ...);
+
+int
+nn_thread_init(struct nn_thread *thr, void (*func)(void *), void *arg)
+{
+	int rv;
+
+	rv = nng_thread_create(&thr->thr, func, arg);
+	if (rv != 0) {
+		nni_panic("Cannot create thread: %s", nng_strerror(rv));
+	}
+	return (rv);
+}
+
+
+void
+nn_thread_term(struct nn_thread *thr)
+{
+	nng_thread_destroy(thr->thr);
+}