2 Unix SMB/CIFS implementation.
4 Provide parent->child communication based on NDR marshalling
6 Copyright (C) Volker Lendecke 2009
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 * This file implements an RPC between winbind parent and child processes,
24 * leveraging the autogenerated marshalling routines for MSRPC. This is not
25 * MSRPC, as it does not go through the whole DCERPC fragmentation, we just
26 * leverage much the same infrastructure we already have for it.
30 #include "winbindd/winbindd.h"
31 #include "winbindd/winbindd_proto.h"
33 #include "librpc/gen_ndr/srv_winbind.h"
35 struct wbint_bh_state
{
36 struct winbindd_domain
*domain
;
37 struct winbindd_child
*child
;
40 static bool wbint_bh_is_connected(struct dcerpc_binding_handle
*h
)
42 struct wbint_bh_state
*hs
= dcerpc_binding_handle_data(h
,
43 struct wbint_bh_state
);
45 if ((hs
->domain
== NULL
) && (hs
->child
== NULL
)) {
52 static uint32_t wbint_bh_set_timeout(struct dcerpc_binding_handle
*h
,
55 /* TODO: implement timeouts */
59 struct wbint_bh_raw_call_state
{
60 struct winbindd_domain
*domain
;
63 struct winbindd_request request
;
64 struct winbindd_response
*response
;
68 static void wbint_bh_raw_call_child_done(struct tevent_req
*subreq
);
69 static void wbint_bh_raw_call_domain_done(struct tevent_req
*subreq
);
71 static struct tevent_req
*wbint_bh_raw_call_send(TALLOC_CTX
*mem_ctx
,
72 struct tevent_context
*ev
,
73 struct dcerpc_binding_handle
*h
,
74 const struct GUID
*object
,
77 const uint8_t *in_data
,
80 struct wbint_bh_state
*hs
=
81 dcerpc_binding_handle_data(h
,
82 struct wbint_bh_state
);
83 struct tevent_req
*req
;
84 struct wbint_bh_raw_call_state
*state
;
86 struct tevent_req
*subreq
;
88 req
= tevent_req_create(mem_ctx
, &state
,
89 struct wbint_bh_raw_call_state
);
93 state
->domain
= hs
->domain
;
95 state
->in_data
.data
= discard_const_p(uint8_t, in_data
);
96 state
->in_data
.length
= in_length
;
98 ok
= wbint_bh_is_connected(h
);
100 tevent_req_nterror(req
, NT_STATUS_CONNECTION_DISCONNECTED
);
101 return tevent_req_post(req
, ev
);
104 if ((state
->domain
!= NULL
)
105 && wcache_fetch_ndr(state
, state
->domain
, state
->opnum
,
106 &state
->in_data
, &state
->out_data
)) {
107 DBG_DEBUG("Got opnum %"PRIu32
" for domain %s from cache\n",
108 state
->opnum
, state
->domain
->name
);
109 tevent_req_done(req
);
110 return tevent_req_post(req
, ev
);
113 state
->request
.cmd
= WINBINDD_DUAL_NDRCMD
;
114 state
->request
.data
.ndrcmd
= state
->opnum
;
115 state
->request
.extra_data
.data
= (char *)state
->in_data
.data
;
116 state
->request
.extra_len
= state
->in_data
.length
;
118 if (hs
->child
!= NULL
) {
119 subreq
= wb_child_request_send(state
, ev
, hs
->child
,
121 if (tevent_req_nomem(subreq
, req
)) {
122 return tevent_req_post(req
, ev
);
124 tevent_req_set_callback(
125 subreq
, wbint_bh_raw_call_child_done
, req
);
129 subreq
= wb_domain_request_send(state
, ev
, hs
->domain
,
131 if (tevent_req_nomem(subreq
, req
)) {
132 return tevent_req_post(req
, ev
);
134 tevent_req_set_callback(subreq
, wbint_bh_raw_call_domain_done
, req
);
139 static void wbint_bh_raw_call_child_done(struct tevent_req
*subreq
)
141 struct tevent_req
*req
=
142 tevent_req_callback_data(subreq
,
144 struct wbint_bh_raw_call_state
*state
=
146 struct wbint_bh_raw_call_state
);
149 ret
= wb_child_request_recv(subreq
, state
, &state
->response
, &err
);
152 NTSTATUS status
= map_nt_error_from_unix(err
);
153 tevent_req_nterror(req
, status
);
157 state
->out_data
= data_blob_talloc(state
,
158 state
->response
->extra_data
.data
,
159 state
->response
->length
- sizeof(struct winbindd_response
));
160 if (state
->response
->extra_data
.data
&& !state
->out_data
.data
) {
165 if (state
->domain
!= NULL
) {
166 wcache_store_ndr(state
->domain
, state
->opnum
,
167 &state
->in_data
, &state
->out_data
);
170 tevent_req_done(req
);
173 static void wbint_bh_raw_call_domain_done(struct tevent_req
*subreq
)
175 struct tevent_req
*req
=
176 tevent_req_callback_data(subreq
,
178 struct wbint_bh_raw_call_state
*state
=
180 struct wbint_bh_raw_call_state
);
183 ret
= wb_domain_request_recv(subreq
, state
, &state
->response
, &err
);
186 NTSTATUS status
= map_nt_error_from_unix(err
);
187 tevent_req_nterror(req
, status
);
191 state
->out_data
= data_blob_talloc(state
,
192 state
->response
->extra_data
.data
,
193 state
->response
->length
- sizeof(struct winbindd_response
));
194 if (state
->response
->extra_data
.data
&& !state
->out_data
.data
) {
199 if (state
->domain
!= NULL
) {
200 wcache_store_ndr(state
->domain
, state
->opnum
,
201 &state
->in_data
, &state
->out_data
);
204 tevent_req_done(req
);
207 static NTSTATUS
wbint_bh_raw_call_recv(struct tevent_req
*req
,
213 struct wbint_bh_raw_call_state
*state
=
215 struct wbint_bh_raw_call_state
);
218 if (tevent_req_is_nterror(req
, &status
)) {
219 tevent_req_received(req
);
223 *out_data
= talloc_move(mem_ctx
, &state
->out_data
.data
);
224 *out_length
= state
->out_data
.length
;
226 tevent_req_received(req
);
230 struct wbint_bh_disconnect_state
{
234 static struct tevent_req
*wbint_bh_disconnect_send(TALLOC_CTX
*mem_ctx
,
235 struct tevent_context
*ev
,
236 struct dcerpc_binding_handle
*h
)
238 struct wbint_bh_state
*hs
= dcerpc_binding_handle_data(h
,
239 struct wbint_bh_state
);
240 struct tevent_req
*req
;
241 struct wbint_bh_disconnect_state
*state
;
244 req
= tevent_req_create(mem_ctx
, &state
,
245 struct wbint_bh_disconnect_state
);
250 ok
= wbint_bh_is_connected(h
);
252 tevent_req_nterror(req
, NT_STATUS_CONNECTION_DISCONNECTED
);
253 return tevent_req_post(req
, ev
);
257 * TODO: do a real async disconnect ...
262 tevent_req_done(req
);
263 return tevent_req_post(req
, ev
);
266 static NTSTATUS
wbint_bh_disconnect_recv(struct tevent_req
*req
)
270 if (tevent_req_is_nterror(req
, &status
)) {
271 tevent_req_received(req
);
275 tevent_req_received(req
);
279 static bool wbint_bh_ref_alloc(struct dcerpc_binding_handle
*h
)
284 static void wbint_bh_do_ndr_print(struct dcerpc_binding_handle
*h
,
286 const void *_struct_ptr
,
287 const struct ndr_interface_call
*call
)
289 void *struct_ptr
= discard_const(_struct_ptr
);
291 if (DEBUGLEVEL
< 10) {
295 if (ndr_flags
& NDR_IN
) {
296 ndr_print_function_debug(call
->ndr_print
,
301 if (ndr_flags
& NDR_OUT
) {
302 ndr_print_function_debug(call
->ndr_print
,
309 static const struct dcerpc_binding_handle_ops wbint_bh_ops
= {
311 .is_connected
= wbint_bh_is_connected
,
312 .set_timeout
= wbint_bh_set_timeout
,
313 .raw_call_send
= wbint_bh_raw_call_send
,
314 .raw_call_recv
= wbint_bh_raw_call_recv
,
315 .disconnect_send
= wbint_bh_disconnect_send
,
316 .disconnect_recv
= wbint_bh_disconnect_recv
,
318 .ref_alloc
= wbint_bh_ref_alloc
,
319 .do_ndr_print
= wbint_bh_do_ndr_print
,
322 /* initialise a wbint binding handle */
323 struct dcerpc_binding_handle
*wbint_binding_handle(TALLOC_CTX
*mem_ctx
,
324 struct winbindd_domain
*domain
,
325 struct winbindd_child
*child
)
327 struct dcerpc_binding_handle
*h
;
328 struct wbint_bh_state
*hs
;
330 h
= dcerpc_binding_handle_create(mem_ctx
,
335 struct wbint_bh_state
,
346 enum winbindd_result
winbindd_dual_ndrcmd(struct winbindd_domain
*domain
,
347 struct winbindd_cli_state
*state
)
349 struct pipes_struct p
;
350 const struct api_struct
*fns
;
354 fns
= winbind_get_pipe_fns(&num_fns
);
356 if (state
->request
->data
.ndrcmd
>= num_fns
) {
357 return WINBINDD_ERROR
;
360 DEBUG(10, ("winbindd_dual_ndrcmd: Running command %s (%s)\n",
361 fns
[state
->request
->data
.ndrcmd
].name
,
362 domain
? domain
->name
: "no domain"));
365 p
.mem_ctx
= talloc_stackframe();
366 p
.in_data
.data
= data_blob_const(state
->request
->extra_data
.data
,
367 state
->request
->extra_len
);
369 ret
= fns
[state
->request
->data
.ndrcmd
].fn(&p
);
371 TALLOC_FREE(p
.mem_ctx
);
372 return WINBINDD_ERROR
;
375 state
->response
->extra_data
.data
=
376 talloc_move(state
->mem_ctx
, &p
.out_data
.rdata
.data
);
377 state
->response
->length
+= p
.out_data
.rdata
.length
;
378 p
.out_data
.rdata
.length
= 0;
380 TALLOC_FREE(p
.mem_ctx
);
382 if (state
->response
->extra_data
.data
== NULL
) {
383 return WINBINDD_ERROR
;