2 Socket wrapper library. Passes all socket communication over
3 unix domain sockets if the environment variable SOCKET_WRAPPER_DIR
5 Copyright (C) Jelmer Vernooij 2005
7 This program is free software; you can redistribute it and/or modify
8 it under the terms of the GNU General Public License as published by
9 the Free Software Foundation; either version 2 of the License, or
10 (at your option) any later version.
12 This program is distributed in the hope that it will be useful,
13 but WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 GNU General Public License for more details.
17 You should have received a copy of the GNU General Public License
18 along with this program; if not, write to the Free Software
19 Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
22 #ifdef SAMBA_MAJOR_VERSION
24 #include "system/network.h"
26 #include <sys/types.h>
27 #include <sys/socket.h>
30 #include <netinet/in.h>
35 #include "dlinklist.h"
38 /* LD_PRELOAD doesn't work yet, so REWRITE_CALLS is all we support
43 #define real_accept accept
44 #define real_connect connect
45 #define real_bind bind
46 #define real_getpeername getpeername
47 #define real_getsockname getsockname
48 #define real_getsockopt getsockopt
49 #define real_setsockopt setsockopt
50 #define real_recvfrom recvfrom
51 #define real_sendto sendto
52 #define real_socket socket
53 #define real_close close
56 static struct sockaddr *memdup(const void *data, socklen_t len)
58 struct sockaddr *ret = (struct sockaddr *)malloc(len);
59 memcpy(ret, data, len);
73 struct sockaddr *myname;
76 struct sockaddr *peername;
77 socklen_t peername_len;
79 struct socket_info *prev, *next;
82 static int convert_un_in(const struct sockaddr_un *un, struct sockaddr_in *in, socklen_t *len)
87 if ((*len) < sizeof(struct sockaddr_in)) {
91 in->sin_family = AF_INET;
92 in->sin_port = 1025; /* Default to 1025 */
93 p = strchr(un->sun_path, '/');
94 if (p) p++; else p = un->sun_path;
96 if(sscanf(p, "sock_ip_%u", &prt) == 1)
98 in->sin_port = htons(prt);
100 in->sin_addr.s_addr = INADDR_LOOPBACK;
101 *len = sizeof(struct sockaddr_in);
105 static int convert_in_un(const struct sockaddr_in *in, struct sockaddr_un *un)
107 uint16_t prt = ntohs(in->sin_port);
108 /* FIXME: ENETUNREACH if in->sin_addr is not loopback */
109 un->sun_family = AF_LOCAL;
110 snprintf(un->sun_path, sizeof(un->sun_path), "%s/sock_ip_%u", getenv("SOCKET_WRAPPER_DIR"), prt);
114 static struct socket_info *find_socket_info(int fd)
116 struct socket_info *i;
117 for (i = sockets; i; i = i->next) {
125 static int sockaddr_convert_to_un(const struct sockaddr *in_addr, socklen_t in_len,
126 struct sockaddr_un *out_addr)
131 switch (in_addr->sa_family) {
133 return convert_in_un((const struct sockaddr_in *)in_addr, out_addr);
135 memcpy(out_addr, in_addr, sizeof(*out_addr));
141 errno = EAFNOSUPPORT;
145 static int sockaddr_convert_from_un(const struct sockaddr_un *in_addr,
147 struct sockaddr *out_addr,
155 return convert_un_in(in_addr, (struct sockaddr_in *)out_addr, out_len);
157 memcpy(out_addr, in_addr, sizeof(*in_addr));
158 *out_len = sizeof(*in_addr);
164 errno = EAFNOSUPPORT;
168 int swrap_socket(int domain, int type, int protocol)
170 struct socket_info *si;
173 if (!getenv("SOCKET_WRAPPER_DIR")) {
174 return real_socket(domain, type, protocol);
177 fd = real_socket(PF_LOCAL, type, 0);
182 si = malloc(sizeof(struct socket_info));
183 memset(si, 0, sizeof(*si));
187 si->protocol = protocol;
190 DLIST_ADD(sockets, si);
195 int swrap_accept(int s, struct sockaddr *addr, socklen_t *addrlen)
197 struct socket_info *parent_si, *child_si;
199 socklen_t un_addrlen = sizeof(struct sockaddr_un);
200 struct sockaddr_un un_addr;
203 parent_si = find_socket_info(s);
205 return real_accept(s, addr, addrlen);
208 ret = real_accept(s, (struct sockaddr *)&un_addr, &un_addrlen);
209 if (ret < 0) return ret;
213 ret = sockaddr_convert_from_un(&un_addr, parent_si->domain, addr, addrlen);
215 if (ret < 0) return ret;
217 child_si = malloc(sizeof(struct socket_info));
218 memset(child_si, 0, sizeof(*child_si));
222 if (addr && addrlen) {
223 child_si->myname_len = *addrlen;
224 child_si->myname = memdup(addr, *addrlen);
230 int swrap_connect(int s, const struct sockaddr *serv_addr, socklen_t addrlen)
233 struct sockaddr_un un_addr;
234 struct socket_info *si = find_socket_info(s);
237 return real_connect(s, serv_addr, addrlen);
240 ret = sockaddr_convert_to_un((const struct sockaddr *)serv_addr, addrlen, &un_addr);
241 if (ret < 0) return ret;
243 ret = real_connect(s,
244 (struct sockaddr *)&un_addr,
245 sizeof(struct sockaddr_un));
248 si->peername_len = addrlen;
249 si->peername = memdup(serv_addr, addrlen);
255 int swrap_bind(int s, const struct sockaddr *myaddr, socklen_t addrlen)
258 struct sockaddr_un un_addr;
259 struct socket_info *si = find_socket_info(s);
262 return real_bind(s, myaddr, addrlen);
265 ret = sockaddr_convert_to_un((const struct sockaddr *)myaddr, addrlen, &un_addr);
266 if (ret < 0) return ret;
268 unlink(un_addr.sun_path);
271 (struct sockaddr *)&un_addr,
272 sizeof(struct sockaddr_un));
275 si->myname_len = addrlen;
276 si->myname = memdup(myaddr, addrlen);
282 int swrap_getpeername(int s, struct sockaddr *name, socklen_t *addrlen)
284 struct socket_info *si = find_socket_info(s);
287 return real_getpeername(s, name, addrlen);
296 memcpy(name, si->peername, si->peername_len);
297 *addrlen = si->peername_len;
302 int swrap_getsockname(int s, struct sockaddr *name, socklen_t *addrlen)
304 struct socket_info *si = find_socket_info(s);
307 return real_getpeername(s, name, addrlen);
310 memcpy(name, si->myname, si->myname_len);
311 *addrlen = si->myname_len;
316 int swrap_getsockopt(int s, int level, int optname, void *optval, socklen_t *optlen)
318 struct socket_info *si = find_socket_info(s);
321 return real_getsockopt(s, level, optname, optval, optlen);
324 if (level != SOL_SOCKET) {
329 return real_getsockopt(s, level, optname, optval, optlen);
332 int swrap_setsockopt(int s, int level, int optname, const void *optval, socklen_t optlen)
334 struct socket_info *si = find_socket_info(s);
337 return real_setsockopt(s, level, optname, optval, optlen);
340 if (level != SOL_SOCKET) {
345 return real_setsockopt(s, level, optname, optval, optlen);
348 ssize_t swrap_recvfrom(int s, void *buf, size_t len, int flags, struct sockaddr *from, socklen_t *fromlen)
350 socklen_t un_addrlen;
351 struct sockaddr_un un_addr;
353 struct socket_info *si = find_socket_info(s);
356 return real_recvfrom(s, buf, len, flags, from, fromlen);
359 ret = real_recvfrom(s, buf, len, flags, (struct sockaddr *)&un_addr, &un_addrlen);
363 ret = sockaddr_convert_from_un(&un_addr, si->domain, from, fromlen);
368 ssize_t swrap_sendto(int s, const void *buf, size_t len, int flags, const struct sockaddr *to, socklen_t tolen)
370 struct sockaddr_un un_addr;
372 struct socket_info *si = find_socket_info(s);
375 return real_sendto(s, buf, len, flags, to, tolen);
378 ret = sockaddr_convert_to_un(to, tolen, &un_addr);
382 ret = real_sendto(s, buf, len, flags, (struct sockaddr *)&un_addr, sizeof(un_addr));
387 int swrap_close(int fd)
389 struct socket_info *si = find_socket_info(fd);
392 DLIST_REMOVE(sockets, si);
400 return real_close(fd);