messaging3: The backend send_fn doesn't need a messaging_context
authorVolker Lendecke <vl@samba.org>
Thu, 29 May 2014 12:51:37 +0000 (14:51 +0200)
committerJeremy Allison <jra@samba.org>
Fri, 30 May 2014 23:59:17 +0000 (01:59 +0200)
Signed-off-by: Volker Lendecke <vl@samba.org>
Reviewed-by: Jeremy Allison <jra@samba.org>
source3/include/messages.h
source3/lib/messages.c
source3/lib/messages_ctdbd.c
source3/lib/messages_dgm.c

index 18362f9d88ce442b81b4550a7bd1a9c792aa60e4..9a63cd64b1a2fda7a8de00a988bd737dcd9b72e0 100644 (file)
@@ -87,7 +87,7 @@ struct messaging_context {
 };
 
 struct messaging_backend {
-       NTSTATUS (*send_fn)(struct messaging_context *msg_ctx,
+       NTSTATUS (*send_fn)(struct server_id src,
                            struct server_id pid, int msg_type,
                            const struct iovec *iov, int iovlen,
                            struct messaging_backend *backend);
index 6e2e7ca9e2ccb0ba8f2b21076a9edc9419a85943..9e77009d02513bc45aecb10d8874605eac880705 100644 (file)
@@ -380,7 +380,7 @@ NTSTATUS messaging_send_iov(struct messaging_context *msg_ctx,
        }
 
        if (!procid_is_local(&server)) {
-               return msg_ctx->remote->send_fn(msg_ctx, server,
+               return msg_ctx->remote->send_fn(msg_ctx->id, server,
                                                msg_type, iov, iovlen,
                                                msg_ctx->remote);
        }
@@ -407,8 +407,8 @@ NTSTATUS messaging_send_iov(struct messaging_context *msg_ctx,
                return NT_STATUS_OK;
        }
 
-       return msg_ctx->local->send_fn(msg_ctx, server, msg_type, iov, iovlen,
-                                      msg_ctx->local);
+       return msg_ctx->local->send_fn(msg_ctx->id, server, msg_type,
+                                      iov, iovlen, msg_ctx->local);
 }
 
 static struct messaging_rec *messaging_rec_dup(TALLOC_CTX *mem_ctx,
index 34b3e2a0ff8a4399fae10a30233ed73dcdccb0d0..3b7fa0532282f8401a891d5611579fa89ac109f3 100644 (file)
@@ -88,7 +88,7 @@ struct ctdbd_connection *messaging_ctdbd_connection(void)
        return global_ctdbd_connection;
 }
 
-static NTSTATUS messaging_ctdb_send(struct messaging_context *msg_ctx,
+static NTSTATUS messaging_ctdb_send(struct server_id src,
                                    struct server_id pid, int msg_type,
                                    const struct iovec *iov, int iovlen,
                                    struct messaging_backend *backend)
@@ -109,7 +109,7 @@ static NTSTATUS messaging_ctdb_send(struct messaging_context *msg_ctx,
        msg.msg_version = MESSAGE_VERSION;
        msg.msg_type    = msg_type;
        msg.dest        = pid;
-       msg.src         = msg_ctx->id;
+       msg.src         = src;
        msg.buf         = data_blob_const(buf, talloc_get_size(buf));
 
        status = ctdbd_messaging_send(ctx->conn, pid.vnn, pid.pid, &msg);
index 6912035b94592eb6f81dbd7bbc27e2db3b44f806..2f2647e37f8e87391c826982463f6655356791db 100644 (file)
@@ -44,7 +44,7 @@ struct messaging_dgm_hdr {
        struct server_id src;
 };
 
-static NTSTATUS messaging_dgm_send(struct messaging_context *msg_ctx,
+static NTSTATUS messaging_dgm_send(struct server_id src,
                                   struct server_id pid, int msg_type,
                                   const struct iovec *iov, int iovlen,
                                   struct messaging_backend *backend);
@@ -286,7 +286,7 @@ static int messaging_dgm_context_destructor(struct messaging_dgm_context *c)
        return 0;
 }
 
-static NTSTATUS messaging_dgm_send(struct messaging_context *msg_ctx,
+static NTSTATUS messaging_dgm_send(struct server_id src,
                                   struct server_id pid, int msg_type,
                                   const struct iovec *iov, int iovlen,
                                   struct messaging_backend *backend)
@@ -312,7 +312,7 @@ static NTSTATUS messaging_dgm_send(struct messaging_context *msg_ctx,
        hdr.msg_version = MESSAGE_VERSION;
        hdr.msg_type = msg_type & MSG_TYPE_MASK;
        hdr.dst = pid;
-       hdr.src = msg_ctx->id;
+       hdr.src = src;
 
        DEBUG(10, ("%s: Sending message 0x%x to %s\n", __func__,
                   (unsigned)hdr.msg_type,