2 Unix SMB/CIFS implementation.
3 Main winbindd server routines
5 Copyright (C) Stefan Metzmacher 2005
6 Copyright (C) Andrew Tridgell 2005
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 2 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, write to the Free Software
20 Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
24 #include "lib/socket/socket.h"
25 #include "dlinklist.h"
26 #include "lib/events/events.h"
27 #include "smbd/service_task.h"
28 #include "smbd/process_model.h"
29 #include "smbd/service_stream.h"
30 #include "nsswitch/winbind_nss_config.h"
31 #include "winbind/wb_server.h"
32 #include "lib/stream/packet.h"
33 #include "smbd/service.h"
35 void wbsrv_terminate_connection(struct wbsrv_connection *wbconn, const char *reason)
37 stream_terminate_connection(wbconn->conn, reason);
41 called on a tcp recv error
43 static void wbsrv_recv_error(void *private, NTSTATUS status)
45 struct wbsrv_connection *wbconn = talloc_get_type(private, struct wbsrv_connection);
46 wbsrv_terminate_connection(wbconn, nt_errstr(status));
49 static void wbsrv_accept(struct stream_connection *conn)
51 struct wbsrv_listen_socket *listen_socket = talloc_get_type(conn->private,
52 struct wbsrv_listen_socket);
53 struct wbsrv_connection *wbconn;
55 wbconn = talloc_zero(conn, struct wbsrv_connection);
57 stream_terminate_connection(conn, "wbsrv_accept: out of memory");
61 wbconn->listen_socket = listen_socket;
62 conn->private = wbconn;
64 wbconn->packet = packet_init(wbconn);
65 if (wbconn->packet == NULL) {
66 wbsrv_terminate_connection(wbconn, "wbsrv_accept: out of memory");
69 packet_set_private(wbconn->packet, wbconn);
70 packet_set_socket(wbconn->packet, conn->socket);
71 packet_set_callback(wbconn->packet, wbsrv_samba3_process);
72 packet_set_full_request(wbconn->packet, wbsrv_samba3_packet_full_request);
73 packet_set_error_handler(wbconn->packet, wbsrv_recv_error);
74 packet_set_event_context(wbconn->packet, conn->event.ctx);
75 packet_set_fde(wbconn->packet, conn->event.fde);
76 packet_set_serialise(wbconn->packet);
80 receive some data on a winbind connection
82 static void wbsrv_recv(struct stream_connection *conn, uint16_t flags)
84 struct wbsrv_connection *wbconn = talloc_get_type(conn->private,
85 struct wbsrv_connection);
86 packet_recv(wbconn->packet);
91 called when we can write to a connection
93 static void wbsrv_send(struct stream_connection *conn, uint16_t flags)
95 struct wbsrv_connection *wbconn = talloc_get_type(conn->private,
96 struct wbsrv_connection);
97 packet_queue_run(wbconn->packet);
100 static const struct stream_server_ops wbsrv_ops = {
101 .name = "winbind samba3 protocol",
102 .accept_connection = wbsrv_accept,
103 .recv_handler = wbsrv_recv,
104 .send_handler = wbsrv_send
108 startup the winbind task
110 static void winbind_task_init(struct task_server *task)
113 const struct model_ops *model_ops;
115 struct wbsrv_service *service;
116 struct wbsrv_listen_socket *listen_socket;
118 /* within the winbind task we want to be a single process, so
119 ask for the single process model ops and pass these to the
120 stream_setup_socket() call. */
121 model_ops = process_model_byname("single");
123 task_server_terminate(task,
124 "Can't find 'single' process model_ops");
128 /* Make sure the directory for the Samba3 socket exists, and is of the correct permissions */
129 if (!directory_create_or_exist(lp_winbindd_socket_directory(), geteuid(), 0755)) {
130 task_server_terminate(task,
131 "Cannot create winbindd pipe directory");
135 service = talloc_zero(task, struct wbsrv_service);
136 if (!service) goto nomem;
137 service->task = task;
139 service->primary_sid = secrets_get_domain_sid(service,
141 if (service->primary_sid == NULL) {
142 task_server_terminate(
143 task, nt_errstr(NT_STATUS_CANT_ACCESS_DOMAIN_INFO));
147 /* setup the unprivileged samba3 socket */
148 listen_socket = talloc(service, struct wbsrv_listen_socket);
149 if (!listen_socket) goto nomem;
150 listen_socket->socket_path = talloc_asprintf(listen_socket, "%s/%s",
151 lp_winbindd_socket_directory(),
152 WINBINDD_SAMBA3_SOCKET);
153 if (!listen_socket->socket_path) goto nomem;
154 listen_socket->service = service;
155 listen_socket->privileged = False;
156 status = stream_setup_socket(task->event_ctx, model_ops,
158 listen_socket->socket_path, &port,
160 if (!NT_STATUS_IS_OK(status)) goto listen_failed;
162 /* setup the privileged samba3 socket */
163 listen_socket = talloc(service, struct wbsrv_listen_socket);
164 if (!listen_socket) goto nomem;
165 listen_socket->socket_path =
166 smbd_tmp_path(listen_socket,
167 WINBINDD_SAMBA3_PRIVILEGED_SOCKET);
168 if (!listen_socket->socket_path) goto nomem;
169 listen_socket->service = service;
170 listen_socket->privileged = True;
171 status = stream_setup_socket(task->event_ctx, model_ops,
173 listen_socket->socket_path, &port,
175 if (!NT_STATUS_IS_OK(status)) goto listen_failed;
180 DEBUG(0,("stream_setup_socket(path=%s) failed - %s\n",
181 listen_socket->socket_path, nt_errstr(status)));
182 task_server_terminate(task, nt_errstr(status));
185 task_server_terminate(task, nt_errstr(NT_STATUS_NO_MEMORY));
190 initialise the winbind server
192 static NTSTATUS winbind_init(struct event_context *event_ctx,
193 const struct model_ops *model_ops)
195 return task_server_startup(event_ctx, model_ops, winbind_task_init);
199 register ourselves as a available server
201 NTSTATUS server_service_winbind_init(void)
203 return register_server_service("winbind", winbind_init);