*
* @retval True for success.
**/
-BOOL message_send_all(int msg_type,
+BOOL message_send_all(struct messaging_context *msg_ctx,
+ int msg_type,
const void *buf, size_t len,
BOOL duplicates_allowed,
int *n_sent)
{
DEBUG(3, ("sending replication message, serial = 0x%04x\n",
low_serial));
- message_send_all(MSG_SMB_SAM_REPL, &low_serial,
- sizeof(low_serial), False, NULL);
+ message_send_all(nmbd_messaging_context(), MSG_SMB_SAM_REPL,
+ &low_serial, sizeof(low_serial), False, NULL);
}
/****************************************************************************
static void send_sync_message(void)
{
DEBUG(3, ("sending sam synchronisation message\n"));
- message_send_all(MSG_SMB_SAM_SYNC, NULL, 0, False, NULL);
+ message_send_all(smbd_messaging_context(), MSG_SMB_SAM_SYNC, NULL, 0,
+ False, NULL);
}
/*************************************************************************
if ( (ret = smbrun(command, NULL)) == 0 ) {
/* Tell everyone we updated smb.conf. */
- message_send_all(MSG_SMB_CONF_UPDATED, NULL, 0, False, NULL);
+ message_send_all(smbd_messaging_context(),
+ MSG_SMB_CONF_UPDATED, NULL, 0, False, NULL);
}
if ( is_print_op )
if ( (ret = smbrun(command, &fd)) == 0 ) {
/* Tell everyone we updated smb.conf. */
- message_send_all(MSG_SMB_CONF_UPDATED, NULL, 0, False, NULL);
+ message_send_all(smbd_messaging_context(),
+ MSG_SMB_CONF_UPDATED, NULL, 0, False, NULL);
}
if ( is_print_op )
if ( (ret = smbrun(command, NULL)) == 0 ) {
/* Tell everyone we updated smb.conf. */
- message_send_all(MSG_SMB_CONF_UPDATED,
+ message_send_all(smbd_messaging_context(),
+ MSG_SMB_CONF_UPDATED,
NULL, 0, False, NULL);
}
if ( (ret = smbrun(command, NULL)) == 0 ) {
/* Tell everyone we updated smb.conf. */
- message_send_all(MSG_SMB_CONF_UPDATED,
+ message_send_all(smbd_messaging_context(),
+ MSG_SMB_CONF_UPDATED,
NULL, 0, False, NULL);
}
if ( (ret = smbrun(command, NULL)) == 0 ) {
/* Tell everyone we updated smb.conf. */
- message_send_all(MSG_SMB_CONF_UPDATED,
+ message_send_all(smbd_messaging_context(),
+ MSG_SMB_CONF_UPDATED,
NULL, 0, False, NULL);
}
goto error_exit;
} else {
SAFE_FREE(command);
- message_send_all(MSG_SMB_CONF_UPDATED, NULL, 0,
+ message_send_all(smbd_messaging_context(),
+ MSG_SMB_CONF_UPDATED, NULL, 0,
False, NULL);
}
} else {
void send_stat_cache_delete_message(const char *name)
{
#ifdef DEVELOPER
- message_send_all(MSG_SMB_STAT_CACHE_DELETE,
+ message_send_all(smbd_messaging_context(),
+ MSG_SMB_STAT_CACHE_DELETE,
name,
strlen(name)+1,
True,
messaging_send_buf(msg_ctx, pid, msg_type,
(uint8 *)buf, len));
- ret = message_send_all(msg_type, buf, len, duplicates,
+ ret = message_send_all(msg_ctx, msg_type, buf, len, duplicates,
&n_sent);
DEBUG(10,("smbcontrol/send_message: broadcast message to "
"%d processes\n", n_sent));