1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
|
/*
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 <http://www.gnu.org/licenses/>.
*/
#ifndef _MESSAGES_H_
#define _MESSAGES_H_
/* change the message version with any incompatible changes in the protocol */
#define MESSAGE_VERSION 2
#define MSG_TYPE_MASK 0xFFFF
/* general messages */
#define MSG_DEBUG 0x0001
#define MSG_PING 0x0002
#define MSG_PONG 0x0003
#define MSG_PROFILE 0x0004
#define MSG_REQ_DEBUGLEVEL 0x0005
#define MSG_DEBUGLEVEL 0x0006
#define MSG_REQ_PROFILELEVEL 0x0007
#define MSG_PROFILELEVEL 0x0008
#define MSG_REQ_POOL_USAGE 0x0009
#define MSG_POOL_USAGE 0x000A
/* If dmalloc is included, set a steady-state mark */
#define MSG_REQ_DMALLOC_MARK 0x000B
/* If dmalloc is included, dump to the dmalloc log a description of
* what has changed since the last MARK */
#define MSG_REQ_DMALLOC_LOG_CHANGED 0x000C
#define MSG_SHUTDOWN 0x000D
/* nmbd messages */
#define MSG_FORCE_ELECTION 0x0101
#define MSG_WINS_NEW_ENTRY 0x0102
#define MSG_SEND_PACKET 0x0103
/* printing messages */
/* #define MSG_PRINTER_NOTIFY 2001*/ /* Obsolete */
#define MSG_PRINTER_NOTIFY2 0x0202
#define MSG_PRINTER_DRVUPGRADE 0x0203
#define MSG_PRINTERDATA_INIT_RESET 0x0204
#define MSG_PRINTER_UPDATE 0x0205
#define MSG_PRINTER_MOD 0x0206
/* smbd messages */
#define MSG_SMB_CONF_UPDATED 0x0301
#define MSG_SMB_FORCE_TDIS 0x0302
#define MSG_SMB_SAM_SYNC 0x0303
#define MSG_SMB_SAM_REPL 0x0304
#define MSG_SMB_UNLOCK 0x0305
#define MSG_SMB_BREAK_REQUEST 0x0306
#define MSG_SMB_BREAK_RESPONSE 0x0307
#define MSG_SMB_ASYNC_LEVEL2_BREAK 0x0308
#define MSG_SMB_OPEN_RETRY 0x0309
#define MSG_SMB_KERNEL_BREAK 0x030A
#define MSG_SMB_FILE_RENAME 0x030B
#define MSG_SMB_INJECT_FAULT 0x030C
#define MSG_SMB_BLOCKING_LOCK_CANCEL 0x030D
#define MSG_SMB_NOTIFY 0x030E
#define MSG_SMB_STAT_CACHE_DELETE 0x030F
/*
* Samba4 compatibility
*/
#define MSG_PVFS_NOTIFY 0x0310
/*
* cluster reconfigure events
*/
#define MSG_SMB_BRL_VALIDATE 0x0311
#define MSG_SMB_RELEASE_IP 0x0312
/* winbind messages */
#define MSG_WINBIND_FINISHED 0x0401
#define MSG_WINBIND_FORGET_STATE 0x0402
#define MSG_WINBIND_ONLINE 0x0403
#define MSG_WINBIND_OFFLINE 0x0404
#define MSG_WINBIND_ONLINESTATUS 0x0405
#define MSG_WINBIND_TRY_TO_GO_ONLINE 0x0406
#define MSG_WINBIND_FAILED_TO_GO_ONLINE 0x0407
#define MSG_WINBIND_VALIDATE_CACHE 0x0408
/* event messages */
#define MSG_DUMP_EVENT_LIST 0x0500
/*
* 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
/* Flags to classify messages - used in message_send_all() */
/* Sender will filter by flag. */
#define FLAG_MSG_GENERAL 0x0001
#define FLAG_MSG_SMBD 0x0002
#define FLAG_MSG_NMBD 0x0004
#define FLAG_MSG_PRINT_NOTIFY 0x0008
#define FLAG_MSG_PRINT_GENERAL 0x0010
/*
* Virtual Node Numbers are identifying a node within a cluster. Ctdbd sets
* this, we retrieve our vnn from it.
*/
#define NONCLUSTER_VNN (0xFFFFFFFF)
/*
* ctdb gives us 64-bit server ids for messaging_send. This is done to avoid
* pid clashes and to be able to register for special messages like "all
* smbds".
*
* Normal individual server id's have the upper 32 bits to 0, I picked "1" for
* Samba, other subsystems might use something else.
*/
#define MSG_SRVID_SAMBA 0x0000000100000000LL
struct server_id {
pid_t pid;
#ifdef CLUSTER_SUPPORT
uint32 vnn;
#endif
};
#ifdef CLUSTER_SUPPORT
#define MSG_BROADCAST_PID_STR "0:0"
#else
#define MSG_BROADCAST_PID_STR "0"
#endif
struct messaging_context;
struct messaging_rec;
struct data_blob;
/*
* struct messaging_context belongs to messages.c, but because we still have
* messaging_dispatch, we need it here. Once we get rid of signals for
* notifying processes, this will go.
*/
struct messaging_context {
struct server_id id;
struct event_context *event_ctx;
struct messaging_callback *callbacks;
struct messaging_backend *local;
struct messaging_backend *remote;
};
struct messaging_backend {
NTSTATUS (*send_fn)(struct messaging_context *msg_ctx,
struct server_id pid, int msg_type,
const struct data_blob *data,
struct messaging_backend *backend);
void *private_data;
};
NTSTATUS messaging_tdb_init(struct messaging_context *msg_ctx,
TALLOC_CTX *mem_ctx,
struct messaging_backend **presult);
void message_dispatch(struct messaging_context *msg_ctx);
NTSTATUS messaging_ctdbd_init(struct messaging_context *msg_ctx,
TALLOC_CTX *mem_ctx,
struct messaging_backend **presult);
struct ctdbd_connection *messaging_ctdbd_connection(void);
bool message_send_all(struct messaging_context *msg_ctx,
int msg_type,
const void *buf, size_t len,
int *n_sent);
struct event_context *messaging_event_context(struct messaging_context *msg_ctx);
struct messaging_context *messaging_init(TALLOC_CTX *mem_ctx,
struct server_id server_id,
struct event_context *ev);
/*
* 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,
struct data_blob *data));
void messaging_deregister(struct messaging_context *ctx, uint32_t msg_type,
void *private_data);
NTSTATUS messaging_send(struct messaging_context *msg_ctx,
struct server_id server,
uint32_t msg_type, const struct data_blob *data);
NTSTATUS messaging_send_buf(struct messaging_context *msg_ctx,
struct server_id server, uint32_t msg_type,
const uint8 *buf, size_t len);
void messaging_dispatch_rec(struct messaging_context *msg_ctx,
struct messaging_rec *rec);
#endif
|
