svn commit: samba r5472 - in branches/SAMBA_4_0/source/libnet: .
mimir at samba.org
mimir at samba.org
Sun Feb 20 18:20:51 GMT 2005
Author: mimir
Date: 2005-02-20 18:20:51 +0000 (Sun, 20 Feb 2005)
New Revision: 5472
WebSVN: http://websvn.samba.org/cgi-bin/viewcvs.cgi?view=rev&root=samba&rev=5472
Log:
First approach to composite rpc call fetchin user info.
It does only compile. Completely untested yet, so almost certainly
broken, but I don't want it to lay on my laptop only.
rafal
Added:
branches/SAMBA_4_0/source/libnet/userinfo.c
Changeset:
Added: branches/SAMBA_4_0/source/libnet/userinfo.c
===================================================================
--- branches/SAMBA_4_0/source/libnet/userinfo.c 2005-02-20 15:15:33 UTC (rev 5471)
+++ branches/SAMBA_4_0/source/libnet/userinfo.c 2005-02-20 18:20:51 UTC (rev 5472)
@@ -0,0 +1,229 @@
+/*
+ Unix SMB/CIFS implementation.
+
+ Copyright (C) Rafal Szczesniak 2005
+
+ This program is free software; you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation; either version 2 of the License, or
+ (at your option) any later version.
+
+ This program is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ GNU General Public License for more details.
+
+ You should have received a copy of the GNU General Public License
+ along with this program; if not, write to the Free Software
+ Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+*/
+
+/*
+ a composite function for getting user information via samr pipe
+*/
+
+#include "includes.h"
+#include "libcli/raw/libcliraw.h"
+#include "libcli/composite/composite.h"
+#include "librpc/gen_ndr/ndr_samr.h"
+
+enum userinfo_stage { USERINFO_OPENUSER, USERINFO_GETUSER, USERINFO_CLOSEUSER };
+
+struct rpc_composite_userinfo {
+ struct {
+ struct policy_handle domain_handle;
+ const char *sid;
+ uint16_t level;
+ } in;
+ struct {
+ union samr_UserInfo info;
+ } out;
+};
+
+struct userinfo_state {
+ enum userinfo_stage stage;
+ struct dcerpc_pipe *pipe;
+ struct rpc_composite_userinfo io;
+};
+
+static void userinfo_handler(struct rpc_request *req);
+
+
+static NTSTATUS userinfo_openuser(struct composite_context *c,
+ struct rpc_composite_userinfo *io)
+{
+ struct userinfo_state *s = talloc_get_type(c->private, struct userinfo_state);
+ struct rpc_request *req = s->pipe->conn->pending;
+ struct samr_OpenUser *rep;
+ struct samr_QueryUserInfo r;
+
+ /* receive samr_OpenUser reply */
+ c->status = dcerpc_ndr_request_recv(req);
+ NT_STATUS_NOT_OK_RETURN(c->status);
+ rep = (struct samr_OpenUser*)req->ndr.struct_ptr;
+
+ /* prepare parameters for QueryUserInfo call */
+ r.in.user_handle = talloc_zero(c, struct policy_handle);
+ memcpy((void*)r.in.user_handle, (void*)rep->out.user_handle, sizeof(struct policy_handle));
+ r.in.level = io->in.level;
+
+ /* queue rpc call, set event handling and new state */
+ s->pipe->conn->pending = dcerpc_samr_QueryUserInfo_send(s->pipe, c, &r);
+
+ s->pipe->conn->pending->async.callback = userinfo_handler;
+ s->pipe->conn->pending->async.private = c;
+ s->stage = USERINFO_GETUSER;
+
+ return rep->out.result;
+}
+
+
+static NTSTATUS userinfo_getuser(struct composite_context *c,
+ struct rpc_composite_userinfo *io)
+{
+ struct userinfo_state *s = talloc_get_type(c->private, struct userinfo_state);
+ struct rpc_request *req = s->pipe->conn->pending;
+ struct samr_QueryUserInfo *rep;
+ struct samr_Close r;
+
+ /* receive samr_QueryUserInfo reply */
+ c->status = dcerpc_ndr_request_recv(req);
+ NT_STATUS_NOT_OK_RETURN(c->status);
+ rep = (struct samr_QueryUserInfo*)req->ndr.struct_ptr;
+
+ /* prepare arguments for Close call */
+ r.in.handle = talloc_zero(c, struct policy_handle);
+ memcpy((void*)r.in.handle, (void*)rep->in.user_handle, sizeof(struct policy_handle));
+
+ /* queue rpc call, set event handling and new state */
+ s->pipe->conn->pending = dcerpc_samr_Close_send(s->pipe, c, &r);
+
+ s->pipe->conn->pending->async.callback = userinfo_handler;
+ s->pipe->conn->pending->async.private = c;
+ s->stage = USERINFO_CLOSEUSER;
+
+ /* copying result of composite call */
+ memcpy((void*)&io->out.info, (void*)rep->out.info, sizeof(union samr_UserInfo));
+
+ return rep->out.result;
+}
+
+
+static NTSTATUS userinfo_closeuser(struct composite_context *c,
+ struct rpc_composite_userinfo *io)
+{
+ struct userinfo_state *s = talloc_get_type(c->private, struct userinfo_state);
+ struct rpc_request *req = s->pipe->conn->pending;
+ struct samr_Close *rep;
+
+ /* receive samr_Close reply */
+ c->status = dcerpc_ndr_request_recv(req);
+ NT_STATUS_NOT_OK_RETURN(c->status);
+ rep = (struct samr_Close*)req->ndr.struct_ptr;
+
+ /* return result */
+ return rep->out.result;
+}
+
+
+static void userinfo_handler(struct rpc_request *req)
+{
+ struct composite_context *c = req->async.private;
+ struct userinfo_state *s = talloc_get_type(c->private, struct userinfo_state);
+
+ switch (s->stage) {
+ case USERINFO_OPENUSER:
+ c->status = userinfo_openuser(c, &s->io);
+ break;
+
+ case USERINFO_GETUSER:
+ c->status = userinfo_getuser(c, &s->io);
+ break;
+
+ case USERINFO_CLOSEUSER:
+ c->status = userinfo_closeuser(c, &s->io);
+ break;
+ }
+
+ if (!NT_STATUS_IS_OK(c->status)) {
+ /* this should be some error state instead */
+ c->state = RPC_REQUEST_DONE;
+ }
+
+ if (c->state >= RPC_REQUEST_DONE &&
+ c->async.fn) {
+ c->async.fn(c);
+ }
+}
+
+
+struct composite_context* rpc_composite_userinfo_send(struct dcerpc_pipe *p,
+ struct rpc_composite_userinfo *io)
+{
+
+ /* dom_sid_parse_talloc call */
+ struct composite_context *c;
+ struct userinfo_state *s;
+ struct samr_OpenUser *r;
+ struct dom_sid *sid;
+
+ c = talloc_zero(p, struct composite_context);
+ if (c == NULL) goto failure;
+
+ s = talloc_zero(c, struct userinfo_state);
+ if (s == NULL) goto failure;
+
+ /* copying input parameters */
+ memcpy((void*)&s->io.in.domain_handle, (void*)&io->in.domain_handle, sizeof(struct policy_handle));
+ s->io.in.sid = talloc_strdup(p, io->in.sid);
+ s->io.in.level = io->in.level;
+ sid = dom_sid_parse_talloc(c, s->io.in.sid);
+
+ c->private = s;
+ c->event_ctx = dcerpc_event_context(p);
+
+ /* preparing parameters to send rpc request */
+ r = talloc_zero(p, struct samr_OpenUser);
+ r->in.domain_handle = &s->io.in.domain_handle;
+ r->in.access_mask = 0;
+ r->in.rid = sid->sub_auths[sid->num_auths - 1];
+
+ /* send request */
+ s->pipe->conn->pending = dcerpc_samr_OpenUser_send(p, c, r);
+
+ /* callback handler */
+ s->pipe->conn->pending->async.callback = userinfo_handler;
+ s->pipe->conn->pending->async.private = c;
+ s->stage = USERINFO_OPENUSER;
+
+ return c;
+
+failure:
+ talloc_free(c);
+}
+
+
+NTSTATUS rpc_composite_userinfo_recv(struct composite_context *c, TALLOC_CTX *mem_ctx)
+{
+ NTSTATUS status;
+ struct userinfo_state *s;
+
+ status = composite_wait(c);
+
+ if (NT_STATUS_IS_OK(status)) {
+ s = talloc_get_type(c->private, struct userinfo_state);
+ talloc_steal(mem_ctx, &s->io.out.info);
+ }
+
+ talloc_free(c);
+ return status;
+}
+
+
+NTSTATUS rpc_composite_userinfo(struct dcerpc_pipe *pipe,
+ TALLOC_CTX *mem_ctx,
+ struct rpc_composite_userinfo *io)
+{
+ struct composite_context *c = rpc_composite_userinfo_send(pipe, io);
+ return rpc_composite_userinfo_recv(c, mem_ctx);
+}
More information about the samba-cvs
mailing list