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; } }
