2 Unix SMB/CIFS implementation.
4 process incoming connections and fork a samba3 in inetd mode
6 Copyright (C) Stefan Metzmacher 2008
8 This program is free software; you can redistribute it and/or modify
9 it under the terms of the GNU General Public License as published by
10 the Free Software Foundation; either version 3 of the License, or
11 (at your option) any later version.
13 This program is distributed in the hope that it will be useful,
14 but WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 GNU General Public License for more details.
18 You should have received a copy of the GNU General Public License
19 along with this program. If not, see <http://www.gnu.org/licenses/>.
23 #include "smbd/service_task.h"
24 #include "smbd/service_stream.h"
25 #include "smbd/service.h"
26 #include "lib/messaging/irpc.h"
27 #include "lib/stream/packet.h"
28 #include "lib/socket/socket.h"
29 #include "libcli/smb2/smb2.h"
30 #include "smb_server/smb2/smb2_server.h"
31 #include "system/network.h"
32 #include "lib/socket/netif.h"
33 #include "param/share.h"
34 #include "dsdb/samdb/samdb.h"
35 #include "param/param.h"
36 #include "dynconfig/dynconfig.h"
37 #include "smbd/process_model.h"
40 initialise a server_context from a open socket and register a event handler
41 for reading from that socket
43 static void samba3_smb_accept(struct stream_connection
*conn
)
46 int fd
= socket_get_fd(conn
->socket
);
50 extern char **environ
;
61 prog
= lp_parm_string(conn
->lp_ctx
, NULL
, "samba3", "smbd");
64 argv
[0] = talloc_asprintf(conn
, "%s/%s", dyn_BINDIR
, "smbd3");
67 argv
[0] = talloc_strdup(conn
, prog
);
70 if (argv
[0] == NULL
) {
71 stream_terminate_connection(conn
, "out of memory");
76 execve(argv
[0], argv
, environ
);
79 * Should never get here
81 reason
= talloc_asprintf(conn
, "Could not execute %s", argv
[0]);
83 stream_terminate_connection(conn
, "out of memory");
86 stream_terminate_connection(conn
, reason
);
90 static const struct stream_server_ops samba3_smb_stream_ops
= {
92 .accept_connection
= samba3_smb_accept
,
96 setup a listening socket on all the SMB ports for a particular address
98 static NTSTATUS
samba3_add_socket(struct event_context
*event_context
,
99 struct loadparm_context
*lp_ctx
,
100 const struct model_ops
*model_ops
,
103 const char **ports
= lp_smb_ports(lp_ctx
);
107 for (i
=0;ports
[i
];i
++) {
108 uint16_t port
= atoi(ports
[i
]);
109 if (port
== 0) continue;
110 status
= stream_setup_socket(event_context
, lp_ctx
,
111 model_ops
, &samba3_smb_stream_ops
,
112 "ip", address
, &port
,
113 lp_socket_options(lp_ctx
),
115 NT_STATUS_NOT_OK_RETURN(status
);
123 open the smb server sockets
125 static void samba3_smb_task_init(struct task_server
*task
)
128 const struct model_ops
*model_ops
;
130 model_ops
= process_model_startup(task
->event_ctx
, "standard");
132 if (model_ops
== NULL
) {
136 task_server_set_title(task
, "task[samba3_smb]");
138 if (lp_interfaces(task
->lp_ctx
)
139 && lp_bind_interfaces_only(task
->lp_ctx
)) {
142 struct interface
*ifaces
;
144 load_interfaces(task
, lp_interfaces(task
->lp_ctx
), &ifaces
);
146 num_interfaces
= iface_count(ifaces
);
148 /* We have been given an interfaces line, and been
149 told to only bind to those interfaces. Create a
150 socket per interface and bind to only these.
152 for(i
= 0; i
< num_interfaces
; i
++) {
153 const char *address
= iface_n_ip(ifaces
, i
);
154 status
= samba3_add_socket(task
->event_ctx
,
157 if (!NT_STATUS_IS_OK(status
)) goto failed
;
160 /* Just bind to lp_socket_address() (usually 0.0.0.0) */
161 status
= samba3_add_socket(task
->event_ctx
, task
->lp_ctx
,
163 lp_socket_address(task
->lp_ctx
));
164 if (!NT_STATUS_IS_OK(status
)) goto failed
;
169 task_server_terminate(task
, "Failed to startup samba3 smb task");
172 /* called at smbd startup - register ourselves as a server service */
173 NTSTATUS
server_service_samba3_smb_init(void)
175 return register_server_service("samba3_smb", samba3_smb_task_init
);