From 8daa83a594a2e98f39d764422bfbdbc62c9efd44 Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Fri, 19 Apr 2024 19:20:00 +0200 Subject: Adding upstream version 2:4.20.0+dfsg. Signed-off-by: Daniel Baumann --- source3/include/messages.h | 128 +++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 128 insertions(+) create mode 100644 source3/include/messages.h (limited to 'source3/include/messages.h') diff --git a/source3/include/messages.h b/source3/include/messages.h new file mode 100644 index 0000000..23c90f7 --- /dev/null +++ b/source3/include/messages.h @@ -0,0 +1,128 @@ +/* + Unix SMB/CIFS implementation. + messages.c header + Copyright (C) Andrew Tridgell 2000 + Copyright (C) 2001, 2002 by Martin Pool + + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 3 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program. If not, see . +*/ + +#ifndef _MESSAGES_H_ +#define _MESSAGES_H_ + +#include "replace.h" +#include + +/* change the message version with any incompatible changes in the protocol */ +#define MESSAGE_VERSION 2 + +/* + * Special flags passed to message_send. Allocated from the top, lets see when + * it collides with the message types in the lower 16 bits :-) + */ + +/* + * Under high load, this message can be dropped. Use for notify-style + * messages that are not critical for correct operation. + */ +#define MSG_FLAG_LOWPRIORITY 0x80000000 + +#include "librpc/gen_ndr/server_id.h" +#include "lib/util/data_blob.h" +#include "system/network.h" + +#define MSG_BROADCAST_PID_STR "0:0" + +struct messaging_context; +struct messaging_rec; + +struct messaging_context *messaging_init(TALLOC_CTX *mem_ctx, + struct tevent_context *ev); + +struct server_id messaging_server_id(const struct messaging_context *msg_ctx); +struct tevent_context *messaging_tevent_context( + struct messaging_context *msg_ctx); +struct server_id_db *messaging_names_db(struct messaging_context *msg_ctx); + +/* + * re-init after a fork + */ +NTSTATUS messaging_reinit(struct messaging_context *msg_ctx); + +NTSTATUS messaging_register(struct messaging_context *msg_ctx, + void *private_data, + uint32_t msg_type, + void (*fn)(struct messaging_context *msg, + void *private_data, + uint32_t msg_type, + struct server_id server_id, + DATA_BLOB *data)); +void messaging_deregister(struct messaging_context *ctx, uint32_t msg_type, + void *private_data); + +/** + * CAVEAT: + * + * While the messaging_send*() functions are synchronous by API, + * they trigger a tevent-based loop upon sending bigger messages. + * + * Hence callers should not use these in purely synchronous code, + * but run a tevent_loop instead. + */ +NTSTATUS messaging_send(struct messaging_context *msg_ctx, + struct server_id server, + uint32_t msg_type, const DATA_BLOB *data); + +NTSTATUS messaging_send_buf(struct messaging_context *msg_ctx, + struct server_id server, uint32_t msg_type, + const uint8_t *buf, size_t len); +int messaging_send_iov_from(struct messaging_context *msg_ctx, + struct server_id src, struct server_id dst, + uint32_t msg_type, + const struct iovec *iov, int iovlen, + const int *fds, size_t num_fds); +NTSTATUS messaging_send_iov(struct messaging_context *msg_ctx, + struct server_id server, uint32_t msg_type, + const struct iovec *iov, int iovlen, + const int *fds, size_t num_fds); +void messaging_send_all(struct messaging_context *msg_ctx, + int msg_type, const void *buf, size_t len); + +struct tevent_req *messaging_filtered_read_send( + TALLOC_CTX *mem_ctx, struct tevent_context *ev, + struct messaging_context *msg_ctx, + bool (*filter)(struct messaging_rec *rec, void *private_data), + void *private_data); +int messaging_filtered_read_recv(struct tevent_req *req, TALLOC_CTX *mem_ctx, + struct messaging_rec **presult); + +struct tevent_req *messaging_read_send(TALLOC_CTX *mem_ctx, + struct tevent_context *ev, + struct messaging_context *msg, + uint32_t msg_type); +int messaging_read_recv(struct tevent_req *req, TALLOC_CTX *mem_ctx, + struct messaging_rec **presult); + +int messaging_cleanup(struct messaging_context *msg_ctx, pid_t pid); + +bool messaging_parent_dgm_cleanup_init(struct messaging_context *msg); + +struct messaging_rec *messaging_rec_create( + TALLOC_CTX *mem_ctx, struct server_id src, struct server_id dst, + uint32_t msg_type, const struct iovec *iov, int iovlen, + const int *fds, size_t num_fds); + +#include "librpc/gen_ndr/ndr_messaging.h" + +#endif -- cgit v1.2.3