svn commit: samba r8761 - in branches/SAMBA_4_0/source: libnet
torture/libnet
mimir at samba.org
mimir at samba.org
Mon Jul 25 22:57:14 GMT 2005
Author: mimir
Date: 2005-07-25 22:57:14 +0000 (Mon, 25 Jul 2005)
New Revision: 8761
WebSVN: http://websvn.samba.org/cgi-bin/viewcvs.cgi?view=rev&root=samba&rev=8761
Log:
Propagate changes in monitor messaging code.
rafal
Modified:
branches/SAMBA_4_0/source/libnet/userinfo.c
branches/SAMBA_4_0/source/libnet/userman.c
branches/SAMBA_4_0/source/torture/libnet/userinfo.c
branches/SAMBA_4_0/source/torture/libnet/userman.c
Changeset:
Modified: branches/SAMBA_4_0/source/libnet/userinfo.c
===================================================================
--- branches/SAMBA_4_0/source/libnet/userinfo.c 2005-07-25 22:56:28 UTC (rev 8760)
+++ branches/SAMBA_4_0/source/libnet/userinfo.c 2005-07-25 22:57:14 UTC (rev 8761)
@@ -28,6 +28,7 @@
#include "libcli/composite/monitor.h"
#include "librpc/gen_ndr/ndr_samr.h"
#include "libnet/composite.h"
+#include "libnet/userinfo.h"
static void userinfo_handler(struct rpc_request *req);
@@ -129,26 +130,41 @@
struct composite_context *c = req->async.private;
struct userinfo_state *s = talloc_get_type(c->private, struct userinfo_state);
struct monitor_msg msg;
+ struct msg_rpc_open_user *msg_open;
+ struct msg_rpc_query_user *msg_query;
+ struct msg_rpc_close_user *msg_close;
/* Stages of the call */
switch (s->stage) {
case USERINFO_OPENUSER:
c->status = userinfo_openuser(c, s);
+
msg.type = rpc_open_user;
- msg.data.rpc_open_user.rid = s->openuser.in.rid;
- msg.data.rpc_open_user.access_mask = s->openuser.in.access_mask;
+ msg_open = talloc(s, struct msg_rpc_open_user);
+ msg_open->rid = s->openuser.in.rid;
+ msg_open->access_mask = s->openuser.in.access_mask;
+ msg.data = (void*)msg_open;
+ msg.data_size = sizeof(*msg_open);
break;
case USERINFO_GETUSER:
c->status = userinfo_getuser(c, s);
+
msg.type = rpc_query_user;
- msg.data.rpc_query_user.level = s->queryuserinfo.in.level;
+ msg_query = talloc(s, struct msg_rpc_query_user);
+ msg_query->level = s->queryuserinfo.in.level;
+ msg.data = (void*)msg_query;
+ msg.data_size = sizeof(*msg_query);
break;
case USERINFO_CLOSEUSER:
c->status = userinfo_closeuser(c, s);
+
msg.type = rpc_close_user;
- msg.data.rpc_close_user.rid = s->openuser.in.rid;
+ msg_close = talloc(s, struct msg_rpc_close_user);
+ msg_close->rid = s->openuser.in.rid;
+ msg.data = (void*)msg_close;
+ msg.data_size = sizeof(*msg_close);
break;
}
Modified: branches/SAMBA_4_0/source/libnet/userman.c
===================================================================
--- branches/SAMBA_4_0/source/libnet/userman.c 2005-07-25 22:56:28 UTC (rev 8760)
+++ branches/SAMBA_4_0/source/libnet/userman.c 2005-07-25 22:57:14 UTC (rev 8761)
@@ -28,6 +28,7 @@
#include "libcli/composite/monitor.h"
#include "librpc/gen_ndr/ndr_samr.h"
#include "libnet/composite.h"
+#include "libnet/userman.h"
/*
* Composite user add function
@@ -73,12 +74,17 @@
struct composite_context *c = req->async.private;
struct useradd_state *s = talloc_get_type(c->private, struct useradd_state);
struct monitor_msg msg;
+ struct msg_rpc_create_user *rpc_create;
switch (s->stage) {
case USERADD_CREATE:
c->status = useradd_create(c, s);
+
msg.type = rpc_create_user;
- msg.data.rpc_create_user.rid = *s->createuser.out.rid;
+ rpc_create = talloc(s, struct msg_rpc_create_user);
+ rpc_create->rid = *s->createuser.out.rid;
+ msg.data = (void*)rpc_create;
+ msg.data_size = sizeof(*rpc_create);
break;
}
Modified: branches/SAMBA_4_0/source/torture/libnet/userinfo.c
===================================================================
--- branches/SAMBA_4_0/source/torture/libnet/userinfo.c 2005-07-25 22:56:28 UTC (rev 8760)
+++ branches/SAMBA_4_0/source/torture/libnet/userinfo.c 2005-07-25 22:57:14 UTC (rev 8761)
@@ -22,6 +22,7 @@
#include "includes.h"
#include "librpc/gen_ndr/ndr_samr.h"
#include "libnet/composite.h"
+#include "libnet/userinfo.h"
#include "libcli/composite/monitor.h"
#define TEST_USERNAME "libnetuserinfotest"
@@ -206,16 +207,23 @@
static void msg_handler(struct monitor_msg *m)
{
+ struct msg_rpc_open_user *msg_open;
+ struct msg_rpc_query_user *msg_query;
+ struct msg_rpc_close_user *msg_close;
+
switch (m->type) {
case rpc_open_user:
+ msg_open = (struct msg_rpc_open_user*)m->data;
printf("monitor_msg: user opened (rid=%d, access_mask=0x%08x)\n",
- m->data.rpc_open_user.rid, m->data.rpc_open_user.access_mask);
+ msg_open->rid, msg_open->access_mask);
break;
case rpc_query_user:
- printf("monitor_msg: user queried (level=%d)\n", m->data.rpc_query_user.level);
+ msg_query = (struct msg_rpc_query_user*)m->data;
+ printf("monitor_msg: user queried (level=%d)\n", msg_query->level);
break;
case rpc_close_user:
- printf("monitor_msg: user closed (rid=%d)\n", m->data.rpc_close_user.rid);
+ msg_close = (struct msg_rpc_close_user*)m->data;
+ printf("monitor_msg: user closed (rid=%d)\n", msg_close->rid);
break;
}
}
Modified: branches/SAMBA_4_0/source/torture/libnet/userman.c
===================================================================
--- branches/SAMBA_4_0/source/torture/libnet/userman.c 2005-07-25 22:56:28 UTC (rev 8760)
+++ branches/SAMBA_4_0/source/torture/libnet/userman.c 2005-07-25 22:57:14 UTC (rev 8761)
@@ -22,6 +22,7 @@
#include "includes.h"
#include "librpc/gen_ndr/ndr_samr.h"
#include "libnet/composite.h"
+#include "libnet/userman.h"
#include "libcli/composite/monitor.h"
#define TEST_USERNAME "libnetusermantest"
@@ -103,9 +104,12 @@
static void msg_handler(struct monitor_msg *m)
{
+ struct msg_rpc_create_user *msg_create;
+
switch (m->type) {
case rpc_create_user:
- printf("monitor_msg: user created (rid=%d)\n", m->data.rpc_create_user.rid);
+ msg_create = (struct msg_rpc_create_user*)m->data;
+ printf("monitor_msg: user created (rid=%d)\n", msg_create->rid);
break;
}
}
More information about the samba-cvs
mailing list