svn commit: samba r24051 - in branches/SAMBA_4_0/source: libnet
torture/libnet
mimir at samba.org
mimir at samba.org
Wed Jul 25 23:17:04 GMT 2007
Author: mimir
Date: 2007-07-25 23:17:02 +0000 (Wed, 25 Jul 2007)
New Revision: 24051
WebSVN: http://websvn.samba.org/cgi-bin/viewcvs.cgi?view=rev&root=samba&rev=24051
Log:
more monitor function calls and monitor msg names
convention change.
rafal
Modified:
branches/SAMBA_4_0/source/libnet/composite.h
branches/SAMBA_4_0/source/libnet/libnet_domain.c
branches/SAMBA_4_0/source/libnet/libnet_rpc.c
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/composite.h
===================================================================
--- branches/SAMBA_4_0/source/libnet/composite.h 2007-07-25 20:01:03 UTC (rev 24050)
+++ branches/SAMBA_4_0/source/libnet/composite.h 2007-07-25 23:17:02 UTC (rev 24051)
@@ -24,24 +24,29 @@
*/
-#define rpc_create_user (0x00000001)
-#define rpc_open_user (0x00000002)
-#define rpc_query_user (0x00000003)
-#define rpc_close_user (0x00000004)
-#define rpc_lookup_name (0x00000005)
-#define rpc_delete_user (0x00000006)
-#define rpc_set_user (0x00000007)
-#define rpc_close (0x00000008)
-#define rpc_connect (0x00000009)
-#define rpc_lookup_domain (0x00000010)
-#define rpc_open_domain (0x00000011)
-#define rpc_open_policy (0x00000012)
-#define rpc_query_policy (0x00000013)
+#define mon_SamrCreateUser (0x00000001)
+#define mon_SamrOpenUser (0x00000002)
+#define mon_SamrQueryUser (0x00000003)
+#define mon_SamrCloseUser (0x00000004)
+#define mon_SamrLookupName (0x00000005)
+#define mon_SamrDeleteUser (0x00000006)
+#define mon_SamrSetUser (0x00000007)
+#define mon_SamrClose (0x00000008)
+#define mon_SamrConnect (0x00000009)
+#define mon_SamrLookupDomain (0x0000000A)
+#define mon_SamrOpenDomain (0x0000000B)
+#define mon_SamrEnumDomains (0x0000000C)
+#define mon_LsaOpenPolicy (0x0000000D)
+#define mon_LsaQueryPolicy (0x0000000E)
+#define mon_LsaClose (0x0000000F)
-#define net_lookup_dc (0x00000100)
-#define net_rpc_connect (0x00000200)
+#define mon_NetLookupDc (0x00000100)
+#define mon_NetRpcConnect (0x00000200)
+#define mon_Mask_Rpc (0x000000FF)
+#define mon_Mask_Net (0x0000FF00)
+
struct monitor_msg {
uint32_t type;
void *data;
Modified: branches/SAMBA_4_0/source/libnet/libnet_domain.c
===================================================================
--- branches/SAMBA_4_0/source/libnet/libnet_domain.c 2007-07-25 20:01:03 UTC (rev 24050)
+++ branches/SAMBA_4_0/source/libnet/libnet_domain.c 2007-07-25 23:17:02 UTC (rev 24051)
@@ -103,7 +103,7 @@
if (s->monitor_fn) {
struct monitor_msg msg;
- msg.type = rpc_close;
+ msg.type = mon_SamrClose;
msg.data = NULL;
msg.data_size = 0;
s->monitor_fn(&msg);
@@ -148,7 +148,7 @@
if (s->monitor_fn) {
struct monitor_msg msg;
- msg.type = rpc_connect;
+ msg.type = mon_SamrConnect;
msg.data = NULL;
msg.data_size = 0;
s->monitor_fn(&msg);
@@ -189,7 +189,7 @@
data.domain_name = s->domain_name.string;
- msg.type = rpc_lookup_domain;
+ msg.type = mon_SamrLookupDomain;
msg.data = (void*)&data;
msg.data_size = sizeof(data);
s->monitor_fn(&msg);
@@ -237,7 +237,7 @@
if (s->monitor_fn) {
struct monitor_msg msg;
- msg.type = rpc_open_domain;
+ msg.type = mon_SamrOpenDomain;
msg.data = NULL;
msg.data_size = 0;
s->monitor_fn(&msg);
@@ -518,6 +518,15 @@
c->status = dcerpc_ndr_request_recv(req);
if (!composite_is_ok(c)) return;
+ if (s->monitor_fn) {
+ struct monitor_msg msg;
+
+ msg.type = mon_LsaOpenPolicy;
+ msg.data = NULL;
+ msg.data_size = 0;
+ s->monitor_fn(&msg);
+ }
+
composite_done(c);
}
@@ -709,6 +718,15 @@
c->status = dcerpc_ndr_request_recv(req);
if (!composite_is_ok(c)) return;
+ if (s->monitor_fn) {
+ struct monitor_msg msg;
+
+ msg.type = mon_LsaClose;
+ msg.data = NULL;
+ msg.data_size = 0;
+ s->monitor_fn(&msg);
+ }
+
composite_done(c);
}
@@ -801,6 +819,15 @@
c->status = dcerpc_ndr_request_recv(req);
if (!composite_is_ok(c)) return;
+
+ if (s->monitor_fn) {
+ struct monitor_msg msg;
+
+ msg.type = mon_SamrClose;
+ msg.data = NULL;
+ msg.data_size = 0;
+ s->monitor_fn(&msg);
+ }
composite_done(c);
}
@@ -954,6 +981,15 @@
c->status = dcerpc_ndr_request_recv(req);
if (!composite_is_ok(c)) return;
+ if (s->monitor_fn) {
+ struct monitor_msg msg;
+
+ msg.type = mon_SamrConnect;
+ msg.data = NULL;
+ msg.data_size = 0;
+ s->monitor_fn(&msg);
+ }
+
s->enumdom.in.connect_handle = &s->connect_handle;
s->enumdom.in.resume_handle = &s->resume_handle;
s->enumdom.in.buf_size = s->buf_size;
@@ -984,6 +1020,15 @@
c->status = dcerpc_ndr_request_recv(req);
if (!composite_is_ok(c)) return;
+ if (s->monitor_fn) {
+ struct monitor_msg msg;
+
+ msg.type = mon_SamrEnumDomains;
+ msg.data = NULL;
+ msg.data_size = 0;
+ s->monitor_fn(&msg);
+ }
+
if (NT_STATUS_IS_OK(s->enumdom.out.result)) {
s->domains = get_domain_list(c, s);
@@ -1035,6 +1080,15 @@
c->status = dcerpc_ndr_request_recv(req);
if (!composite_is_ok(c)) return;
+ if (s->monitor_fn) {
+ struct monitor_msg msg;
+
+ msg.type = mon_SamrClose;
+ msg.data = NULL;
+ msg.data_size = 0;
+ s->monitor_fn(&msg);
+ }
+
/* did everything go fine ? */
if (!NT_STATUS_IS_OK(s->samrclose.out.result)) {
composite_error(c, s->samrclose.out.result);
Modified: branches/SAMBA_4_0/source/libnet/libnet_rpc.c
===================================================================
--- branches/SAMBA_4_0/source/libnet/libnet_rpc.c 2007-07-25 20:01:03 UTC (rev 24050)
+++ branches/SAMBA_4_0/source/libnet/libnet_rpc.c 2007-07-25 23:17:02 UTC (rev 24051)
@@ -148,7 +148,7 @@
data.transport = binding->transport;
data.domain_name = binding->target_hostname;
- msg.type = net_rpc_connect;
+ msg.type = mon_NetRpcConnect;
msg.data = (void*)&data;
msg.data_size = sizeof(data);
s->monitor_fn(&msg);
@@ -307,7 +307,7 @@
data.hostname = s->f.out.dcs[0].name;
data.address = s->f.out.dcs[0].address;
- msg.type = net_lookup_dc;
+ msg.type = mon_NetLookupDc;
msg.data = &data;
msg.data_size = sizeof(data);
s->monitor_fn(&msg);
@@ -360,7 +360,7 @@
data.transport = binding->transport;
data.domain_name = binding->target_hostname;
- msg.type = net_rpc_connect;
+ msg.type = mon_NetRpcConnect;
msg.data = (void*)&data;
msg.data_size = sizeof(data);
s->monitor_fn(&msg);
@@ -528,7 +528,7 @@
data.transport = binding->transport;
data.domain_name = binding->target_hostname;
- msg.type = net_rpc_connect;
+ msg.type = mon_NetRpcConnect;
msg.data = (void*)&data;
msg.data_size = sizeof(data);
s->monitor_fn(&msg);
@@ -596,7 +596,7 @@
if (s->monitor_fn) {
struct monitor_msg msg;
- msg.type = rpc_open_policy;
+ msg.type = mon_LsaOpenPolicy;
msg.data = NULL;
msg.data_size = 0;
s->monitor_fn(&msg);
@@ -669,7 +669,7 @@
if (s->monitor_fn) {
struct monitor_msg msg;
- msg.type = rpc_query_policy;
+ msg.type = mon_LsaQueryPolicy;
msg.data = NULL;
msg.data_size = 0;
s->monitor_fn(&msg);
@@ -710,7 +710,7 @@
if (s->monitor_fn) {
struct monitor_msg msg;
- msg.type = rpc_query_policy;
+ msg.type = mon_LsaQueryPolicy;
msg.data = NULL;
msg.data_size = 0;
s->monitor_fn(&msg);
@@ -816,7 +816,7 @@
data.transport = binding->transport;
data.domain_name = binding->target_hostname;
- msg.type = net_rpc_connect;
+ msg.type = mon_NetRpcConnect;
msg.data = (void*)&data;
msg.data_size = sizeof(data);
s->monitor_fn(&msg);
Modified: branches/SAMBA_4_0/source/libnet/userinfo.c
===================================================================
--- branches/SAMBA_4_0/source/libnet/userinfo.c 2007-07-25 20:01:03 UTC (rev 24050)
+++ branches/SAMBA_4_0/source/libnet/userinfo.c 2007-07-25 23:17:02 UTC (rev 24051)
@@ -79,7 +79,7 @@
/* issue a monitor message */
if (s->monitor_fn) {
- msg.type = rpc_lookup_name;
+ msg.type = mon_SamrLookupName;
msg_lookup = talloc(s, struct msg_rpc_lookup_name);
msg_lookup->rid = s->lookup.out.rids.ids;
msg_lookup->count = s->lookup.out.rids.count;
@@ -137,7 +137,7 @@
/* issue a monitor message */
if (s->monitor_fn) {
- msg.type = rpc_open_user;
+ msg.type = mon_SamrOpenUser;
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;
@@ -187,7 +187,7 @@
/* issue a monitor message */
if (s->monitor_fn) {
- msg.type = rpc_query_user;
+ msg.type = mon_SamrQueryUser;
msg_query = talloc(s, struct msg_rpc_query_user);
msg_query->level = s->queryuserinfo.in.level;
msg.data = (void*)msg_query;
@@ -232,7 +232,7 @@
/* issue a monitor message */
if (s->monitor_fn) {
- msg.type = rpc_close_user;
+ msg.type = mon_SamrClose;
msg_close = talloc(s, struct msg_rpc_close_user);
msg_close->rid = s->openuser.in.rid;
msg.data = (void*)msg_close;
Modified: branches/SAMBA_4_0/source/libnet/userman.c
===================================================================
--- branches/SAMBA_4_0/source/libnet/userman.c 2007-07-25 20:01:03 UTC (rev 24050)
+++ branches/SAMBA_4_0/source/libnet/userman.c 2007-07-25 23:17:02 UTC (rev 24051)
@@ -85,7 +85,7 @@
c->status = useradd_create(c, s);
/* prepare a message to pass to monitor function */
- msg.type = rpc_create_user;
+ msg.type = mon_SamrCreateUser;
rpc_create = talloc(s, struct msg_rpc_create_user);
rpc_create->rid = *s->createuser.out.rid;
msg.data = (void*)rpc_create;
@@ -350,7 +350,7 @@
c->status = userdel_lookup(c, s);
/* monitor message */
- msg.type = rpc_lookup_name;
+ msg.type = mon_SamrLookupName;
msg_lookup = talloc(s, struct msg_rpc_lookup_name);
msg_lookup->rid = s->lookupname.out.rids.ids;
@@ -363,7 +363,7 @@
c->status = userdel_open(c, s);
/* monitor message */
- msg.type = rpc_open_user;
+ msg.type = mon_SamrOpenUser;
msg_open = talloc(s, struct msg_rpc_open_user);
msg_open->rid = s->openuser.in.rid;
@@ -376,7 +376,7 @@
c->status = userdel_delete(c, s);
/* monitor message */
- msg.type = rpc_delete_user;
+ msg.type = mon_SamrDeleteUser;
msg.data = NULL;
msg.data_size = 0;
break;
@@ -829,7 +829,7 @@
if (NT_STATUS_IS_OK(c->status)) {
/* monitor message */
- msg.type = rpc_lookup_name;
+ msg.type = mon_SamrLookupName;
msg_lookup = talloc(s, struct msg_rpc_lookup_name);
msg_lookup->rid = s->lookupname.out.rids.ids;
@@ -844,7 +844,7 @@
if (NT_STATUS_IS_OK(c->status)) {
/* monitor message */
- msg.type = rpc_open_user;
+ msg.type = mon_SamrOpenUser;
msg_open = talloc(s, struct msg_rpc_open_user);
msg_open->rid = s->openuser.in.rid;
@@ -859,7 +859,7 @@
if (NT_STATUS_IS_OK(c->status)) {
/* monitor message */
- msg.type = rpc_query_user;
+ msg.type = mon_SamrQueryUser;
msg.data = NULL;
msg.data_size = 0;
}
@@ -870,7 +870,7 @@
if (NT_STATUS_IS_OK(c->status)) {
/* monitor message */
- msg.type = rpc_set_user;
+ msg.type = mon_SamrSetUser;
msg.data = NULL;
msg.data_size = 0;
}
Modified: branches/SAMBA_4_0/source/torture/libnet/userinfo.c
===================================================================
--- branches/SAMBA_4_0/source/torture/libnet/userinfo.c 2007-07-25 20:01:03 UTC (rev 24050)
+++ branches/SAMBA_4_0/source/torture/libnet/userinfo.c 2007-07-25 23:17:02 UTC (rev 24051)
@@ -226,16 +226,16 @@
struct msg_rpc_close_user *msg_close;
switch (m->type) {
- case rpc_open_user:
+ case mon_SamrOpenUser:
msg_open = (struct msg_rpc_open_user*)m->data;
printf("monitor_msg: user opened (rid=%d, access_mask=0x%08x)\n",
msg_open->rid, msg_open->access_mask);
break;
- case rpc_query_user:
+ case mon_SamrQueryUser:
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:
+ case mon_SamrCloseUser:
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 2007-07-25 20:01:03 UTC (rev 24050)
+++ branches/SAMBA_4_0/source/torture/libnet/userman.c 2007-07-25 23:17:02 UTC (rev 24051)
@@ -104,7 +104,7 @@
struct msg_rpc_create_user *msg_create;
switch (m->type) {
- case rpc_create_user:
+ case mon_SamrCreateUser:
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