From 8f9369f2e627cf2da4f5902be570200a9d2b1a67 Mon Sep 17 00:00:00 2001 From: Volker Lendecke Date: Tue, 15 May 2007 12:18:17 +0000 Subject: r22900: Convert profile/ to messaging_send_pid/messaging_register (This used to be commit edbeea520727f51568ccd8ffa802e06bd120794c) --- source3/profile/profile.c | 36 ++++++++++++++++++++++++++---------- 1 file changed, 26 insertions(+), 10 deletions(-) (limited to 'source3/profile') diff --git a/source3/profile/profile.c b/source3/profile/profile.c index c4136950a5..257b0abba5 100644 --- a/source3/profile/profile.c +++ b/source3/profile/profile.c @@ -93,20 +93,31 @@ void set_profile_level(int level, struct server_id src) /**************************************************************************** receive a set profile level message ****************************************************************************/ -void profile_message(int msg_type, struct server_id src, void *buf, size_t len, - void *private_data) +static void profile_message(struct messaging_context *msg_ctx, + void *private_data, + uint32_t msg_type, + struct server_id src, + DATA_BLOB *data) { int level; - memcpy(&level, buf, sizeof(int)); + if (data->length != sizeof(level)) { + DEBUG(0, ("got invalid profile message\n")); + return; + } + + memcpy(&level, data->data, sizeof(level)); set_profile_level(level, src); } /**************************************************************************** receive a request profile level message ****************************************************************************/ -void reqprofile_message(int msg_type, struct server_id src, - void *buf, size_t len, void *private_data) +static void reqprofile_message(struct messaging_context *msg_ctx, + void *private_data, + uint32_t msg_type, + struct server_id src, + DATA_BLOB *data) { int level; @@ -117,7 +128,8 @@ void reqprofile_message(int msg_type, struct server_id src, #endif DEBUG(1,("INFO: Received REQ_PROFILELEVEL message from PID %u\n", (unsigned int)procid_to_pid(&src))); - message_send_pid(src, MSG_PROFILELEVEL, &level, sizeof(int), True); + messaging_send_buf(msg_ctx, src, MSG_PROFILELEVEL, + (uint8 *)&level, sizeof(level)); } /******************************************************************* @@ -184,7 +196,7 @@ static void init_clock_gettime(void) } #endif -BOOL profile_setup(BOOL rdonly) +BOOL profile_setup(struct messaging_context *msg_ctx, BOOL rdonly) { struct shmid_ds shm_ds; @@ -238,7 +250,7 @@ BOOL profile_setup(BOOL rdonly) } if (shm_ds.shm_segsz != sizeof(*profile_h)) { - DEBUG(0,("WARNING: profile size is %d (expected %lu). Deleting\n", + DEBUG(0,("WARNING: profile size is %d (expected %d). Deleting\n", (int)shm_ds.shm_segsz, sizeof(*profile_h))); if (shmctl(shm_id, IPC_RMID, &shm_ds) == 0) { goto again; @@ -255,8 +267,12 @@ BOOL profile_setup(BOOL rdonly) } profile_p = &profile_h->stats; - message_register(MSG_PROFILE, profile_message, NULL); - message_register(MSG_REQ_PROFILELEVEL, reqprofile_message, NULL); + if (msg_ctx != NULL) { + messaging_register(msg_ctx, NULL, MSG_PROFILE, + profile_message); + messaging_register(msg_ctx, NULL, MSG_REQ_PROFILELEVEL, + reqprofile_message); + } return True; } -- cgit