2 Unix SMB/CIFS implementation.
3 Main winbindd irpc handlers
5 Copyright (C) Stefan Metzmacher 2006
7 This program is free software; you can redistribute it and/or modify
8 it under the terms of the GNU General Public License as published by
9 the Free Software Foundation; either version 3 of the License, or
10 (at your option) any later version.
12 This program is distributed in the hope that it will be useful,
13 but WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 GNU General Public License for more details.
17 You should have received a copy of the GNU General Public License
18 along with this program. If not, see <http://www.gnu.org/licenses/>.
22 #include "winbind/wb_server.h"
23 #include "lib/messaging/irpc.h"
24 #include "libcli/composite/composite.h"
25 #include "librpc/gen_ndr/ndr_winbind.h"
26 #include "smbd/service_task.h"
28 struct wb_irpc_SamLogon_state {
29 struct irpc_message *msg;
30 struct winbind_SamLogon *req;
33 static void wb_irpc_SamLogon_callback(struct tevent_req *subreq);
35 static NTSTATUS wb_irpc_SamLogon(struct irpc_message *msg,
36 struct winbind_SamLogon *req)
38 struct wbsrv_service *service = talloc_get_type(msg->private_data,
39 struct wbsrv_service);
40 struct wb_irpc_SamLogon_state *s;
41 struct tevent_req *subreq;
43 DEBUG(5, ("wb_irpc_SamLogon called\n"));
45 s = talloc(msg, struct wb_irpc_SamLogon_state);
46 NT_STATUS_HAVE_NO_MEMORY(s);
51 subreq = wb_sam_logon_send(s,
52 service->task->event_ctx,
54 NT_STATUS_HAVE_NO_MEMORY(subreq);
56 tevent_req_set_callback(subreq, wb_irpc_SamLogon_callback, s);
58 msg->defer_reply = true;
62 static void wb_irpc_SamLogon_callback(struct tevent_req *subreq)
64 struct wb_irpc_SamLogon_state *s =
65 tevent_req_callback_data(subreq,
66 struct wb_irpc_SamLogon_state);
69 DEBUG(5, ("wb_irpc_SamLogon_callback called\n"));
71 status = wb_sam_logon_recv(subreq, s, s->req);
74 irpc_send_reply(s->msg, status);
77 struct wb_irpc_DsrUpdateReadOnlyServerDnsRecords_state {
78 struct irpc_message *msg;
79 struct winbind_DsrUpdateReadOnlyServerDnsRecords *req;
82 static void wb_irpc_DsrUpdateReadOnlyServerDnsRecords_callback(struct composite_context *ctx);
84 static NTSTATUS wb_irpc_DsrUpdateReadOnlyServerDnsRecords(struct irpc_message *msg,
85 struct winbind_DsrUpdateReadOnlyServerDnsRecords *req)
87 struct wbsrv_service *service = talloc_get_type(msg->private_data,
88 struct wbsrv_service);
89 struct wb_irpc_DsrUpdateReadOnlyServerDnsRecords_state *s;
90 struct composite_context *ctx;
92 DEBUG(5, ("wb_irpc_DsrUpdateReadOnlyServerDnsRecords called\n"));
94 s = talloc(msg, struct wb_irpc_DsrUpdateReadOnlyServerDnsRecords_state);
95 NT_STATUS_HAVE_NO_MEMORY(s);
100 ctx = wb_update_rodc_dns_send(msg, service, req);
101 NT_STATUS_HAVE_NO_MEMORY(ctx);
103 ctx->async.fn = wb_irpc_DsrUpdateReadOnlyServerDnsRecords_callback;
104 ctx->async.private_data = s;
106 msg->defer_reply = true;
110 static void wb_irpc_DsrUpdateReadOnlyServerDnsRecords_callback(struct composite_context *ctx)
112 struct wb_irpc_DsrUpdateReadOnlyServerDnsRecords_state *s = talloc_get_type(ctx->async.private_data,
113 struct wb_irpc_DsrUpdateReadOnlyServerDnsRecords_state);
116 DEBUG(5, ("wb_irpc_DsrUpdateReadOnlyServerDnsRecords_callback called\n"));
118 status = wb_update_rodc_dns_recv(ctx, s, s->req);
120 irpc_send_reply(s->msg, status);
123 struct wb_irpc_get_idmap_state {
124 struct irpc_message *msg;
125 struct winbind_get_idmap *req;
129 static void wb_irpc_get_idmap_callback(struct composite_context *ctx);
131 static NTSTATUS wb_irpc_get_idmap(struct irpc_message *msg,
132 struct winbind_get_idmap *req)
134 struct wbsrv_service *service = talloc_get_type(msg->private_data,
135 struct wbsrv_service);
136 struct wb_irpc_get_idmap_state *s;
137 struct composite_context *ctx = NULL;
139 DEBUG(5, ("wb_irpc_get_idmap called\n"));
141 s = talloc(msg, struct wb_irpc_get_idmap_state);
142 NT_STATUS_HAVE_NO_MEMORY(s);
146 s->level = req->in.level;
149 case WINBIND_IDMAP_LEVEL_SIDS_TO_XIDS:
150 ctx = wb_sids2xids_send(msg, service, req->in.count,
153 case WINBIND_IDMAP_LEVEL_XIDS_TO_SIDS:
154 ctx = wb_xids2sids_send(msg, service, req->in.count,
158 NT_STATUS_HAVE_NO_MEMORY(ctx);
160 composite_continue(ctx, ctx, wb_irpc_get_idmap_callback, s);
161 msg->defer_reply = true;
166 static void wb_irpc_get_idmap_callback(struct composite_context *ctx)
168 struct wb_irpc_get_idmap_state *s;
171 DEBUG(5, ("wb_irpc_get_idmap_callback called\n"));
173 s = talloc_get_type(ctx->async.private_data,
174 struct wb_irpc_get_idmap_state);
177 case WINBIND_IDMAP_LEVEL_SIDS_TO_XIDS:
178 status = wb_sids2xids_recv(ctx, &s->req->out.ids, NULL);
180 case WINBIND_IDMAP_LEVEL_XIDS_TO_SIDS:
181 status = wb_xids2sids_recv(ctx, &s->req->out.ids);
184 status = NT_STATUS_INTERNAL_ERROR;
188 irpc_send_reply(s->msg, status);
191 NTSTATUS wbsrv_init_irpc(struct wbsrv_service *service)
195 irpc_add_name(service->task->msg_ctx, "winbind_server");
197 status = IRPC_REGISTER(service->task->msg_ctx, winbind, WINBIND_SAMLOGON,
198 wb_irpc_SamLogon, service);
199 NT_STATUS_NOT_OK_RETURN(status);
201 status = IRPC_REGISTER(service->task->msg_ctx, winbind, WINBIND_DSRUPDATEREADONLYSERVERDNSRECORDS,
202 wb_irpc_DsrUpdateReadOnlyServerDnsRecords, service);
203 NT_STATUS_NOT_OK_RETURN(status);
205 status = IRPC_REGISTER(service->task->msg_ctx, winbind, WINBIND_GET_IDMAP,
206 wb_irpc_get_idmap, service);
207 NT_STATUS_NOT_OK_RETURN(status);