r22911: Pass a messaging_context to message_send_all

diff --git a/source/lib/messages.c b/source/lib/messages.c
index 55eed105b3c3a8dc8658d3686fbcb65bb44281ea..9c1eba7b1c6349adbc620ed4f350018138b6b0c9 100644 (file)
--- a/source/lib/messages.c
+++ b/source/lib/messages.c
@@ -659,7 +659,8 @@ static int traverse_fn(TDB_CONTEXT *the_tdb, TDB_DATA kbuf, TDB_DATA dbuf, void
  *
  * @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)

diff --git a/source/nmbd/nmbd_processlogon.c b/source/nmbd/nmbd_processlogon.c
index 15be7f59c081ec92094a69f322cf7ca5f0eec6a9..0d869f1586bc09870c654781bd105bbe5bb957c8 100644 (file)
--- a/source/nmbd/nmbd_processlogon.c
+++ b/source/nmbd/nmbd_processlogon.c
@@ -40,8 +40,8 @@ static void send_repl_message(uint32 low_serial)
 {
         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);
 }
 
 /****************************************************************************

diff --git a/source/rpc_server/srv_netlog_nt.c b/source/rpc_server/srv_netlog_nt.c
index e110f39289aa7ec425f66d9e9ed6015a6dc2ccc2..4dd04c02881e24e85783eaae0bf7fb48d3a2cfa9 100644 (file)
--- a/source/rpc_server/srv_netlog_nt.c
+++ b/source/rpc_server/srv_netlog_nt.c
@@ -76,7 +76,8 @@ Send a message to smbd to do a sam synchronisation
 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);
 }
 
 /*************************************************************************

diff --git a/source/rpc_server/srv_spoolss_nt.c b/source/rpc_server/srv_spoolss_nt.c
index cbc44a224a09c8400b5d715094804aeb272972ce..e2dd773c04231f8bce6df8d35270601ebe434c46 100644 (file)
--- a/source/rpc_server/srv_spoolss_nt.c
+++ b/source/rpc_server/srv_spoolss_nt.c
@@ -311,7 +311,8 @@ WERROR delete_printer_hook( NT_USER_TOKEN *token, const char *sharename )
                
        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 )
@@ -6255,7 +6256,8 @@ BOOL add_printer_hook(NT_USER_TOKEN *token, NT_PRINTER_INFO_LEVEL *printer)
        
        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 )

diff --git a/source/rpc_server/srv_srvsvc_nt.c b/source/rpc_server/srv_srvsvc_nt.c
index bb60f57a149b99c314a5b3e9b42f73f61870f4bb..cf3268d44d9298047d191abc57d1db364477164e 100644 (file)
--- a/source/rpc_server/srv_srvsvc_nt.c
+++ b/source/rpc_server/srv_srvsvc_nt.c
@@ -1421,7 +1421,8 @@ static WERROR add_share(const char *share_name, const char *path,
 
                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);
                }
 
@@ -1517,7 +1518,8 @@ static WERROR delete_share(const char *sharename,
 
                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);
                }
 
@@ -1575,7 +1577,8 @@ static WERROR change_share(const char *share_name, const char *path,
                        
                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);
                }
                

diff --git a/source/smbd/lanman.c b/source/smbd/lanman.c
index b235fd16986fe6df1bcb131b5f5ecc8a31a010f3..fae63120802fa3cb16f246050e4af3c58c7338ab 100644 (file)
--- a/source/smbd/lanman.c
+++ b/source/smbd/lanman.c
@@ -1894,7 +1894,8 @@ static BOOL api_RNetShareAdd(connection_struct *conn,uint16 vuid,
                        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 {

diff --git a/source/smbd/statcache.c b/source/smbd/statcache.c
index 7c2c968d8dca4a27e387e3165c469555ffc475b2..1d6646257a962415c61b8502d9ce703635ddac40 100644 (file)
--- a/source/smbd/statcache.c
+++ b/source/smbd/statcache.c
@@ -292,7 +292,8 @@ BOOL stat_cache_lookup(connection_struct *conn, pstring name, pstring dirpath,
 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,

diff --git a/source/utils/smbcontrol.c b/source/utils/smbcontrol.c
index 7dfa385306c5ab928249890c016c16a1e46c996d..f9e39329f178159f124ff7b4f55200d744b45dbd 100644 (file)
--- a/source/utils/smbcontrol.c
+++ b/source/utils/smbcontrol.c
@@ -60,7 +60,7 @@ static BOOL send_message(struct messaging_context *msg_ctx,
                        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));