2 Unix SMB/CIFS implementation.
4 unix domain socket functions
6 Copyright (C) Stefan Metzmacher 2004
7 Copyright (C) Andrew Tridgell 2004-2005
9 This program is free software; you can redistribute it and/or modify
10 it under the terms of the GNU General Public License as published by
11 the Free Software Foundation; either version 2 of the License, or
12 (at your option) any later version.
14 This program is distributed in the hope that it will be useful,
15 but WITHOUT ANY WARRANTY; without even the implied warranty of
16 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 GNU General Public License for more details.
19 You should have received a copy of the GNU General Public License
20 along with this program; if not, write to the Free Software
21 Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
25 #include "lib/socket/socket.h"
26 #include "system/network.h"
27 #include "system/filesys.h"
32 approximate errno mapping
34 static NTSTATUS unixdom_error(int ernum)
36 return map_nt_error_from_unix(ernum);
39 static NTSTATUS unixdom_init(struct socket_context *sock)
44 case SOCKET_TYPE_STREAM:
47 case SOCKET_TYPE_DGRAM:
51 return NT_STATUS_INVALID_PARAMETER;
54 sock->fd = socket(PF_UNIX, type, 0);
56 return map_nt_error_from_unix(errno);
58 sock->private_data = NULL;
60 sock->backend_name = "unix";
65 static void unixdom_close(struct socket_context *sock)
70 static NTSTATUS unixdom_connect_complete(struct socket_context *sock, uint32_t flags)
73 socklen_t len = sizeof(error);
75 /* check for any errors that may have occurred - this is needed
76 for non-blocking connect */
77 ret = getsockopt(sock->fd, SOL_SOCKET, SO_ERROR, &error, &len);
79 return map_nt_error_from_unix(errno);
82 return map_nt_error_from_unix(error);
85 if (!(flags & SOCKET_FLAG_BLOCK)) {
86 ret = set_blocking(sock->fd, False);
88 return map_nt_error_from_unix(errno);
92 sock->state = SOCKET_STATE_CLIENT_CONNECTED;
97 static NTSTATUS unixdom_connect(struct socket_context *sock,
98 const struct socket_address *my_address,
99 const struct socket_address *srv_address,
104 if (srv_address->sockaddr) {
105 ret = connect(sock->fd, srv_address->sockaddr, srv_address->sockaddrlen);
107 struct sockaddr_un srv_addr;
108 if (strlen(srv_address->addr)+1 > sizeof(srv_addr.sun_path)) {
109 return NT_STATUS_OBJECT_PATH_INVALID;
112 ZERO_STRUCT(srv_addr);
113 srv_addr.sun_family = AF_UNIX;
114 strncpy(srv_addr.sun_path, srv_address->addr, sizeof(srv_addr.sun_path));
116 ret = connect(sock->fd, (const struct sockaddr *)&srv_addr, sizeof(srv_addr));
119 return unixdom_error(errno);
122 return unixdom_connect_complete(sock, flags);
125 static NTSTATUS unixdom_listen(struct socket_context *sock,
126 const struct socket_address *my_address,
127 int queue_size, uint32_t flags)
129 struct sockaddr_un my_addr;
132 /* delete if it already exists */
133 if (my_address->addr) {
134 unlink(my_address->addr);
137 if (my_address && my_address->sockaddr) {
138 ret = bind(sock->fd, (struct sockaddr *)&my_addr, sizeof(my_addr));
141 if (strlen(my_address->addr)+1 > sizeof(my_addr.sun_path)) {
142 return NT_STATUS_OBJECT_PATH_INVALID;
146 ZERO_STRUCT(my_addr);
147 my_addr.sun_family = AF_UNIX;
148 strncpy(my_addr.sun_path, my_address->addr, sizeof(my_addr.sun_path));
150 ret = bind(sock->fd, (struct sockaddr *)&my_addr, sizeof(my_addr));
153 return unixdom_error(errno);
156 if (sock->type == SOCKET_TYPE_STREAM) {
157 ret = listen(sock->fd, queue_size);
159 return unixdom_error(errno);
163 if (!(flags & SOCKET_FLAG_BLOCK)) {
164 ret = set_blocking(sock->fd, False);
166 return unixdom_error(errno);
170 sock->state = SOCKET_STATE_SERVER_LISTEN;
171 sock->private_data = (void *)talloc_strdup(sock, my_address->addr);
176 static NTSTATUS unixdom_accept(struct socket_context *sock,
177 struct socket_context **new_sock)
179 struct sockaddr_un cli_addr;
180 socklen_t cli_addr_len = sizeof(cli_addr);
183 if (sock->type != SOCKET_TYPE_STREAM) {
184 return NT_STATUS_INVALID_PARAMETER;
187 new_fd = accept(sock->fd, (struct sockaddr *)&cli_addr, &cli_addr_len);
189 return unixdom_error(errno);
192 if (!(sock->flags & SOCKET_FLAG_BLOCK)) {
193 int ret = set_blocking(new_fd, False);
196 return map_nt_error_from_unix(errno);
200 (*new_sock) = talloc(NULL, struct socket_context);
203 return NT_STATUS_NO_MEMORY;
206 /* copy the socket_context */
207 (*new_sock)->type = sock->type;
208 (*new_sock)->state = SOCKET_STATE_SERVER_CONNECTED;
209 (*new_sock)->flags = sock->flags;
211 (*new_sock)->fd = new_fd;
213 (*new_sock)->private_data = NULL;
214 (*new_sock)->ops = sock->ops;
215 (*new_sock)->backend_name = sock->backend_name;
220 static NTSTATUS unixdom_recv(struct socket_context *sock, void *buf,
221 size_t wantlen, size_t *nread, uint32_t flags)
226 /* TODO: we need to map all flags here */
227 if (flags & SOCKET_FLAG_PEEK) {
231 if (flags & SOCKET_FLAG_BLOCK) {
237 gotlen = recv(sock->fd, buf, wantlen, flgs);
239 return NT_STATUS_END_OF_FILE;
240 } else if (gotlen == -1) {
241 return unixdom_error(errno);
249 static NTSTATUS unixdom_send(struct socket_context *sock,
250 const DATA_BLOB *blob, size_t *sendlen, uint32_t flags)
257 len = send(sock->fd, blob->data, blob->length, flgs);
259 return unixdom_error(errno);
268 static NTSTATUS unixdom_sendto(struct socket_context *sock,
269 const DATA_BLOB *blob, size_t *sendlen, uint32_t flags,
270 const struct socket_address *dest)
276 if (dest->sockaddr) {
277 len = sendto(sock->fd, blob->data, blob->length, flgs,
278 dest->sockaddr, dest->sockaddrlen);
280 struct sockaddr_un srv_addr;
282 if (strlen(dest->addr)+1 > sizeof(srv_addr.sun_path)) {
283 return NT_STATUS_OBJECT_PATH_INVALID;
286 ZERO_STRUCT(srv_addr);
287 srv_addr.sun_family = AF_UNIX;
288 strncpy(srv_addr.sun_path, dest->addr, sizeof(srv_addr.sun_path));
290 len = sendto(sock->fd, blob->data, blob->length, flgs,
291 (struct sockaddr *)&srv_addr, sizeof(srv_addr));
294 return map_nt_error_from_unix(errno);
303 static NTSTATUS unixdom_set_option(struct socket_context *sock,
304 const char *option, const char *val)
309 static char *unixdom_get_peer_name(struct socket_context *sock, TALLOC_CTX *mem_ctx)
311 return talloc_strdup(mem_ctx, "LOCAL/unixdom");
314 static struct socket_address *unixdom_get_peer_addr(struct socket_context *sock, TALLOC_CTX *mem_ctx)
316 struct sockaddr_in *peer_addr;
317 socklen_t len = sizeof(*peer_addr);
318 struct socket_address *peer;
321 peer = talloc(mem_ctx, struct socket_address);
326 peer->family = sock->backend_name;
327 peer_addr = talloc(peer, struct sockaddr_in);
333 peer->sockaddr = (struct sockaddr *)peer_addr;
335 ret = getpeername(sock->fd, peer->sockaddr, &len);
341 peer->sockaddrlen = len;
344 peer->addr = talloc_strdup(peer, "LOCAL/unixdom");
353 static struct socket_address *unixdom_get_my_addr(struct socket_context *sock, TALLOC_CTX *mem_ctx)
355 struct sockaddr_in *local_addr;
356 socklen_t len = sizeof(*local_addr);
357 struct socket_address *local;
360 local = talloc(mem_ctx, struct socket_address);
365 local->family = sock->backend_name;
366 local_addr = talloc(local, struct sockaddr_in);
372 local->sockaddr = (struct sockaddr *)local_addr;
374 ret = getsockname(sock->fd, local->sockaddr, &len);
380 local->sockaddrlen = len;
383 local->addr = talloc_strdup(local, "LOCAL/unixdom");
392 static int unixdom_get_fd(struct socket_context *sock)
397 static NTSTATUS unixdom_pending(struct socket_context *sock, size_t *npending)
400 if (ioctl(sock->fd, FIONREAD, &value) == 0) {
404 return map_nt_error_from_unix(errno);
407 static const struct socket_ops unixdom_ops = {
409 .fn_init = unixdom_init,
410 .fn_connect = unixdom_connect,
411 .fn_connect_complete = unixdom_connect_complete,
412 .fn_listen = unixdom_listen,
413 .fn_accept = unixdom_accept,
414 .fn_recv = unixdom_recv,
415 .fn_send = unixdom_send,
416 .fn_sendto = unixdom_sendto,
417 .fn_close = unixdom_close,
418 .fn_pending = unixdom_pending,
420 .fn_set_option = unixdom_set_option,
422 .fn_get_peer_name = unixdom_get_peer_name,
423 .fn_get_peer_addr = unixdom_get_peer_addr,
424 .fn_get_my_addr = unixdom_get_my_addr,
426 .fn_get_fd = unixdom_get_fd
429 const struct socket_ops *socket_unixdom_ops(enum socket_type type)