1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
|
//
// Copyright 2017 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"
#ifdef PLATFORM_POSIX_IPC
#include "platform/posix/posix_aio.h"
#include "platform/posix/posix_socket.h"
#include <errno.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/uio.h>
#include <sys/un.h>
#include <fcntl.h>
#include <unistd.h>
#include <netdb.h>
// Solaris/SunOS systems define this, which collides with our symbol
// names. Just undefine it now.
#ifdef sun
#undef sun
#endif
// We alias nni_posix_sock to nni_plat_ipcsock.
static int
nni_plat_ipc_path_resolve(nni_sockaddr *addr, const char *path)
{
nng_sockaddr_path *spath;
size_t len;
memset(addr, 0, sizeof (*addr));
spath = &addr->s_un.s_path;
// TODO: abstract sockets, including autobind sockets.
len = strlen(path);
if ((len >= sizeof (spath->sa_path)) || (len < 1)) {
return (NNG_EADDRINVAL);
}
(void) snprintf(spath->sa_path, sizeof (spath->sa_path), "%s", path);
spath->sa_family = NNG_AF_IPC;
return (0);
}
int
nni_plat_ipc_send(nni_plat_ipcsock *s, nni_iov *iovs, int cnt)
{
return (nni_posix_sock_send_sync((void *) s, iovs, cnt));
}
int
nni_plat_ipc_recv(nni_plat_ipcsock *s, nni_iov *iovs, int cnt)
{
return (nni_posix_sock_recv_sync((void *) s, iovs, cnt));
}
void
nni_plat_ipc_aio_send(nni_plat_ipcsock *s, nni_aio *aio)
{
nni_posix_sock_aio_send((void *) s, aio);
}
void
nni_plat_ipc_aio_recv(nni_plat_ipcsock *s, nni_aio *aio)
{
nni_posix_sock_aio_recv((void *) s, aio);
}
int
nni_plat_ipc_init(nni_plat_ipcsock **sp)
{
nni_posix_sock *s;
int rv;
if ((rv = nni_posix_sock_init(&s)) == 0) {
*sp = (void *) s;
}
return (rv);
}
void
nni_plat_ipc_fini(nni_plat_ipcsock *s)
{
nni_posix_sock_fini((void *) s);
}
void
nni_plat_ipc_shutdown(nni_plat_ipcsock *s)
{
nni_posix_sock_shutdown((void *) s);
}
int
nni_plat_ipc_listen(nni_plat_ipcsock *s, const char *path)
{
int rv;
nni_sockaddr addr;
if ((rv = nni_plat_ipc_path_resolve(&addr, path)) != 0) {
return (rv);
}
return (nni_posix_sock_listen((void *) s, &addr));
}
int
nni_plat_ipc_connect(nni_plat_ipcsock *s, const char *path)
{
int rv;
nni_sockaddr addr;
if ((rv = nni_plat_ipc_path_resolve(&addr, path)) != 0) {
return (rv);
}
return (nni_posix_sock_connect_sync((void *) s, &addr, NULL));
}
int
nni_plat_ipc_accept(nni_plat_ipcsock *s, nni_plat_ipcsock *server)
{
return (nni_posix_sock_accept_sync((void *) s, (void *) server));
}
#else
// Suppress empty symbols warnings in ranlib.
int nni_posix_ipc_not_used = 0;
#endif // PLATFORM_POSIX_IPC
|
