fixes #5 Address properties

Added TCP socket address properties on pipes.

This adds the plumbing for the various platform specifics, and
includes both v4 and v6 handling.

We've included a TCPv6 test as well.

1 files changed, 86 insertions, 0 deletions

diff --git a/tests/tcp6.c b/tests/tcp6.c
new file mode 100644
index 00000000..6f84d282
--- /dev/null
+++ b/tests/tcp6.c
@@ -0,0 +1,86 @@
+//
+// Copyright 2017 Garrett D'Amore <garrett@damore.org>
+// Copyright 2017 Capitar IT Group BV <info@capitar.com>
+//
+// 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 "convey.h"
+#include "trantest.h"
+
+#include "core/nng_impl.h"
+// TCP tests for IPv6.
+
+static int
+has_v6(void)
+{
+	nng_sockaddr  sa;
+	nni_plat_udp *u;
+	int           rv;
+
+	sa.s_un.s_in6.sa_family = NNG_AF_INET6;
+	sa.s_un.s_in6.sa_port   = 0;
+	memset(sa.s_un.s_in6.sa_addr, 0, 16);
+	sa.s_un.s_in6.sa_addr[15] = 1;
+
+	rv = nni_plat_udp_open(&u, &sa);
+	if (rv == 0) {
+		nni_plat_udp_close(u);
+	}
+	return (rv == 0 ? 1 : 0);
+}
+
+static int
+check_props_v6(nng_msg *msg, nng_listener l, nng_dialer d)
+{
+	nng_pipe p;
+	size_t   z;
+	uint8_t  loopback[16];
+
+	memset(loopback, 0, sizeof(loopback));
+	loopback[15] = 1;
+	Convey("IPv6 Local address property works", {
+		nng_sockaddr la;
+		z = sizeof(nng_sockaddr);
+		p = nng_msg_get_pipe(msg);
+		So(p > 0);
+		So(nng_pipe_getopt(p, NNG_OPT_LOCADDR, &la, &z) == 0);
+		So(z == sizeof(la));
+		So(la.s_un.s_family == NNG_AF_INET6);
+		// So(la.s_un.s_in.sa_port == (trantest_port - 1));
+		So(la.s_un.s_in6.sa_port != 0);
+		So(memcmp(la.s_un.s_in6.sa_addr, loopback, 16) == 0);
+	});
+
+	Convey("IPv6 Remote address property works", {
+		nng_sockaddr ra;
+		z = sizeof(nng_sockaddr);
+		p = nng_msg_get_pipe(msg);
+		So(p > 0);
+		So(nng_pipe_getopt(p, NNG_OPT_REMADDR, &ra, &z) == 0);
+		So(z == sizeof(ra));
+		So(ra.s_un.s_family == NNG_AF_INET6);
+		So(ra.s_un.s_in6.sa_port != 0);
+		So(memcmp(ra.s_un.s_in6.sa_addr, loopback, 16) == 0);
+
+		So(nng_dialer_getopt(d, NNG_OPT_REMADDR, &ra, &z) != 0);
+	});
+
+	return (0);
+}
+
+TestMain("TCP (IPv6) Transport", {
+
+	nni_init();
+
+	if (has_v6()) {
+		trantest_test_extended("tcp://[::1]:%u", check_props_v6);
+	} else {
+		SkipSo("IPv6 not available");
+	}
+
+	nng_fini();
+})