1 | /*
|
---|
2 | Unix SMB/CIFS implementation.
|
---|
3 |
|
---|
4 | CLDAP server task
|
---|
5 |
|
---|
6 | Copyright (C) Andrew Tridgell 2005
|
---|
7 |
|
---|
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.
|
---|
12 |
|
---|
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.
|
---|
17 |
|
---|
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/>.
|
---|
20 | */
|
---|
21 |
|
---|
22 | #include "includes.h"
|
---|
23 | #include <talloc.h>
|
---|
24 | #include "lib/messaging/irpc.h"
|
---|
25 | #include "smbd/service_task.h"
|
---|
26 | #include "smbd/service.h"
|
---|
27 | #include "cldap_server/cldap_server.h"
|
---|
28 | #include "system/network.h"
|
---|
29 | #include "lib/socket/netif.h"
|
---|
30 | #include <ldb.h>
|
---|
31 | #include <ldb_errors.h>
|
---|
32 | #include "dsdb/samdb/samdb.h"
|
---|
33 | #include "ldb_wrap.h"
|
---|
34 | #include "auth/auth.h"
|
---|
35 | #include "param/param.h"
|
---|
36 | #include "../lib/tsocket/tsocket.h"
|
---|
37 |
|
---|
38 | /*
|
---|
39 | handle incoming cldap requests
|
---|
40 | */
|
---|
41 | static void cldapd_request_handler(struct cldap_socket *cldap,
|
---|
42 | void *private_data,
|
---|
43 | struct cldap_incoming *in)
|
---|
44 | {
|
---|
45 | struct cldapd_server *cldapd = talloc_get_type(private_data,
|
---|
46 | struct cldapd_server);
|
---|
47 | struct ldap_SearchRequest *search;
|
---|
48 |
|
---|
49 | if (in->ldap_msg->type != LDAP_TAG_SearchRequest) {
|
---|
50 | DEBUG(0,("Invalid CLDAP request type %d from %s\n",
|
---|
51 | in->ldap_msg->type,
|
---|
52 | tsocket_address_string(in->src, in)));
|
---|
53 | cldap_error_reply(cldap, in->ldap_msg->messageid, in->src,
|
---|
54 | LDAP_OPERATIONS_ERROR, "Invalid CLDAP request");
|
---|
55 | talloc_free(in);
|
---|
56 | return;
|
---|
57 | }
|
---|
58 |
|
---|
59 | search = &in->ldap_msg->r.SearchRequest;
|
---|
60 |
|
---|
61 | if (strcmp("", search->basedn) != 0) {
|
---|
62 | DEBUG(0,("Invalid CLDAP basedn '%s' from %s\n",
|
---|
63 | search->basedn,
|
---|
64 | tsocket_address_string(in->src, in)));
|
---|
65 | cldap_error_reply(cldap, in->ldap_msg->messageid, in->src,
|
---|
66 | LDAP_OPERATIONS_ERROR, "Invalid CLDAP basedn");
|
---|
67 | talloc_free(in);
|
---|
68 | return;
|
---|
69 | }
|
---|
70 |
|
---|
71 | if (search->scope != LDAP_SEARCH_SCOPE_BASE) {
|
---|
72 | DEBUG(0,("Invalid CLDAP scope %d from %s\n",
|
---|
73 | search->scope,
|
---|
74 | tsocket_address_string(in->src, in)));
|
---|
75 | cldap_error_reply(cldap, in->ldap_msg->messageid, in->src,
|
---|
76 | LDAP_OPERATIONS_ERROR, "Invalid CLDAP scope");
|
---|
77 | talloc_free(in);
|
---|
78 | return;
|
---|
79 | }
|
---|
80 |
|
---|
81 | if (search->num_attributes == 1 &&
|
---|
82 | strcasecmp(search->attributes[0], "netlogon") == 0) {
|
---|
83 | cldapd_netlogon_request(cldap,
|
---|
84 | cldapd,
|
---|
85 | in,
|
---|
86 | in->ldap_msg->messageid,
|
---|
87 | search->tree,
|
---|
88 | in->src);
|
---|
89 | talloc_free(in);
|
---|
90 | return;
|
---|
91 | }
|
---|
92 |
|
---|
93 | cldapd_rootdse_request(cldap, cldapd, in,
|
---|
94 | in->ldap_msg->messageid,
|
---|
95 | search, in->src);
|
---|
96 | talloc_free(in);
|
---|
97 | }
|
---|
98 |
|
---|
99 |
|
---|
100 | /*
|
---|
101 | start listening on the given address
|
---|
102 | */
|
---|
103 | static NTSTATUS cldapd_add_socket(struct cldapd_server *cldapd, struct loadparm_context *lp_ctx,
|
---|
104 | const char *address)
|
---|
105 | {
|
---|
106 | struct cldap_socket *cldapsock;
|
---|
107 | struct tsocket_address *socket_address;
|
---|
108 | NTSTATUS status;
|
---|
109 | int ret;
|
---|
110 |
|
---|
111 | ret = tsocket_address_inet_from_strings(cldapd,
|
---|
112 | "ip",
|
---|
113 | address,
|
---|
114 | lpcfg_cldap_port(lp_ctx),
|
---|
115 | &socket_address);
|
---|
116 | if (ret != 0) {
|
---|
117 | status = map_nt_error_from_unix(errno);
|
---|
118 | DEBUG(0,("invalid address %s:%d - %s:%s\n",
|
---|
119 | address, lpcfg_cldap_port(lp_ctx),
|
---|
120 | gai_strerror(ret), nt_errstr(status)));
|
---|
121 | return status;
|
---|
122 | }
|
---|
123 |
|
---|
124 | /* listen for unicasts on the CLDAP port (389) */
|
---|
125 | status = cldap_socket_init(cldapd,
|
---|
126 | cldapd->task->event_ctx,
|
---|
127 | socket_address,
|
---|
128 | NULL,
|
---|
129 | &cldapsock);
|
---|
130 | if (!NT_STATUS_IS_OK(status)) {
|
---|
131 | DEBUG(0,("Failed to bind to %s - %s\n",
|
---|
132 | tsocket_address_string(socket_address, socket_address),
|
---|
133 | nt_errstr(status)));
|
---|
134 | talloc_free(socket_address);
|
---|
135 | return status;
|
---|
136 | }
|
---|
137 | talloc_free(socket_address);
|
---|
138 |
|
---|
139 | cldap_set_incoming_handler(cldapsock, cldapd_request_handler, cldapd);
|
---|
140 |
|
---|
141 | return NT_STATUS_OK;
|
---|
142 | }
|
---|
143 |
|
---|
144 | /*
|
---|
145 | setup our listening sockets on the configured network interfaces
|
---|
146 | */
|
---|
147 | static NTSTATUS cldapd_startup_interfaces(struct cldapd_server *cldapd, struct loadparm_context *lp_ctx,
|
---|
148 | struct interface *ifaces)
|
---|
149 | {
|
---|
150 | int i, num_interfaces;
|
---|
151 | TALLOC_CTX *tmp_ctx = talloc_new(cldapd);
|
---|
152 | NTSTATUS status;
|
---|
153 |
|
---|
154 | num_interfaces = iface_count(ifaces);
|
---|
155 |
|
---|
156 | /* if we are allowing incoming packets from any address, then
|
---|
157 | we need to bind to the wildcard address */
|
---|
158 | if (!lpcfg_bind_interfaces_only(lp_ctx)) {
|
---|
159 | status = cldapd_add_socket(cldapd, lp_ctx, "0.0.0.0");
|
---|
160 | NT_STATUS_NOT_OK_RETURN(status);
|
---|
161 | }
|
---|
162 |
|
---|
163 | /* now we have to also listen on the specific interfaces,
|
---|
164 | so that replies always come from the right IP */
|
---|
165 | for (i=0; i<num_interfaces; i++) {
|
---|
166 | const char *address = talloc_strdup(tmp_ctx, iface_n_ip(ifaces, i));
|
---|
167 | status = cldapd_add_socket(cldapd, lp_ctx, address);
|
---|
168 | NT_STATUS_NOT_OK_RETURN(status);
|
---|
169 | }
|
---|
170 |
|
---|
171 | talloc_free(tmp_ctx);
|
---|
172 |
|
---|
173 | return NT_STATUS_OK;
|
---|
174 | }
|
---|
175 |
|
---|
176 | /*
|
---|
177 | startup the cldapd task
|
---|
178 | */
|
---|
179 | static void cldapd_task_init(struct task_server *task)
|
---|
180 | {
|
---|
181 | struct cldapd_server *cldapd;
|
---|
182 | NTSTATUS status;
|
---|
183 | struct interface *ifaces;
|
---|
184 |
|
---|
185 | load_interfaces(task, lpcfg_interfaces(task->lp_ctx), &ifaces);
|
---|
186 |
|
---|
187 | if (iface_count(ifaces) == 0) {
|
---|
188 | task_server_terminate(task, "cldapd: no network interfaces configured", false);
|
---|
189 | return;
|
---|
190 | }
|
---|
191 |
|
---|
192 | switch (lpcfg_server_role(task->lp_ctx)) {
|
---|
193 | case ROLE_STANDALONE:
|
---|
194 | task_server_terminate(task, "cldap_server: no CLDAP server required in standalone configuration",
|
---|
195 | false);
|
---|
196 | return;
|
---|
197 | case ROLE_DOMAIN_MEMBER:
|
---|
198 | task_server_terminate(task, "cldap_server: no CLDAP server required in member server configuration",
|
---|
199 | false);
|
---|
200 | return;
|
---|
201 | case ROLE_DOMAIN_CONTROLLER:
|
---|
202 | /* Yes, we want an CLDAP server */
|
---|
203 | break;
|
---|
204 | }
|
---|
205 |
|
---|
206 | task_server_set_title(task, "task[cldapd]");
|
---|
207 |
|
---|
208 | cldapd = talloc(task, struct cldapd_server);
|
---|
209 | if (cldapd == NULL) {
|
---|
210 | task_server_terminate(task, "cldapd: out of memory", true);
|
---|
211 | return;
|
---|
212 | }
|
---|
213 |
|
---|
214 | cldapd->task = task;
|
---|
215 | cldapd->samctx = samdb_connect(cldapd, task->event_ctx, task->lp_ctx, system_session(task->lp_ctx), 0);
|
---|
216 | if (cldapd->samctx == NULL) {
|
---|
217 | task_server_terminate(task, "cldapd failed to open samdb", true);
|
---|
218 | return;
|
---|
219 | }
|
---|
220 |
|
---|
221 | /* start listening on the configured network interfaces */
|
---|
222 | status = cldapd_startup_interfaces(cldapd, task->lp_ctx, ifaces);
|
---|
223 | if (!NT_STATUS_IS_OK(status)) {
|
---|
224 | task_server_terminate(task, "cldapd failed to setup interfaces", true);
|
---|
225 | return;
|
---|
226 | }
|
---|
227 |
|
---|
228 | irpc_add_name(task->msg_ctx, "cldap_server");
|
---|
229 | }
|
---|
230 |
|
---|
231 |
|
---|
232 | /*
|
---|
233 | register ourselves as a available server
|
---|
234 | */
|
---|
235 | NTSTATUS server_service_cldapd_init(void)
|
---|
236 | {
|
---|
237 | return register_server_service("cldap", cldapd_task_init);
|
---|
238 | }
|
---|