return NT_STATUS_NO_MEMORY;
}
- rec.msg_version = MESSAGE_VERSION;
- rec.msg_type = msg_type & MSG_TYPE_MASK;
- rec.dest = server;
- rec.src = msg_ctx->id;
- rec.buf = data_blob_const(buf, talloc_get_size(buf));
+ rec = (struct messaging_rec) {
+ .msg_version = MESSAGE_VERSION,
+ .msg_type = msg_type & MSG_TYPE_MASK,
+ .dest = server,
+ .src = msg_ctx->id,
+ .buf = data_blob_const(buf, talloc_get_size(buf)),
+ };
+
messaging_dispatch_rec(msg_ctx, &rec);
TALLOC_FREE(buf);
return NT_STATUS_OK;
{
struct messaging_ctdbd_context *ctx = talloc_get_type_abort(
backend->private_data, struct messaging_ctdbd_context);
-
struct messaging_rec msg;
uint8_t *buf;
NTSTATUS status;
return ENOMEM;
}
-
- msg.msg_version = MESSAGE_VERSION;
- msg.msg_type = msg_type;
- msg.dest = pid;
- msg.src = src;
- msg.buf = data_blob_const(buf, talloc_get_size(buf));
+ msg = (struct messaging_rec) {
+ .msg_version = MESSAGE_VERSION,
+ .msg_type = msg_type,
+ .dest = pid,
+ .src = src,
+ .buf = data_blob_const(buf, talloc_get_size(buf)),
+ };
status = ctdbd_messaging_send(ctx->conn, pid.vnn, pid.pid, &msg);