aboutsummaryrefslogtreecommitdiff
path: root/src/platform/windows/win_resolv.c
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2017-07-10 15:02:38 -0700
committerGarrett D'Amore <garrett@damore.org>2017-07-10 15:02:38 -0700
commit795aebbee77bb74d8792df96dfe1aa79ec9548fc (patch)
tree58c16424c16b9e71cebdceaee4507ab6608f80da /src/platform/windows/win_resolv.c
parentde90f97167d2df6739db47b2c6aad85f06250270 (diff)
downloadnng-795aebbee77bb74d8792df96dfe1aa79ec9548fc.tar.gz
nng-795aebbee77bb74d8792df96dfe1aa79ec9548fc.tar.bz2
nng-795aebbee77bb74d8792df96dfe1aa79ec9548fc.zip
Give up on uncrustify; switch to clang-format.
Diffstat (limited to 'src/platform/windows/win_resolv.c')
-rw-r--r--src/platform/windows/win_resolv.c75
1 files changed, 32 insertions, 43 deletions
diff --git a/src/platform/windows/win_resolv.c b/src/platform/windows/win_resolv.c
index 3d37d546..44d00c34 100644
--- a/src/platform/windows/win_resolv.c
+++ b/src/platform/windows/win_resolv.c
@@ -7,7 +7,6 @@
// found online at https://opensource.org/licenses/MIT.
//
-
#include "core/nng_impl.h"
#ifdef PLATFORM_WINDOWS
@@ -23,25 +22,23 @@
// changed with this define.
#ifndef NNG_WIN_RESOLV_CONCURRENCY
-#define NNG_WIN_RESOLV_CONCURRENCY 4
+#define NNG_WIN_RESOLV_CONCURRENCY 4
#endif
-
static nni_taskq *nni_win_resolv_tq = NULL;
-static nni_mtx nni_win_resolv_mtx;
+static nni_mtx nni_win_resolv_mtx;
-typedef struct nni_win_resolv_item nni_win_resolv_item;
+typedef struct nni_win_resolv_item nni_win_resolv_item;
struct nni_win_resolv_item {
- int family;
- int passive;
- const char * name;
- const char * serv;
- int proto;
- nni_aio * aio;
- nni_taskq_ent tqe;
+ int family;
+ int passive;
+ const char * name;
+ const char * serv;
+ int proto;
+ nni_aio * aio;
+ nni_taskq_ent tqe;
};
-
static void
nni_win_resolv_finish(nni_win_resolv_item *item, int rv)
{
@@ -52,7 +49,6 @@ nni_win_resolv_finish(nni_win_resolv_item *item, int rv)
NNI_FREE_STRUCT(item);
}
-
static void
nni_win_resolv_cancel(nni_aio *aio)
{
@@ -69,7 +65,6 @@ nni_win_resolv_cancel(nni_aio *aio)
NNI_FREE_STRUCT(item);
}
-
static int
nni_win_gai_errno(int rv)
{
@@ -97,16 +92,15 @@ nni_win_gai_errno(int rv)
}
}
-
static void
nni_win_resolv_task(void *arg)
{
nni_win_resolv_item *item = arg;
- nni_aio *aio = item->aio;
- struct addrinfo hints;
- struct addrinfo *results;
- struct addrinfo *probe;
- int i, rv;
+ nni_aio * aio = item->aio;
+ struct addrinfo hints;
+ struct addrinfo * results;
+ struct addrinfo * probe;
+ int i, rv;
results = NULL;
@@ -116,13 +110,13 @@ nni_win_resolv_task(void *arg)
case AF_UNSPEC:
// We treat these all as IP addresses. The service and the
// host part are split.
- memset(&hints, 0, sizeof (hints));
+ memset(&hints, 0, sizeof(hints));
if (item->passive) {
hints.ai_flags |= AI_PASSIVE;
}
hints.ai_flags |= AI_ADDRCONFIG;
hints.ai_protocol = item->proto;
- hints.ai_family = item->family;
+ hints.ai_family = item->family;
if (item->family == AF_INET6) {
hints.ai_flags |= AI_V4MAPPED;
}
@@ -152,27 +146,27 @@ nni_win_resolv_task(void *arg)
aio->a_addrs = NNI_ALLOC_STRUCTS(aio->a_addrs, aio->a_naddrs);
if (aio->a_addrs == NULL) {
aio->a_naddrs = 0;
- rv = NNG_ENOMEM;
+ rv = NNG_ENOMEM;
break;
}
i = 0;
for (probe = results; probe != NULL; probe = probe->ai_next) {
- struct sockaddr_in *sin;
+ struct sockaddr_in * sin;
struct sockaddr_in6 *sin6;
- nng_sockaddr *sa = &aio->a_addrs[i];
+ nng_sockaddr * sa = &aio->a_addrs[i];
switch (probe->ai_addr->sa_family) {
case AF_INET:
sin = (void *) probe->ai_addr;
sa->s_un.s_in.sa_family = NNG_AF_INET;
- sa->s_un.s_in.sa_port = sin->sin_port;
- sa->s_un.s_in.sa_addr = sin->sin_addr.s_addr;
+ sa->s_un.s_in.sa_port = sin->sin_port;
+ sa->s_un.s_in.sa_addr = sin->sin_addr.s_addr;
i++;
break;
case AF_INET6:
sin6 = (void *) probe->ai_addr;
sa->s_un.s_in6.sa_family = NNG_AF_INET6;
- sa->s_un.s_in6.sa_port = sin6->sin6_port;
+ sa->s_un.s_in6.sa_port = sin6->sin6_port;
memcpy(sa->s_un.s_in6.sa_addr,
sin6->sin6_addr.s6_addr, 16);
i++;
@@ -200,13 +194,12 @@ nni_win_resolv_task(void *arg)
nni_mtx_unlock(&nni_win_resolv_mtx);
}
-
static void
-nni_win_resolv_ip(const char *host, const char *serv, int passive,
- int family, int proto, nni_aio *aio)
+nni_win_resolv_ip(const char *host, const char *serv, int passive, int family,
+ int proto, nni_aio *aio)
{
nni_win_resolv_item *item;
- int rv;
+ int rv;
if ((aio->a_naddrs != 0) && (aio->a_addrs != NULL)) {
NNI_FREE_STRUCTS(aio->a_addrs, aio->a_naddrs);
@@ -231,10 +224,10 @@ nni_win_resolv_ip(const char *host, const char *serv, int passive,
}
// NB: host and serv must remain valid until this is completed.
item->passive = passive;
- item->name = host;
- item->serv = serv;
- item->proto = proto;
- item->aio = aio;
+ item->name = host;
+ item->serv = serv;
+ item->proto = proto;
+ item->aio = aio;
nni_mtx_lock(&nni_win_resolv_mtx);
// If we were stopped, we're done...
@@ -251,15 +244,13 @@ nni_win_resolv_ip(const char *host, const char *serv, int passive,
nni_mtx_unlock(&nni_win_resolv_mtx);
}
-
void
-nni_plat_tcp_resolv(const char *host, const char *serv, int family,
- int passive, nni_aio *aio)
+nni_plat_tcp_resolv(
+ const char *host, const char *serv, int family, int passive, nni_aio *aio)
{
nni_win_resolv_ip(host, serv, passive, family, IPPROTO_TCP, aio);
}
-
int
nni_win_resolv_sysinit(void)
{
@@ -275,7 +266,6 @@ nni_win_resolv_sysinit(void)
return (0);
}
-
void
nni_win_resolv_sysfini(void)
{
@@ -286,7 +276,6 @@ nni_win_resolv_sysfini(void)
nni_mtx_fini(&nni_win_resolv_mtx);
}
-
#else
// Suppress empty symbols warnings in ranlib.