File: | xlators/mgmt/glusterd/src/glusterd-sm.c |
Location: | line 576, column 9 |
Description: | Value stored to 'ret' is never read |
1 | /* |
2 | Copyright (c) 2006-2012 Red Hat, Inc. <http://www.redhat.com> |
3 | This file is part of GlusterFS. |
4 | |
5 | This file is licensed to you under your choice of the GNU Lesser |
6 | General Public License, version 3 or any later version (LGPLv3 or |
7 | later), or the GNU General Public License, version 2 (GPLv2), in all |
8 | cases as published by the Free Software Foundation. |
9 | */ |
10 | |
11 | #ifndef _CONFIG_H |
12 | #define _CONFIG_H |
13 | #include "config.h" |
14 | #endif |
15 | #include <time.h> |
16 | #include <sys/uio.h> |
17 | #include <sys/resource.h> |
18 | |
19 | #include <libgen.h> |
20 | #include "uuid.h" |
21 | |
22 | #include "fnmatch.h" |
23 | #include "xlator.h" |
24 | #include "protocol-common.h" |
25 | #include "glusterd.h" |
26 | #include "call-stub.h" |
27 | #include "defaults.h" |
28 | #include "list.h" |
29 | #include "dict.h" |
30 | #include "compat.h" |
31 | #include "compat-errno.h" |
32 | #include "statedump.h" |
33 | #include "glusterd-sm.h" |
34 | #include "glusterd-op-sm.h" |
35 | #include "glusterd-utils.h" |
36 | #include "glusterd-store.h" |
37 | |
38 | static struct list_head gd_friend_sm_queue; |
39 | |
40 | static char *glusterd_friend_sm_state_names[] = { |
41 | "Establishing Connection", |
42 | "Probe Sent to Peer", |
43 | "Probe Received from Peer", |
44 | "Peer in Cluster", |
45 | "Accepted peer request", |
46 | "Sent and Received peer request", |
47 | "Peer Rejected", |
48 | "Peer detach in progress", |
49 | "Probe Received from peer", |
50 | "Connected to Peer", |
51 | "Peer is connected and Accepted", |
52 | "Invalid State" |
53 | }; |
54 | |
55 | static char *glusterd_friend_sm_event_names[] = { |
56 | "GD_FRIEND_EVENT_NONE", |
57 | "GD_FRIEND_EVENT_PROBE", |
58 | "GD_FRIEND_EVENT_INIT_FRIEND_REQ", |
59 | "GD_FRIEND_EVENT_RCVD_ACC", |
60 | "GD_FRIEND_EVENT_LOCAL_ACC", |
61 | "GD_FRIEND_EVENT_RCVD_RJT", |
62 | "GD_FRIEND_EVENT_LOCAL_RJT", |
63 | "GD_FRIEND_EVENT_RCVD_FRIEND_REQ", |
64 | "GD_FRIEND_EVENT_INIT_REMOVE_FRIEND", |
65 | "GD_FRIEND_EVENT_RCVD_REMOVE_FRIEND", |
66 | "GD_FRIEND_EVENT_REMOVE_FRIEND", |
67 | "GD_FRIEND_EVENT_CONNECTED", |
68 | "GD_FRIEND_EVENT_MAX" |
69 | }; |
70 | |
71 | char* |
72 | glusterd_friend_sm_state_name_get (int state) |
73 | { |
74 | if (state < 0 || state >= GD_FRIEND_STATE_MAX) |
75 | return glusterd_friend_sm_state_names[GD_FRIEND_STATE_MAX]; |
76 | return glusterd_friend_sm_state_names[state]; |
77 | } |
78 | |
79 | char* |
80 | glusterd_friend_sm_event_name_get (int event) |
81 | { |
82 | if (event < 0 || event >= GD_FRIEND_EVENT_MAX) |
83 | return glusterd_friend_sm_event_names[GD_FRIEND_EVENT_MAX]; |
84 | return glusterd_friend_sm_event_names[event]; |
85 | } |
86 | |
87 | void |
88 | glusterd_destroy_probe_ctx (glusterd_probe_ctx_t *ctx) |
89 | { |
90 | if (!ctx) |
91 | return; |
92 | |
93 | GF_FREE (ctx->hostname)__gf_free (ctx->hostname); |
94 | GF_FREE (ctx)__gf_free (ctx); |
95 | } |
96 | |
97 | void |
98 | glusterd_destroy_friend_req_ctx (glusterd_friend_req_ctx_t *ctx) |
99 | { |
100 | if (!ctx) |
101 | return; |
102 | |
103 | if (ctx->vols) |
104 | dict_unref (ctx->vols); |
105 | GF_FREE (ctx->hostname)__gf_free (ctx->hostname); |
106 | GF_FREE (ctx)__gf_free (ctx); |
107 | } |
108 | |
109 | void |
110 | glusterd_destroy_friend_update_ctx (glusterd_friend_update_ctx_t *ctx) |
111 | { |
112 | if (!ctx) |
113 | return; |
114 | GF_FREE (ctx->hostname)__gf_free (ctx->hostname); |
115 | GF_FREE (ctx)__gf_free (ctx); |
116 | } |
117 | |
118 | int |
119 | glusterd_broadcast_friend_delete (char *hostname, uuid_t uuid) |
120 | { |
121 | int ret = 0; |
122 | rpc_clnt_procedure_t *proc = NULL((void*)0); |
123 | xlator_t *this = NULL((void*)0); |
124 | glusterd_friend_update_ctx_t ctx = {{0},}; |
125 | glusterd_peerinfo_t *peerinfo = NULL((void*)0); |
126 | glusterd_conf_t *priv = NULL((void*)0); |
127 | dict_t *friends = NULL((void*)0); |
128 | char key[100] = {0,}; |
129 | int32_t count = 0; |
130 | |
131 | this = THIS(*__glusterfs_this_location()); |
132 | priv = this->private; |
133 | |
134 | GF_ASSERT (priv)do { if (!(priv)) { do { do { if (0) printf ("Assertion failed: " "priv"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 134, GF_LOG_ERROR, "Assertion failed: " "priv" ); } while (0); } } while (0); |
135 | |
136 | ctx.hostname = hostname; |
137 | ctx.op = GD_FRIEND_UPDATE_DEL; |
138 | |
139 | friends = dict_new (); |
140 | if (!friends) |
141 | goto out; |
142 | |
143 | snprintf (key, sizeof (key), "op"); |
144 | ret = dict_set_int32 (friends, key, ctx.op); |
145 | if (ret) |
146 | goto out; |
147 | |
148 | snprintf (key, sizeof (key), "hostname"); |
149 | ret = dict_set_str (friends, key, hostname); |
150 | if (ret) |
151 | goto out; |
152 | |
153 | ret = dict_set_int32 (friends, "count", count); |
154 | if (ret) |
155 | goto out; |
156 | |
157 | list_for_each_entry (peerinfo, &priv->peers, uuid_list)for (peerinfo = ((typeof(*peerinfo) *)((char *)((&priv-> peers)->next)-(unsigned long)(&((typeof(*peerinfo) *)0 )->uuid_list))); &peerinfo->uuid_list != (&priv ->peers); peerinfo = ((typeof(*peerinfo) *)((char *)(peerinfo ->uuid_list.next)-(unsigned long)(&((typeof(*peerinfo) *)0)->uuid_list)))) { |
158 | if (!peerinfo->connected || !peerinfo->peer) |
159 | continue; |
160 | |
161 | ret = dict_set_static_ptr (friends, "peerinfo", peerinfo); |
162 | if (ret) { |
163 | gf_log ("", GF_LOG_ERROR, "failed to set peerinfo")do { do { if (0) printf ("failed to set peerinfo"); } while ( 0); _gf_log ("", "glusterd-sm.c", __FUNCTION__, 163, GF_LOG_ERROR , "failed to set peerinfo"); } while (0); |
164 | goto out; |
165 | } |
166 | |
167 | proc = &peerinfo->peer->proctable[GLUSTERD_FRIEND_UPDATE]; |
168 | if (proc->fn) { |
169 | ret = proc->fn (NULL((void*)0), this, friends); |
170 | } |
171 | } |
172 | |
173 | gf_log ("", GF_LOG_DEBUG, "Returning with %d", ret)do { do { if (0) printf ("Returning with %d", ret); } while ( 0); _gf_log ("", "glusterd-sm.c", __FUNCTION__, 173, GF_LOG_DEBUG , "Returning with %d", ret); } while (0); |
174 | |
175 | out: |
176 | if (friends) |
177 | dict_unref (friends); |
178 | |
179 | return ret; |
180 | } |
181 | |
182 | |
183 | static int |
184 | glusterd_ac_none (glusterd_friend_sm_event_t *event, void *ctx) |
185 | { |
186 | int ret = 0; |
187 | |
188 | gf_log ("", GF_LOG_DEBUG, "Returning with %d", ret)do { do { if (0) printf ("Returning with %d", ret); } while ( 0); _gf_log ("", "glusterd-sm.c", __FUNCTION__, 188, GF_LOG_DEBUG , "Returning with %d", ret); } while (0); |
189 | |
190 | return ret; |
191 | } |
192 | |
193 | static int |
194 | glusterd_ac_error (glusterd_friend_sm_event_t *event, void *ctx) |
195 | { |
196 | int ret = 0; |
197 | |
198 | gf_log ("", GF_LOG_ERROR, "Received event %d ", event->event)do { do { if (0) printf ("Received event %d ", event->event ); } while (0); _gf_log ("", "glusterd-sm.c", __FUNCTION__, 198 , GF_LOG_ERROR, "Received event %d ", event->event); } while (0); |
199 | |
200 | return ret; |
201 | } |
202 | |
203 | static int |
204 | glusterd_ac_reverse_probe_begin (glusterd_friend_sm_event_t *event, void *ctx) |
205 | { |
206 | int ret = 0; |
207 | glusterd_peerinfo_t *peerinfo = NULL((void*)0); |
208 | glusterd_friend_sm_event_t *new_event = NULL((void*)0); |
209 | glusterd_probe_ctx_t *new_ev_ctx = NULL((void*)0); |
210 | |
211 | GF_ASSERT (event)do { if (!(event)) { do { do { if (0) printf ("Assertion failed: " "event"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 211, GF_LOG_ERROR, "Assertion failed: " "event" ); } while (0); } } while (0); |
212 | GF_ASSERT (ctx)do { if (!(ctx)) { do { do { if (0) printf ("Assertion failed: " "ctx"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c", __FUNCTION__, 212, GF_LOG_ERROR, "Assertion failed: " "ctx") ; } while (0); } } while (0); |
213 | |
214 | peerinfo = event->peerinfo; |
215 | ret = glusterd_friend_sm_new_event |
216 | (GD_FRIEND_EVENT_PROBE, &new_event); |
217 | |
218 | if (ret) { |
219 | gf_log ("glusterd", GF_LOG_ERROR, "Unable to get new new_event")do { do { if (0) printf ("Unable to get new new_event"); } while (0); _gf_log ("glusterd", "glusterd-sm.c", __FUNCTION__, 219 , GF_LOG_ERROR, "Unable to get new new_event"); } while (0); |
220 | ret = -1; |
221 | goto out; |
222 | } |
223 | |
224 | new_ev_ctx = GF_CALLOC (1, sizeof(*new_ev_ctx), gf_gld_mt_probe_ctx_t)__gf_calloc (1, sizeof(*new_ev_ctx), gf_gld_mt_probe_ctx_t); |
225 | |
226 | if (!new_ev_ctx) { |
227 | ret = -1; |
228 | goto out; |
229 | } |
230 | |
231 | new_ev_ctx->hostname = gf_strdup (peerinfo->hostname); |
232 | new_ev_ctx->port = peerinfo->port; |
233 | new_ev_ctx->req = NULL((void*)0); |
234 | |
235 | new_event->peerinfo = peerinfo; |
236 | new_event->ctx = new_ev_ctx; |
237 | |
238 | ret = glusterd_friend_sm_inject_event (new_event); |
239 | |
240 | if (ret) { |
241 | gf_log ("glusterd", GF_LOG_ERROR, "Unable to inject new_event %d, "do { do { if (0) printf ("Unable to inject new_event %d, " "ret = %d" , new_event->event, ret); } while (0); _gf_log ("glusterd" , "glusterd-sm.c", __FUNCTION__, 242, GF_LOG_ERROR, "Unable to inject new_event %d, " "ret = %d", new_event->event, ret); } while (0) |
242 | "ret = %d", new_event->event, ret)do { do { if (0) printf ("Unable to inject new_event %d, " "ret = %d" , new_event->event, ret); } while (0); _gf_log ("glusterd" , "glusterd-sm.c", __FUNCTION__, 242, GF_LOG_ERROR, "Unable to inject new_event %d, " "ret = %d", new_event->event, ret); } while (0); |
243 | } |
244 | |
245 | out: |
246 | if (ret) { |
247 | GF_FREE (new_event)__gf_free (new_event); |
248 | GF_FREE (new_ev_ctx->hostname)__gf_free (new_ev_ctx->hostname); |
249 | GF_FREE (new_ev_ctx)__gf_free (new_ev_ctx); |
250 | } |
251 | gf_log ("", GF_LOG_DEBUG, "returning with %d", ret)do { do { if (0) printf ("returning with %d", ret); } while ( 0); _gf_log ("", "glusterd-sm.c", __FUNCTION__, 251, GF_LOG_DEBUG , "returning with %d", ret); } while (0); |
252 | return ret; |
253 | } |
254 | |
255 | static int |
256 | glusterd_ac_friend_add (glusterd_friend_sm_event_t *event, void *ctx) |
257 | { |
258 | int ret = 0; |
259 | glusterd_peerinfo_t *peerinfo = NULL((void*)0); |
260 | rpc_clnt_procedure_t *proc = NULL((void*)0); |
261 | call_frame_t *frame = NULL((void*)0); |
262 | glusterd_conf_t *conf = NULL((void*)0); |
263 | xlator_t *this = NULL((void*)0); |
264 | |
265 | GF_ASSERT (event)do { if (!(event)) { do { do { if (0) printf ("Assertion failed: " "event"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 265, GF_LOG_ERROR, "Assertion failed: " "event" ); } while (0); } } while (0); |
266 | peerinfo = event->peerinfo; |
267 | |
268 | this = THIS(*__glusterfs_this_location()); |
269 | conf = this->private; |
270 | |
271 | GF_ASSERT (conf)do { if (!(conf)) { do { do { if (0) printf ("Assertion failed: " "conf"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 271, GF_LOG_ERROR, "Assertion failed: " "conf" ); } while (0); } } while (0); |
272 | |
273 | if (!peerinfo->peer) |
274 | goto out; |
275 | proc = &peerinfo->peer->proctable[GLUSTERD_FRIEND_ADD]; |
276 | if (proc->fn) { |
277 | frame = create_frame (this, this->ctx->pool); |
278 | if (!frame) { |
279 | goto out; |
280 | } |
281 | frame->local = ctx; |
282 | ret = proc->fn (frame, this, event); |
283 | } |
284 | |
285 | out: |
286 | gf_log ("", GF_LOG_DEBUG, "Returning with %d", ret)do { do { if (0) printf ("Returning with %d", ret); } while ( 0); _gf_log ("", "glusterd-sm.c", __FUNCTION__, 286, GF_LOG_DEBUG , "Returning with %d", ret); } while (0); |
287 | |
288 | return ret; |
289 | } |
290 | |
291 | static int |
292 | glusterd_ac_friend_probe (glusterd_friend_sm_event_t *event, void *ctx) |
293 | { |
294 | int ret = -1; |
295 | rpc_clnt_procedure_t *proc = NULL((void*)0); |
296 | call_frame_t *frame = NULL((void*)0); |
297 | glusterd_conf_t *conf = NULL((void*)0); |
298 | xlator_t *this = NULL((void*)0); |
299 | glusterd_probe_ctx_t *probe_ctx = NULL((void*)0); |
300 | glusterd_peerinfo_t *peerinfo = NULL((void*)0); |
301 | dict_t *dict = NULL((void*)0); |
302 | |
303 | GF_ASSERT (ctx)do { if (!(ctx)) { do { do { if (0) printf ("Assertion failed: " "ctx"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c", __FUNCTION__, 303, GF_LOG_ERROR, "Assertion failed: " "ctx") ; } while (0); } } while (0); |
304 | |
305 | probe_ctx = ctx; |
306 | |
307 | this = THIS(*__glusterfs_this_location()); |
308 | |
309 | GF_ASSERT (this)do { if (!(this)) { do { do { if (0) printf ("Assertion failed: " "this"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 309, GF_LOG_ERROR, "Assertion failed: " "this" ); } while (0); } } while (0); |
310 | |
311 | conf = this->private; |
312 | |
313 | GF_ASSERT (conf)do { if (!(conf)) { do { do { if (0) printf ("Assertion failed: " "conf"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 313, GF_LOG_ERROR, "Assertion failed: " "conf" ); } while (0); } } while (0); |
314 | |
315 | ret = glusterd_friend_find (NULL((void*)0), probe_ctx->hostname, &peerinfo); |
316 | if (ret) { |
317 | //We should not reach this state ideally |
318 | GF_ASSERT (0)do { if (!(0)) { do { do { if (0) printf ("Assertion failed: " "0"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c", __FUNCTION__ , 318, GF_LOG_ERROR, "Assertion failed: " "0"); } while (0); } } while (0); |
319 | goto out; |
320 | } |
321 | |
322 | if (!peerinfo->peer) |
323 | goto out; |
324 | proc = &peerinfo->peer->proctable[GLUSTERD_PROBE_QUERY]; |
325 | if (proc->fn) { |
326 | frame = create_frame (this, this->ctx->pool); |
327 | if (!frame) { |
328 | goto out; |
329 | } |
330 | frame->local = ctx; |
331 | dict = dict_new (); |
332 | if (!dict) |
333 | goto out; |
334 | ret = dict_set_str (dict, "hostname", probe_ctx->hostname); |
335 | if (ret) |
336 | goto out; |
337 | |
338 | ret = dict_set_int32 (dict, "port", probe_ctx->port); |
339 | if (ret) |
340 | goto out; |
341 | |
342 | ret = dict_set_static_ptr (dict, "peerinfo", peerinfo); |
343 | if (ret) { |
344 | gf_log ("", GF_LOG_ERROR, "failed to set peerinfo")do { do { if (0) printf ("failed to set peerinfo"); } while ( 0); _gf_log ("", "glusterd-sm.c", __FUNCTION__, 344, GF_LOG_ERROR , "failed to set peerinfo"); } while (0); |
345 | goto out; |
346 | } |
347 | |
348 | ret = proc->fn (frame, this, dict); |
349 | if (ret) |
350 | goto out; |
351 | |
352 | } |
353 | |
354 | |
355 | out: |
356 | if (dict) |
357 | dict_unref (dict); |
358 | gf_log ("", GF_LOG_DEBUG, "Returning with %d", ret)do { do { if (0) printf ("Returning with %d", ret); } while ( 0); _gf_log ("", "glusterd-sm.c", __FUNCTION__, 358, GF_LOG_DEBUG , "Returning with %d", ret); } while (0); |
359 | |
360 | return ret; |
361 | } |
362 | |
363 | static int |
364 | glusterd_ac_send_friend_remove_req (glusterd_friend_sm_event_t *event, |
365 | void *data) |
366 | { |
367 | int ret = 0; |
368 | glusterd_peerinfo_t *peerinfo = NULL((void*)0); |
369 | rpc_clnt_procedure_t *proc = NULL((void*)0); |
370 | call_frame_t *frame = NULL((void*)0); |
371 | glusterd_conf_t *conf = NULL((void*)0); |
372 | xlator_t *this = NULL((void*)0); |
373 | glusterd_friend_sm_event_type_t event_type = GD_FRIEND_EVENT_NONE; |
374 | glusterd_probe_ctx_t *ctx = NULL((void*)0); |
375 | glusterd_friend_sm_event_t *new_event = NULL((void*)0); |
376 | |
377 | GF_ASSERT (event)do { if (!(event)) { do { do { if (0) printf ("Assertion failed: " "event"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 377, GF_LOG_ERROR, "Assertion failed: " "event" ); } while (0); } } while (0); |
378 | peerinfo = event->peerinfo; |
379 | |
380 | this = THIS(*__glusterfs_this_location()); |
381 | conf = this->private; |
382 | |
383 | GF_ASSERT (conf)do { if (!(conf)) { do { do { if (0) printf ("Assertion failed: " "conf"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 383, GF_LOG_ERROR, "Assertion failed: " "conf" ); } while (0); } } while (0); |
384 | |
385 | ctx = event->ctx; |
386 | |
387 | if (!peerinfo->connected) { |
388 | event_type = GD_FRIEND_EVENT_REMOVE_FRIEND; |
389 | |
390 | ret = glusterd_friend_sm_new_event (event_type, &new_event); |
391 | |
392 | if (!ret) { |
393 | new_event->peerinfo = peerinfo; |
394 | ret = glusterd_friend_sm_inject_event (new_event); |
395 | } else { |
396 | gf_log ("glusterd", GF_LOG_ERROR,do { do { if (0) printf ("Unable to get event"); } while (0); _gf_log ("glusterd", "glusterd-sm.c", __FUNCTION__, 397, GF_LOG_ERROR , "Unable to get event"); } while (0) |
397 | "Unable to get event")do { do { if (0) printf ("Unable to get event"); } while (0); _gf_log ("glusterd", "glusterd-sm.c", __FUNCTION__, 397, GF_LOG_ERROR , "Unable to get event"); } while (0); |
398 | } |
399 | |
400 | if (ctx) |
401 | ret = glusterd_xfer_cli_deprobe_resp (ctx->req, ret, 0, |
402 | NULL((void*)0), |
403 | ctx->hostname); |
404 | glusterd_friend_sm (); |
405 | glusterd_op_sm (); |
406 | |
407 | if (ctx) { |
408 | glusterd_broadcast_friend_delete (ctx->hostname, NULL((void*)0)); |
409 | glusterd_destroy_probe_ctx (ctx); |
410 | } |
411 | goto out; |
412 | } |
413 | |
414 | if (!peerinfo->peer) |
415 | goto out; |
416 | proc = &peerinfo->peer->proctable[GLUSTERD_FRIEND_REMOVE]; |
417 | if (proc->fn) { |
418 | frame = create_frame (this, this->ctx->pool); |
419 | if (!frame) { |
420 | goto out; |
421 | } |
422 | frame->local = data; |
423 | ret = proc->fn (frame, this, event); |
424 | } |
425 | |
426 | out: |
427 | gf_log ("", GF_LOG_DEBUG, "Returning with %d", ret)do { do { if (0) printf ("Returning with %d", ret); } while ( 0); _gf_log ("", "glusterd-sm.c", __FUNCTION__, 427, GF_LOG_DEBUG , "Returning with %d", ret); } while (0); |
428 | |
429 | return ret; |
430 | } |
431 | |
432 | static gf_boolean_t |
433 | glusterd_should_update_peer (glusterd_peerinfo_t *peerinfo, |
434 | glusterd_peerinfo_t *cur_peerinfo) |
435 | { |
436 | gf_boolean_t is_valid = _gf_false; |
437 | |
438 | if ((peerinfo == cur_peerinfo) || |
439 | (peerinfo->state.state == GD_FRIEND_STATE_BEFRIENDED)) |
440 | is_valid = _gf_true; |
441 | |
442 | return is_valid; |
443 | } |
444 | |
445 | static int |
446 | glusterd_ac_send_friend_update (glusterd_friend_sm_event_t *event, void *ctx) |
447 | { |
448 | int ret = 0; |
449 | glusterd_peerinfo_t *cur_peerinfo = NULL((void*)0); |
450 | glusterd_peerinfo_t *peerinfo = NULL((void*)0); |
451 | rpc_clnt_procedure_t *proc = NULL((void*)0); |
452 | xlator_t *this = NULL((void*)0); |
453 | glusterd_friend_update_ctx_t ev_ctx = {{0}}; |
454 | glusterd_conf_t *priv = NULL((void*)0); |
455 | dict_t *friends = NULL((void*)0); |
456 | char key[100] = {0,}; |
457 | char *dup_buf = NULL((void*)0); |
458 | int32_t count = 0; |
459 | |
460 | GF_ASSERT (event)do { if (!(event)) { do { do { if (0) printf ("Assertion failed: " "event"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 460, GF_LOG_ERROR, "Assertion failed: " "event" ); } while (0); } } while (0); |
461 | cur_peerinfo = event->peerinfo; |
462 | |
463 | this = THIS(*__glusterfs_this_location()); |
464 | priv = this->private; |
465 | |
466 | GF_ASSERT (priv)do { if (!(priv)) { do { do { if (0) printf ("Assertion failed: " "priv"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 466, GF_LOG_ERROR, "Assertion failed: " "priv" ); } while (0); } } while (0); |
467 | |
468 | ev_ctx.op = GD_FRIEND_UPDATE_ADD; |
469 | |
470 | friends = dict_new (); |
471 | if (!friends) |
472 | goto out; |
473 | |
474 | snprintf (key, sizeof (key), "op"); |
475 | ret = dict_set_int32 (friends, key, ev_ctx.op); |
476 | if (ret) |
477 | goto out; |
478 | |
479 | list_for_each_entry (peerinfo, &priv->peers, uuid_list)for (peerinfo = ((typeof(*peerinfo) *)((char *)((&priv-> peers)->next)-(unsigned long)(&((typeof(*peerinfo) *)0 )->uuid_list))); &peerinfo->uuid_list != (&priv ->peers); peerinfo = ((typeof(*peerinfo) *)((char *)(peerinfo ->uuid_list.next)-(unsigned long)(&((typeof(*peerinfo) *)0)->uuid_list)))) { |
480 | if (!glusterd_should_update_peer (peerinfo, cur_peerinfo)) |
481 | continue; |
482 | |
483 | count++; |
484 | snprintf (key, sizeof (key), "friend%d.uuid", count); |
485 | dup_buf = gf_strdup (uuid_utoa (peerinfo->uuid)); |
486 | ret = dict_set_dynstr (friends, key, dup_buf); |
487 | if (ret) |
488 | goto out; |
489 | snprintf (key, sizeof (key), "friend%d.hostname", count); |
490 | ret = dict_set_str (friends, key, peerinfo->hostname); |
491 | if (ret) |
492 | goto out; |
493 | gf_log ("", GF_LOG_INFO, "Added uuid: %s, host: %s",do { do { if (0) printf ("Added uuid: %s, host: %s", dup_buf, peerinfo->hostname); } while (0); _gf_log ("", "glusterd-sm.c" , __FUNCTION__, 494, GF_LOG_INFO, "Added uuid: %s, host: %s", dup_buf, peerinfo->hostname); } while (0) |
494 | dup_buf, peerinfo->hostname)do { do { if (0) printf ("Added uuid: %s, host: %s", dup_buf, peerinfo->hostname); } while (0); _gf_log ("", "glusterd-sm.c" , __FUNCTION__, 494, GF_LOG_INFO, "Added uuid: %s, host: %s", dup_buf, peerinfo->hostname); } while (0); |
495 | } |
496 | |
497 | ret = dict_set_int32 (friends, "count", count); |
498 | if (ret) |
499 | goto out; |
500 | |
501 | list_for_each_entry (peerinfo, &priv->peers, uuid_list)for (peerinfo = ((typeof(*peerinfo) *)((char *)((&priv-> peers)->next)-(unsigned long)(&((typeof(*peerinfo) *)0 )->uuid_list))); &peerinfo->uuid_list != (&priv ->peers); peerinfo = ((typeof(*peerinfo) *)((char *)(peerinfo ->uuid_list.next)-(unsigned long)(&((typeof(*peerinfo) *)0)->uuid_list)))) { |
502 | if (!peerinfo->connected || !peerinfo->peer) |
503 | continue; |
504 | |
505 | if (!glusterd_should_update_peer (peerinfo, cur_peerinfo)) |
506 | continue; |
507 | |
508 | ret = dict_set_static_ptr (friends, "peerinfo", peerinfo); |
509 | if (ret) { |
510 | gf_log ("", GF_LOG_ERROR, "failed to set peerinfo")do { do { if (0) printf ("failed to set peerinfo"); } while ( 0); _gf_log ("", "glusterd-sm.c", __FUNCTION__, 510, GF_LOG_ERROR , "failed to set peerinfo"); } while (0); |
511 | goto out; |
512 | } |
513 | |
514 | proc = &peerinfo->peer->proctable[GLUSTERD_FRIEND_UPDATE]; |
515 | if (proc->fn) { |
516 | ret = proc->fn (NULL((void*)0), this, friends); |
517 | } |
518 | } |
519 | |
520 | gf_log ("", GF_LOG_DEBUG, "Returning with %d", ret)do { do { if (0) printf ("Returning with %d", ret); } while ( 0); _gf_log ("", "glusterd-sm.c", __FUNCTION__, 520, GF_LOG_DEBUG , "Returning with %d", ret); } while (0); |
521 | |
522 | out: |
523 | if (friends) |
524 | dict_unref (friends); |
525 | |
526 | return ret; |
527 | } |
528 | |
529 | static int |
530 | glusterd_peer_detach_cleanup (glusterd_conf_t *priv) |
531 | { |
532 | int ret = -1; |
533 | glusterd_volinfo_t *volinfo = NULL((void*)0); |
534 | glusterd_volinfo_t *tmp_volinfo = NULL((void*)0); |
535 | |
536 | GF_ASSERT (priv)do { if (!(priv)) { do { do { if (0) printf ("Assertion failed: " "priv"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 536, GF_LOG_ERROR, "Assertion failed: " "priv" ); } while (0); } } while (0); |
537 | |
538 | list_for_each_entry_safe (volinfo,tmp_volinfo,for (volinfo = ((typeof(*volinfo) *)((char *)((&priv-> volumes)->next)-(unsigned long)(&((typeof(*volinfo) *) 0)->vol_list))), tmp_volinfo = ((typeof(*volinfo) *)((char *)(volinfo->vol_list.next)-(unsigned long)(&((typeof( *volinfo) *)0)->vol_list))); &volinfo->vol_list != ( &priv->volumes); volinfo = tmp_volinfo, tmp_volinfo = ( (typeof(*tmp_volinfo) *)((char *)(tmp_volinfo->vol_list.next )-(unsigned long)(&((typeof(*tmp_volinfo) *)0)->vol_list )))) |
539 | &priv->volumes, vol_list)for (volinfo = ((typeof(*volinfo) *)((char *)((&priv-> volumes)->next)-(unsigned long)(&((typeof(*volinfo) *) 0)->vol_list))), tmp_volinfo = ((typeof(*volinfo) *)((char *)(volinfo->vol_list.next)-(unsigned long)(&((typeof( *volinfo) *)0)->vol_list))); &volinfo->vol_list != ( &priv->volumes); volinfo = tmp_volinfo, tmp_volinfo = ( (typeof(*tmp_volinfo) *)((char *)(tmp_volinfo->vol_list.next )-(unsigned long)(&((typeof(*tmp_volinfo) *)0)->vol_list )))) { |
540 | if (!glusterd_friend_contains_vol_bricks (volinfo, |
541 | MY_UUID(__glusterd_uuid()))) { |
542 | gf_log (THIS->name, GF_LOG_INFO,do { do { if (0) printf ("Deleting stale volume %s", volinfo-> volname); } while (0); _gf_log ((*__glusterfs_this_location() )->name, "glusterd-sm.c", __FUNCTION__, 543, GF_LOG_INFO, "Deleting stale volume %s" , volinfo->volname); } while (0) |
543 | "Deleting stale volume %s", volinfo->volname)do { do { if (0) printf ("Deleting stale volume %s", volinfo-> volname); } while (0); _gf_log ((*__glusterfs_this_location() )->name, "glusterd-sm.c", __FUNCTION__, 543, GF_LOG_INFO, "Deleting stale volume %s" , volinfo->volname); } while (0); |
544 | ret = glusterd_delete_volume (volinfo); |
545 | if (ret) { |
546 | gf_log (THIS->name, GF_LOG_ERROR,do { do { if (0) printf ("Error deleting stale volume"); } while (0); _gf_log ((*__glusterfs_this_location())->name, "glusterd-sm.c" , __FUNCTION__, 547, GF_LOG_ERROR, "Error deleting stale volume" ); } while (0) |
547 | "Error deleting stale volume")do { do { if (0) printf ("Error deleting stale volume"); } while (0); _gf_log ((*__glusterfs_this_location())->name, "glusterd-sm.c" , __FUNCTION__, 547, GF_LOG_ERROR, "Error deleting stale volume" ); } while (0); |
548 | goto out; |
549 | } |
550 | } |
551 | } |
552 | ret = 0; |
553 | out: |
554 | gf_log (THIS->name, GF_LOG_DEBUG, "Returning %d", ret)do { do { if (0) printf ("Returning %d", ret); } while (0); _gf_log ((*__glusterfs_this_location())->name, "glusterd-sm.c", __FUNCTION__ , 554, GF_LOG_DEBUG, "Returning %d", ret); } while (0); |
555 | return ret; |
556 | } |
557 | |
558 | static int |
559 | glusterd_ac_handle_friend_remove_req (glusterd_friend_sm_event_t *event, |
560 | void *ctx) |
561 | { |
562 | int ret = 0; |
563 | glusterd_peerinfo_t *peerinfo = NULL((void*)0); |
564 | glusterd_friend_req_ctx_t *ev_ctx = NULL((void*)0); |
565 | glusterd_friend_sm_event_t *new_event = NULL((void*)0); |
566 | glusterd_conf_t *priv = NULL((void*)0); |
567 | |
568 | GF_ASSERT (ctx)do { if (!(ctx)) { do { do { if (0) printf ("Assertion failed: " "ctx"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c", __FUNCTION__, 568, GF_LOG_ERROR, "Assertion failed: " "ctx") ; } while (0); } } while (0); |
569 | ev_ctx = ctx; |
570 | peerinfo = event->peerinfo; |
571 | GF_ASSERT (peerinfo)do { if (!(peerinfo)) { do { do { if (0) printf ("Assertion failed: " "peerinfo"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 571, GF_LOG_ERROR, "Assertion failed: " "peerinfo" ); } while (0); } } while (0); |
572 | |
573 | priv = THIS(*__glusterfs_this_location())->private; |
574 | GF_ASSERT (priv)do { if (!(priv)) { do { do { if (0) printf ("Assertion failed: " "priv"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 574, GF_LOG_ERROR, "Assertion failed: " "priv" ); } while (0); } } while (0); |
575 | |
576 | ret = glusterd_xfer_friend_remove_resp (ev_ctx->req, ev_ctx->hostname, |
Value stored to 'ret' is never read | |
577 | ev_ctx->port); |
578 | |
579 | list_for_each_entry (peerinfo, &priv->peers, uuid_list)for (peerinfo = ((typeof(*peerinfo) *)((char *)((&priv-> peers)->next)-(unsigned long)(&((typeof(*peerinfo) *)0 )->uuid_list))); &peerinfo->uuid_list != (&priv ->peers); peerinfo = ((typeof(*peerinfo) *)((char *)(peerinfo ->uuid_list.next)-(unsigned long)(&((typeof(*peerinfo) *)0)->uuid_list)))) { |
580 | |
581 | ret = glusterd_friend_sm_new_event (GD_FRIEND_EVENT_REMOVE_FRIEND, |
582 | &new_event); |
583 | if (ret) |
584 | goto out; |
585 | |
586 | new_event->peerinfo = peerinfo; |
587 | |
588 | ret = glusterd_friend_sm_inject_event (new_event); |
589 | if (ret) |
590 | goto out; |
591 | } |
592 | ret = glusterd_peer_detach_cleanup (priv); |
593 | if (ret) { |
594 | gf_log (THIS->name, GF_LOG_WARNING,do { do { if (0) printf ("Peer detach cleanup was not successful" ); } while (0); _gf_log ((*__glusterfs_this_location())->name , "glusterd-sm.c", __FUNCTION__, 595, GF_LOG_WARNING, "Peer detach cleanup was not successful" ); } while (0) |
595 | "Peer detach cleanup was not successful")do { do { if (0) printf ("Peer detach cleanup was not successful" ); } while (0); _gf_log ((*__glusterfs_this_location())->name , "glusterd-sm.c", __FUNCTION__, 595, GF_LOG_WARNING, "Peer detach cleanup was not successful" ); } while (0); |
596 | ret = 0; |
597 | } |
598 | out: |
599 | gf_log (THIS->name, GF_LOG_DEBUG, "Returning with %d", ret)do { do { if (0) printf ("Returning with %d", ret); } while ( 0); _gf_log ((*__glusterfs_this_location())->name, "glusterd-sm.c" , __FUNCTION__, 599, GF_LOG_DEBUG, "Returning with %d", ret); } while (0); |
600 | |
601 | return ret; |
602 | } |
603 | |
604 | static int |
605 | glusterd_ac_friend_remove (glusterd_friend_sm_event_t *event, void *ctx) |
606 | { |
607 | int ret = -1; |
608 | |
609 | ret = glusterd_friend_remove_cleanup_vols (event->peerinfo->uuid); |
610 | if (ret) |
611 | gf_log (THIS->name, GF_LOG_WARNING, "Volumes cleanup failed")do { do { if (0) printf ("Volumes cleanup failed"); } while ( 0); _gf_log ((*__glusterfs_this_location())->name, "glusterd-sm.c" , __FUNCTION__, 611, GF_LOG_WARNING, "Volumes cleanup failed" ); } while (0); |
612 | |
613 | ret = glusterd_friend_cleanup (event->peerinfo); |
614 | if (ret) { |
615 | gf_log (THIS->name, GF_LOG_ERROR, "Cleanup returned: %d", ret)do { do { if (0) printf ("Cleanup returned: %d", ret); } while (0); _gf_log ((*__glusterfs_this_location())->name, "glusterd-sm.c" , __FUNCTION__, 615, GF_LOG_ERROR, "Cleanup returned: %d", ret ); } while (0); |
616 | } |
617 | |
618 | return 0; |
619 | } |
620 | |
621 | /*static int |
622 | glusterd_ac_none (void *ctx) |
623 | { |
624 | int ret = 0; |
625 | |
626 | gf_log ("", GF_LOG_DEBUG, "Returning with %d", ret); |
627 | |
628 | return ret; |
629 | }*/ |
630 | |
631 | static int |
632 | glusterd_ac_handle_friend_add_req (glusterd_friend_sm_event_t *event, void *ctx) |
633 | { |
634 | int ret = 0; |
635 | uuid_t uuid; |
636 | glusterd_peerinfo_t *peerinfo = NULL((void*)0); |
637 | glusterd_friend_req_ctx_t *ev_ctx = NULL((void*)0); |
638 | glusterd_friend_update_ctx_t *new_ev_ctx = NULL((void*)0); |
639 | glusterd_friend_sm_event_t *new_event = NULL((void*)0); |
640 | glusterd_friend_sm_event_type_t event_type = GD_FRIEND_EVENT_NONE; |
641 | int status = 0; |
642 | int32_t op_ret = -1; |
643 | int32_t op_errno = 0; |
644 | |
645 | GF_ASSERT (ctx)do { if (!(ctx)) { do { do { if (0) printf ("Assertion failed: " "ctx"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c", __FUNCTION__, 645, GF_LOG_ERROR, "Assertion failed: " "ctx") ; } while (0); } } while (0); |
646 | ev_ctx = ctx; |
647 | uuid_copy (uuid, ev_ctx->uuid); |
648 | peerinfo = event->peerinfo; |
649 | GF_ASSERT (peerinfo)do { if (!(peerinfo)) { do { do { if (0) printf ("Assertion failed: " "peerinfo"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 649, GF_LOG_ERROR, "Assertion failed: " "peerinfo" ); } while (0); } } while (0); |
650 | uuid_copy (peerinfo->uuid, ev_ctx->uuid); |
651 | |
652 | //Build comparison logic here. |
653 | ret = glusterd_compare_friend_data (ev_ctx->vols, &status, |
654 | peerinfo->hostname); |
655 | if (ret) |
656 | goto out; |
657 | |
658 | if (GLUSTERD_VOL_COMP_RJT != status) { |
659 | event_type = GD_FRIEND_EVENT_LOCAL_ACC; |
660 | op_ret = 0; |
661 | } else { |
662 | event_type = GD_FRIEND_EVENT_LOCAL_RJT; |
663 | op_errno = GF_PROBE_VOLUME_CONFLICT; |
664 | op_ret = -1; |
665 | } |
666 | |
667 | ret = glusterd_friend_sm_new_event (event_type, &new_event); |
668 | |
669 | if (ret) { |
670 | gf_log ("", GF_LOG_ERROR, "Out of Memory")do { do { if (0) printf ("Out of Memory"); } while (0); _gf_log ("", "glusterd-sm.c", __FUNCTION__, 670, GF_LOG_ERROR, "Out of Memory" ); } while (0); |
671 | } |
672 | |
673 | new_event->peerinfo = peerinfo; |
674 | |
675 | new_ev_ctx = GF_CALLOC (1, sizeof (*new_ev_ctx),__gf_calloc (1, sizeof (*new_ev_ctx), gf_gld_mt_friend_update_ctx_t ) |
676 | gf_gld_mt_friend_update_ctx_t)__gf_calloc (1, sizeof (*new_ev_ctx), gf_gld_mt_friend_update_ctx_t ); |
677 | if (!new_ev_ctx) { |
678 | ret = -1; |
679 | goto out; |
680 | } |
681 | |
682 | uuid_copy (new_ev_ctx->uuid, ev_ctx->uuid); |
683 | new_ev_ctx->hostname = gf_strdup (ev_ctx->hostname); |
684 | new_ev_ctx->op = GD_FRIEND_UPDATE_ADD; |
685 | |
686 | new_event->ctx = new_ev_ctx; |
687 | |
688 | glusterd_friend_sm_inject_event (new_event); |
689 | |
690 | ret = glusterd_xfer_friend_add_resp (ev_ctx->req, ev_ctx->hostname, |
691 | ev_ctx->port, op_ret, op_errno); |
692 | |
693 | out: |
694 | gf_log ("", GF_LOG_DEBUG, "Returning with %d", ret)do { do { if (0) printf ("Returning with %d", ret); } while ( 0); _gf_log ("", "glusterd-sm.c", __FUNCTION__, 694, GF_LOG_DEBUG , "Returning with %d", ret); } while (0); |
695 | |
696 | return ret; |
697 | } |
698 | |
699 | static int |
700 | glusterd_friend_sm_transition_state (glusterd_peerinfo_t *peerinfo, |
701 | glusterd_sm_t *state, |
702 | glusterd_friend_sm_event_type_t event_type) |
703 | { |
704 | |
705 | GF_ASSERT (state)do { if (!(state)) { do { do { if (0) printf ("Assertion failed: " "state"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 705, GF_LOG_ERROR, "Assertion failed: " "state" ); } while (0); } } while (0); |
706 | GF_ASSERT (peerinfo)do { if (!(peerinfo)) { do { do { if (0) printf ("Assertion failed: " "peerinfo"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 706, GF_LOG_ERROR, "Assertion failed: " "peerinfo" ); } while (0); } } while (0); |
707 | |
708 | (void) glusterd_sm_tr_log_transition_add (&peerinfo->sm_log, |
709 | peerinfo->state.state, |
710 | state[event_type].next_state, |
711 | event_type); |
712 | |
713 | peerinfo->state.state = state[event_type].next_state; |
714 | return 0; |
715 | } |
716 | |
717 | |
718 | glusterd_sm_t glusterd_state_default [] = { |
719 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_none}, |
720 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_friend_probe},//EV_PROBE |
721 | {GD_FRIEND_STATE_REQ_SENT, glusterd_ac_friend_add}, //EV_INIT_FRIEND_REQ |
722 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_none}, //EVENT_RCVD_ACC |
723 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_none}, //EVENT_RCVD_LOCAL_ACC |
724 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_none}, //EVENT_RCVD_RJT |
725 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_none}, //EVENT_RCVD_LOCAL_RJT |
726 | {GD_FRIEND_STATE_REQ_RCVD, glusterd_ac_handle_friend_add_req}, //EVENT_RCV_FRIEND_REQ |
727 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_send_friend_remove_req}, //EV_INIT_REMOVE_FRIEND |
728 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_none}, //EVENT_RCVD_REMOVE_FRIEND |
729 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_friend_remove}, //EVENT_REMOVE_FRIEND |
730 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_friend_probe}, //EVENT_CONNECTED |
731 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_none}, //EVENT_MAX |
732 | }; |
733 | |
734 | glusterd_sm_t glusterd_state_probe_rcvd [] = { |
735 | {GD_FRIEND_STATE_PROBE_RCVD, glusterd_ac_none}, |
736 | {GD_FRIEND_STATE_PROBE_RCVD, glusterd_ac_none}, //EV_PROBE |
737 | {GD_FRIEND_STATE_PROBE_RCVD, glusterd_ac_none}, //EV_INIT_FRIEND_REQ |
738 | {GD_FRIEND_STATE_PROBE_RCVD, glusterd_ac_none}, //EVENT_RCVD_ACC |
739 | {GD_FRIEND_STATE_PROBE_RCVD, glusterd_ac_none}, //EVENT_RCVD_LOCAL_ACC |
740 | {GD_FRIEND_STATE_PROBE_RCVD, glusterd_ac_none}, //EVENT_RCVD_RJT |
741 | {GD_FRIEND_STATE_PROBE_RCVD, glusterd_ac_none}, //EVENT_RCVD_LOCAL_RJT |
742 | {GD_FRIEND_STATE_REQ_RCVD, glusterd_ac_handle_friend_add_req}, //EVENT_RCV_FRIEND_REQ |
743 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_send_friend_remove_req}, //EV_INIT_REMOVE_FRIEND |
744 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_none}, //EVENT_RCVD_REMOVE_FRIEND |
745 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_friend_remove}, //EVENT_REMOVE_FRIEND |
746 | {GD_FRIEND_STATE_CONNECTED_RCVD, glusterd_ac_none}, //EVENT_CONNECTED |
747 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_none}, //EVENT_MAX |
748 | }; |
749 | |
750 | glusterd_sm_t glusterd_state_connected_rcvd [] = { |
751 | {GD_FRIEND_STATE_CONNECTED_RCVD, glusterd_ac_none}, |
752 | {GD_FRIEND_STATE_CONNECTED_RCVD, glusterd_ac_none}, //EV_PROBE |
753 | {GD_FRIEND_STATE_CONNECTED_RCVD, glusterd_ac_none}, //EV_INIT_FRIEND_REQ |
754 | {GD_FRIEND_STATE_CONNECTED_RCVD, glusterd_ac_none}, //EVENT_RCVD_ACC |
755 | {GD_FRIEND_STATE_CONNECTED_ACCEPTED, glusterd_ac_reverse_probe_begin}, //EVENT_RCVD_LOCAL_ACC |
756 | {GD_FRIEND_STATE_CONNECTED_RCVD, glusterd_ac_none}, //EVENT_RCVD_RJT |
757 | {GD_FRIEND_STATE_REJECTED, glusterd_ac_none}, //EVENT_RCVD_LOCAL_RJT |
758 | {GD_FRIEND_STATE_CONNECTED_RCVD, glusterd_ac_handle_friend_add_req}, //EVENT_RCV_FRIEND_REQ |
759 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_send_friend_remove_req}, //EV_INIT_REMOVE_FRIEND |
760 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_none}, //EVENT_RCVD_REMOVE_FRIEND |
761 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_friend_remove}, //EVENT_REMOVE_FRIEND |
762 | {GD_FRIEND_STATE_CONNECTED_RCVD, glusterd_ac_none}, //EVENT_CONNECTED |
763 | {GD_FRIEND_STATE_CONNECTED_RCVD, glusterd_ac_none}, //EVENT_MAX |
764 | }; |
765 | |
766 | glusterd_sm_t glusterd_state_connected_accepted [] = { |
767 | {GD_FRIEND_STATE_CONNECTED_ACCEPTED, glusterd_ac_none}, |
768 | {GD_FRIEND_STATE_CONNECTED_ACCEPTED, glusterd_ac_friend_probe}, //EV_PROBE |
769 | {GD_FRIEND_STATE_REQ_SENT_RCVD, glusterd_ac_friend_add}, //EV_INIT_FRIEND_REQ |
770 | {GD_FRIEND_STATE_CONNECTED_ACCEPTED, glusterd_ac_none}, //EVENT_RCVD_ACC |
771 | {GD_FRIEND_STATE_CONNECTED_ACCEPTED, glusterd_ac_none}, //EVENT_RCVD_LOCAL_ACC |
772 | {GD_FRIEND_STATE_CONNECTED_ACCEPTED, glusterd_ac_none}, //EVENT_RCVD_RJT |
773 | {GD_FRIEND_STATE_CONNECTED_ACCEPTED, glusterd_ac_none}, //EVENT_RCVD_LOCAL_RJT |
774 | {GD_FRIEND_STATE_CONNECTED_ACCEPTED, glusterd_ac_none}, //EVENT_RCV_FRIEND_REQ |
775 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_send_friend_remove_req}, //EV_INIT_REMOVE_FRIEND |
776 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_none}, //EVENT_RCVD_REMOVE_FRIEND |
777 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_friend_remove}, //EVENT_REMOVE_FRIEND |
778 | {GD_FRIEND_STATE_CONNECTED_ACCEPTED, glusterd_ac_none}, //EVENT_CONNECTED |
779 | {GD_FRIEND_STATE_CONNECTED_ACCEPTED, glusterd_ac_none}, //EVENT_MAX |
780 | }; |
781 | |
782 | glusterd_sm_t glusterd_state_req_sent [] = { |
783 | {GD_FRIEND_STATE_REQ_SENT, glusterd_ac_none}, //EVENT_NONE, |
784 | {GD_FRIEND_STATE_REQ_SENT, glusterd_ac_none}, //EVENT_PROBE, |
785 | {GD_FRIEND_STATE_REQ_SENT, glusterd_ac_none}, //EVENT_INIT_FRIEND_REQ, |
786 | {GD_FRIEND_STATE_REQ_ACCEPTED, glusterd_ac_none}, //EVENT_RCVD_ACC |
787 | {GD_FRIEND_STATE_REQ_SENT, glusterd_ac_none}, //EVENT_RCVD_LOCAL_ACC |
788 | {GD_FRIEND_STATE_REJECTED, glusterd_ac_none}, //EVENT_RCVD_RJT |
789 | {GD_FRIEND_STATE_REQ_SENT, glusterd_ac_none}, //EVENT_RCVD_LOCAL_RJT |
790 | {GD_FRIEND_STATE_REQ_SENT_RCVD, glusterd_ac_handle_friend_add_req}, //EVENT_RCV_FRIEND_REQ |
791 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_send_friend_remove_req}, //EVENT_INIT_REMOVE_FRIEND, |
792 | {GD_FRIEND_STATE_REQ_SENT, glusterd_ac_none}, //EVENT_RCVD_REMOVE_FRIEND |
793 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_friend_remove}, //EVENT_REMOVE_FRIEND |
794 | {GD_FRIEND_STATE_REQ_SENT, glusterd_ac_none},//EVENT_CONNECTED |
795 | {GD_FRIEND_STATE_REQ_SENT, glusterd_ac_none},//EVENT_MAX |
796 | }; |
797 | |
798 | glusterd_sm_t glusterd_state_req_rcvd [] = { |
799 | {GD_FRIEND_STATE_REQ_RCVD, glusterd_ac_none}, //EVENT_NONE, |
800 | {GD_FRIEND_STATE_REQ_RCVD, glusterd_ac_none}, //EVENT_PROBE, |
801 | {GD_FRIEND_STATE_REQ_SENT_RCVD, glusterd_ac_none}, //EVENT_INIT_FRIEND_REQ, |
802 | {GD_FRIEND_STATE_REQ_RCVD, glusterd_ac_none}, //EVENT_RCVD_ACC |
803 | {GD_FRIEND_STATE_REQ_ACCEPTED, glusterd_ac_none}, //EVENT_RCVD_LOCAL_ACC |
804 | {GD_FRIEND_STATE_REQ_RCVD, glusterd_ac_none}, //EVENT_RCVD_RJT |
805 | {GD_FRIEND_STATE_REJECTED, glusterd_ac_none}, //EVENT_RCVD_LOCAL_RJT |
806 | {GD_FRIEND_STATE_REQ_RCVD, glusterd_ac_none}, //EVENT_RCV_FRIEND_REQ |
807 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_send_friend_remove_req}, //EVENT_INIT_REMOVE_FRIEND, |
808 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_handle_friend_remove_req}, //EVENT_RCVD_REMOVE_FRIEND |
809 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_friend_remove}, //EVENT_REMOVE_FRIEND |
810 | {GD_FRIEND_STATE_CONNECTED_RCVD, glusterd_ac_none},//EVENT_CONNECTED |
811 | {GD_FRIEND_STATE_REQ_RCVD, glusterd_ac_none},//EVENT_MAX |
812 | }; |
813 | |
814 | glusterd_sm_t glusterd_state_befriended [] = { |
815 | {GD_FRIEND_STATE_BEFRIENDED, glusterd_ac_none}, //EVENT_NONE, |
816 | {GD_FRIEND_STATE_BEFRIENDED, glusterd_ac_none}, //EVENT_PROBE, |
817 | {GD_FRIEND_STATE_BEFRIENDED, glusterd_ac_none}, //EVENT_INIT_FRIEND_REQ, |
818 | {GD_FRIEND_STATE_BEFRIENDED, glusterd_ac_none}, //EVENT_RCVD_ACC |
819 | {GD_FRIEND_STATE_BEFRIENDED, glusterd_ac_send_friend_update}, //EVENT_RCVD_LOCAL_ACC |
820 | {GD_FRIEND_STATE_REJECTED, glusterd_ac_none}, //EVENT_RCVD_RJT |
821 | {GD_FRIEND_STATE_REJECTED, glusterd_ac_none}, //EVENT_RCVD_LOCAL_RJT |
822 | {GD_FRIEND_STATE_BEFRIENDED, glusterd_ac_handle_friend_add_req}, //EVENT_RCV_FRIEND_REQ |
823 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_send_friend_remove_req}, //EVENT_INIT_REMOVE_FRIEND, |
824 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_handle_friend_remove_req}, //EVENT_RCVD_REMOVE_FRIEND |
825 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_friend_remove}, //EVENT_REMOVE_FRIEND |
826 | {GD_FRIEND_STATE_BEFRIENDED, glusterd_ac_friend_add},//EVENT_CONNECTED |
827 | {GD_FRIEND_STATE_BEFRIENDED, glusterd_ac_none},//EVENT_MAX |
828 | }; |
829 | |
830 | glusterd_sm_t glusterd_state_req_sent_rcvd [] = { |
831 | {GD_FRIEND_STATE_REQ_SENT_RCVD, glusterd_ac_none}, //EVENT_NONE, |
832 | {GD_FRIEND_STATE_REQ_SENT_RCVD, glusterd_ac_none}, //EVENT_PROBE, |
833 | {GD_FRIEND_STATE_REQ_SENT_RCVD, glusterd_ac_none}, //EVENT_INIT_FRIEND_REQ, |
834 | {GD_FRIEND_STATE_BEFRIENDED, glusterd_ac_send_friend_update}, //EVENT_RCVD_ACC |
835 | {GD_FRIEND_STATE_REQ_SENT_RCVD, glusterd_ac_none}, //EVENT_RCVD_LOCAL_ACC |
836 | {GD_FRIEND_STATE_REJECTED, glusterd_ac_none}, //EVENT_RCVD_RJT |
837 | {GD_FRIEND_STATE_REQ_SENT_RCVD, glusterd_ac_none}, //EVENT_RCVD_LOCAL_RJT |
838 | {GD_FRIEND_STATE_REQ_SENT_RCVD, glusterd_ac_none}, //EVENT_RCV_FRIEND_REQ |
839 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_send_friend_remove_req}, //EVENT_INIT_REMOVE_FRIEND, |
840 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_handle_friend_remove_req}, //EVENT_RCVD_REMOVE_FRIEND |
841 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_friend_remove}, //EVENT_REMOVE_FRIEND |
842 | {GD_FRIEND_STATE_REQ_SENT_RCVD, glusterd_ac_none},//EVENT_CONNECTED |
843 | {GD_FRIEND_STATE_REQ_SENT_RCVD, glusterd_ac_none},//EVENT_MAX |
844 | }; |
845 | |
846 | glusterd_sm_t glusterd_state_rejected [] = { |
847 | {GD_FRIEND_STATE_REJECTED, glusterd_ac_none}, //EVENT_NONE, |
848 | {GD_FRIEND_STATE_REJECTED, glusterd_ac_friend_probe}, //EVENT_PROBE, |
849 | {GD_FRIEND_STATE_REQ_SENT, glusterd_ac_friend_add}, //EVENT_INIT_FRIEND_REQ, |
850 | {GD_FRIEND_STATE_BEFRIENDED, glusterd_ac_none}, //EVENT_RCVD_ACC |
851 | {GD_FRIEND_STATE_BEFRIENDED, glusterd_ac_none}, //EVENT_RCVD_LOCAL_ACC |
852 | {GD_FRIEND_STATE_REJECTED, glusterd_ac_none}, //EVENT_RCVD_RJT |
853 | {GD_FRIEND_STATE_REJECTED, glusterd_ac_none}, //EVENT_RCVD_LOCAL_RJT |
854 | {GD_FRIEND_STATE_REQ_RCVD, glusterd_ac_handle_friend_add_req}, //EVENT_RCV_FRIEND_REQ |
855 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_send_friend_remove_req}, //EVENT_INIT_REMOVE_FRIEND |
856 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_handle_friend_remove_req}, //EVENT_RCVD_REMOVE_FRIEND |
857 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_friend_remove}, //EVENT_REMOVE_FRIEND |
858 | {GD_FRIEND_STATE_REJECTED, glusterd_ac_friend_add},//EVENT_CONNECTED |
859 | {GD_FRIEND_STATE_REQ_RCVD, glusterd_ac_none},//EVENT_MAX |
860 | }; |
861 | |
862 | glusterd_sm_t glusterd_state_req_accepted [] = { |
863 | {GD_FRIEND_STATE_REQ_ACCEPTED, glusterd_ac_none}, //EVENT_NONE, |
864 | {GD_FRIEND_STATE_REQ_ACCEPTED, glusterd_ac_none}, //EVENT_PROBE, |
865 | {GD_FRIEND_STATE_REQ_ACCEPTED, glusterd_ac_none}, //EVENT_INIT_FRIEND_REQ, |
866 | {GD_FRIEND_STATE_BEFRIENDED, glusterd_ac_send_friend_update}, //EVENT_RCVD_ACC |
867 | {GD_FRIEND_STATE_BEFRIENDED, glusterd_ac_send_friend_update}, //EVENT_RCVD_LOCAL_ACC |
868 | {GD_FRIEND_STATE_REJECTED, glusterd_ac_none}, //EVENT_RCVD_RJT |
869 | {GD_FRIEND_STATE_REJECTED, glusterd_ac_none}, //EVENT_RCVD_LOCAL_RJT |
870 | {GD_FRIEND_STATE_REQ_ACCEPTED, glusterd_ac_handle_friend_add_req}, //EVENT_RCV_FRIEND_REQ |
871 | {GD_FRIEND_STATE_REQ_ACCEPTED, glusterd_ac_send_friend_remove_req}, //EVENT_INIT_REMOVE_FRIEND |
872 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_handle_friend_remove_req}, //EVENT_RCVD_REMOVE_FRIEND |
873 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_friend_remove}, //EVENT_REMOVE_FRIEND |
874 | {GD_FRIEND_STATE_CONNECTED_ACCEPTED, glusterd_ac_reverse_probe_begin},//EVENT_CONNECTED |
875 | {GD_FRIEND_STATE_REQ_SENT, glusterd_ac_none},//EVENT_MAX |
876 | }; |
877 | |
878 | glusterd_sm_t glusterd_state_unfriend_sent [] = { |
879 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_none}, //EVENT_NONE, |
880 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_error}, //EVENT_PROBE, |
881 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_none}, //EVENT_INIT_FRIEND_REQ, |
882 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_none}, //EVENT_RCVD_ACC |
883 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_none}, //EVENT_RCVD_LOCAL_ACC |
884 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_error}, //EVENT_RCVD_RJT |
885 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_error}, //EVENT_RCVD_LOCAL_RJT |
886 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_error}, //EVENT_RCV_FRIEND_REQ |
887 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_none}, //EVENT_INIT_REMOVE_FRIEND |
888 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_none}, //EVENT_RCVD_REMOVE_FRIEND |
889 | {GD_FRIEND_STATE_DEFAULT, glusterd_ac_friend_remove}, //EVENT_REMOVE_FRIEND |
890 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_none},//EVENT_CONNECTED |
891 | {GD_FRIEND_STATE_UNFRIEND_SENT, glusterd_ac_none},//EVENT_MAX |
892 | }; |
893 | |
894 | glusterd_sm_t *glusterd_friend_state_table [] = { |
895 | glusterd_state_default, |
896 | glusterd_state_req_sent, |
897 | glusterd_state_req_rcvd, |
898 | glusterd_state_befriended, |
899 | glusterd_state_req_accepted, |
900 | glusterd_state_req_sent_rcvd, |
901 | glusterd_state_rejected, |
902 | glusterd_state_unfriend_sent, |
903 | glusterd_state_probe_rcvd, |
904 | glusterd_state_connected_rcvd, |
905 | glusterd_state_connected_accepted |
906 | }; |
907 | |
908 | int |
909 | glusterd_friend_sm_new_event (glusterd_friend_sm_event_type_t event_type, |
910 | glusterd_friend_sm_event_t **new_event) |
911 | { |
912 | glusterd_friend_sm_event_t *event = NULL((void*)0); |
913 | |
914 | GF_ASSERT (new_event)do { if (!(new_event)) { do { do { if (0) printf ("Assertion failed: " "new_event"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 914, GF_LOG_ERROR, "Assertion failed: " "new_event" ); } while (0); } } while (0); |
915 | GF_ASSERT (GD_FRIEND_EVENT_NONE <= event_type &&do { if (!(GD_FRIEND_EVENT_NONE <= event_type && GD_FRIEND_EVENT_MAX > event_type)) { do { do { if (0) printf ("Assertion failed: " "GD_FRIEND_EVENT_NONE <= event_type && GD_FRIEND_EVENT_MAX > event_type" ); } while (0); _gf_log_callingfn ("", "glusterd-sm.c", __FUNCTION__ , 916, GF_LOG_ERROR, "Assertion failed: " "GD_FRIEND_EVENT_NONE <= event_type && GD_FRIEND_EVENT_MAX > event_type" ); } while (0); } } while (0) |
916 | GD_FRIEND_EVENT_MAX > event_type)do { if (!(GD_FRIEND_EVENT_NONE <= event_type && GD_FRIEND_EVENT_MAX > event_type)) { do { do { if (0) printf ("Assertion failed: " "GD_FRIEND_EVENT_NONE <= event_type && GD_FRIEND_EVENT_MAX > event_type" ); } while (0); _gf_log_callingfn ("", "glusterd-sm.c", __FUNCTION__ , 916, GF_LOG_ERROR, "Assertion failed: " "GD_FRIEND_EVENT_NONE <= event_type && GD_FRIEND_EVENT_MAX > event_type" ); } while (0); } } while (0); |
917 | |
918 | event = GF_CALLOC (1, sizeof (*event), gf_gld_mt_friend_sm_event_t)__gf_calloc (1, sizeof (*event), gf_gld_mt_friend_sm_event_t); |
919 | |
920 | if (!event) |
921 | return -1; |
922 | |
923 | *new_event = event; |
924 | event->event = event_type; |
925 | INIT_LIST_HEAD (&event->list)do { (&event->list)->next = (&event->list)-> prev = &event->list; } while (0); |
926 | |
927 | return 0; |
928 | } |
929 | |
930 | int |
931 | glusterd_friend_sm_inject_event (glusterd_friend_sm_event_t *event) |
932 | { |
933 | GF_ASSERT (event)do { if (!(event)) { do { do { if (0) printf ("Assertion failed: " "event"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 933, GF_LOG_ERROR, "Assertion failed: " "event" ); } while (0); } } while (0); |
934 | gf_log ("glusterd", GF_LOG_DEBUG, "Enqueue event: '%s'",do { do { if (0) printf ("Enqueue event: '%s'", glusterd_friend_sm_event_name_get (event->event)); } while (0); _gf_log ("glusterd", "glusterd-sm.c" , __FUNCTION__, 935, GF_LOG_DEBUG, "Enqueue event: '%s'", glusterd_friend_sm_event_name_get (event->event)); } while (0) |
935 | glusterd_friend_sm_event_name_get (event->event))do { do { if (0) printf ("Enqueue event: '%s'", glusterd_friend_sm_event_name_get (event->event)); } while (0); _gf_log ("glusterd", "glusterd-sm.c" , __FUNCTION__, 935, GF_LOG_DEBUG, "Enqueue event: '%s'", glusterd_friend_sm_event_name_get (event->event)); } while (0); |
936 | list_add_tail (&event->list, &gd_friend_sm_queue); |
937 | |
938 | return 0; |
939 | } |
940 | |
941 | void |
942 | glusterd_destroy_friend_event_context (glusterd_friend_sm_event_t *event) |
943 | { |
944 | if (!event) |
945 | return; |
946 | |
947 | switch (event->event) { |
948 | case GD_FRIEND_EVENT_RCVD_FRIEND_REQ: |
949 | case GD_FRIEND_EVENT_RCVD_REMOVE_FRIEND: |
950 | glusterd_destroy_friend_req_ctx (event->ctx); |
951 | break; |
952 | case GD_FRIEND_EVENT_LOCAL_ACC: |
953 | case GD_FRIEND_EVENT_LOCAL_RJT: |
954 | case GD_FRIEND_EVENT_RCVD_ACC: |
955 | case GD_FRIEND_EVENT_RCVD_RJT: |
956 | glusterd_destroy_friend_update_ctx (event->ctx); |
957 | break; |
958 | default: |
959 | break; |
960 | } |
961 | } |
962 | |
963 | gf_boolean_t |
964 | gd_does_peer_affect_quorum (glusterd_friend_sm_state_t old_state, |
965 | glusterd_friend_sm_event_type_t event_type, |
966 | glusterd_peerinfo_t *peerinfo) |
967 | { |
968 | gf_boolean_t affects = _gf_false; |
969 | |
970 | //When glusterd comes up with friends in BEFRIENDED state in store, |
971 | //wait until compare-data happens. |
972 | if ((old_state == GD_FRIEND_STATE_BEFRIENDED) && |
973 | (event_type != GD_FRIEND_EVENT_RCVD_ACC) && |
974 | (event_type != GD_FRIEND_EVENT_LOCAL_ACC)) |
975 | goto out; |
976 | if ((peerinfo->state.state == GD_FRIEND_STATE_BEFRIENDED) |
977 | && peerinfo->connected) { |
978 | affects = _gf_true; |
979 | } |
980 | out: |
981 | return affects; |
982 | } |
983 | |
984 | int |
985 | glusterd_friend_sm () |
986 | { |
987 | glusterd_friend_sm_event_t *event = NULL((void*)0); |
988 | glusterd_friend_sm_event_t *tmp = NULL((void*)0); |
989 | int ret = -1; |
990 | glusterd_friend_sm_ac_fn handler = NULL((void*)0); |
991 | glusterd_sm_t *state = NULL((void*)0); |
992 | glusterd_peerinfo_t *peerinfo = NULL((void*)0); |
993 | glusterd_friend_sm_event_type_t event_type = 0; |
994 | gf_boolean_t is_await_conn = _gf_false; |
995 | gf_boolean_t quorum_action = _gf_false; |
996 | glusterd_friend_sm_state_t old_state = GD_FRIEND_STATE_DEFAULT; |
997 | |
998 | while (!list_empty (&gd_friend_sm_queue)) { |
999 | list_for_each_entry_safe (event, tmp, &gd_friend_sm_queue, list)for (event = ((typeof(*event) *)((char *)((&gd_friend_sm_queue )->next)-(unsigned long)(&((typeof(*event) *)0)->list ))), tmp = ((typeof(*event) *)((char *)(event->list.next)- (unsigned long)(&((typeof(*event) *)0)->list))); & event->list != (&gd_friend_sm_queue); event = tmp, tmp = ((typeof(*tmp) *)((char *)(tmp->list.next)-(unsigned long )(&((typeof(*tmp) *)0)->list)))) { |
1000 | |
1001 | list_del_init (&event->list); |
1002 | event_type = event->event; |
1003 | peerinfo = event->peerinfo; |
1004 | if (!peerinfo) { |
1005 | gf_log ("glusterd", GF_LOG_CRITICAL, "Received"do { do { if (0) printf ("Received" " event %s with empty peer info" , glusterd_friend_sm_event_name_get (event_type)); } while (0 ); _gf_log ("glusterd", "glusterd-sm.c", __FUNCTION__, 1007, GF_LOG_CRITICAL , "Received" " event %s with empty peer info", glusterd_friend_sm_event_name_get (event_type)); } while (0) |
1006 | " event %s with empty peer info",do { do { if (0) printf ("Received" " event %s with empty peer info" , glusterd_friend_sm_event_name_get (event_type)); } while (0 ); _gf_log ("glusterd", "glusterd-sm.c", __FUNCTION__, 1007, GF_LOG_CRITICAL , "Received" " event %s with empty peer info", glusterd_friend_sm_event_name_get (event_type)); } while (0) |
1007 | glusterd_friend_sm_event_name_get (event_type))do { do { if (0) printf ("Received" " event %s with empty peer info" , glusterd_friend_sm_event_name_get (event_type)); } while (0 ); _gf_log ("glusterd", "glusterd-sm.c", __FUNCTION__, 1007, GF_LOG_CRITICAL , "Received" " event %s with empty peer info", glusterd_friend_sm_event_name_get (event_type)); } while (0); |
1008 | |
1009 | GF_FREE (event)__gf_free (event); |
1010 | continue; |
1011 | } |
1012 | gf_log ("", GF_LOG_DEBUG, "Dequeued event of type: '%s'",do { do { if (0) printf ("Dequeued event of type: '%s'", glusterd_friend_sm_event_name_get (event_type)); } while (0); _gf_log ("", "glusterd-sm.c", __FUNCTION__ , 1013, GF_LOG_DEBUG, "Dequeued event of type: '%s'", glusterd_friend_sm_event_name_get (event_type)); } while (0) |
1013 | glusterd_friend_sm_event_name_get (event_type))do { do { if (0) printf ("Dequeued event of type: '%s'", glusterd_friend_sm_event_name_get (event_type)); } while (0); _gf_log ("", "glusterd-sm.c", __FUNCTION__ , 1013, GF_LOG_DEBUG, "Dequeued event of type: '%s'", glusterd_friend_sm_event_name_get (event_type)); } while (0); |
1014 | |
1015 | |
1016 | old_state = peerinfo->state.state; |
1017 | state = glusterd_friend_state_table[peerinfo->state.state]; |
1018 | |
1019 | GF_ASSERT (state)do { if (!(state)) { do { do { if (0) printf ("Assertion failed: " "state"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 1019, GF_LOG_ERROR, "Assertion failed: " "state" ); } while (0); } } while (0); |
1020 | |
1021 | handler = state[event_type].handler; |
1022 | GF_ASSERT (handler)do { if (!(handler)) { do { do { if (0) printf ("Assertion failed: " "handler"); } while (0); _gf_log_callingfn ("", "glusterd-sm.c" , __FUNCTION__, 1022, GF_LOG_ERROR, "Assertion failed: " "handler" ); } while (0); } } while (0); |
1023 | |
1024 | ret = handler (event, event->ctx); |
1025 | if (ret == GLUSTERD_CONNECTION_AWAITED) { |
1026 | is_await_conn = _gf_true; |
1027 | ret = 0; |
1028 | } |
1029 | |
1030 | if (ret) { |
1031 | gf_log ("glusterd", GF_LOG_ERROR, "handler returned: "do { do { if (0) printf ("handler returned: " "%d", ret); } while (0); _gf_log ("glusterd", "glusterd-sm.c", __FUNCTION__, 1032 , GF_LOG_ERROR, "handler returned: " "%d", ret); } while (0) |
1032 | "%d", ret)do { do { if (0) printf ("handler returned: " "%d", ret); } while (0); _gf_log ("glusterd", "glusterd-sm.c", __FUNCTION__, 1032 , GF_LOG_ERROR, "handler returned: " "%d", ret); } while (0); |
1033 | glusterd_destroy_friend_event_context (event); |
1034 | GF_FREE (event)__gf_free (event); |
1035 | continue; |
1036 | } |
1037 | |
1038 | if ((GD_FRIEND_EVENT_REMOVE_FRIEND == event_type) || |
1039 | (GD_FRIEND_EVENT_INIT_REMOVE_FRIEND == event_type)){ |
1040 | glusterd_destroy_friend_event_context (event); |
1041 | GF_FREE (event)__gf_free (event); |
1042 | continue; |
1043 | } |
1044 | |
1045 | ret = glusterd_friend_sm_transition_state (peerinfo, |
1046 | state, event_type); |
1047 | |
1048 | if (ret) { |
1049 | gf_log ("glusterd", GF_LOG_ERROR, "Unable to transition"do { do { if (0) printf ("Unable to transition" " state from '%s' to '%s' for event '%s'" , glusterd_friend_sm_state_name_get(peerinfo->state.state) , glusterd_friend_sm_state_name_get(state[event_type].next_state ), glusterd_friend_sm_event_name_get(event_type)); } while (0 ); _gf_log ("glusterd", "glusterd-sm.c", __FUNCTION__, 1053, GF_LOG_ERROR , "Unable to transition" " state from '%s' to '%s' for event '%s'" , glusterd_friend_sm_state_name_get(peerinfo->state.state) , glusterd_friend_sm_state_name_get(state[event_type].next_state ), glusterd_friend_sm_event_name_get(event_type)); } while (0 ) |
1050 | " state from '%s' to '%s' for event '%s'",do { do { if (0) printf ("Unable to transition" " state from '%s' to '%s' for event '%s'" , glusterd_friend_sm_state_name_get(peerinfo->state.state) , glusterd_friend_sm_state_name_get(state[event_type].next_state ), glusterd_friend_sm_event_name_get(event_type)); } while (0 ); _gf_log ("glusterd", "glusterd-sm.c", __FUNCTION__, 1053, GF_LOG_ERROR , "Unable to transition" " state from '%s' to '%s' for event '%s'" , glusterd_friend_sm_state_name_get(peerinfo->state.state) , glusterd_friend_sm_state_name_get(state[event_type].next_state ), glusterd_friend_sm_event_name_get(event_type)); } while (0 ) |
1051 | glusterd_friend_sm_state_name_get(peerinfo->state.state),do { do { if (0) printf ("Unable to transition" " state from '%s' to '%s' for event '%s'" , glusterd_friend_sm_state_name_get(peerinfo->state.state) , glusterd_friend_sm_state_name_get(state[event_type].next_state ), glusterd_friend_sm_event_name_get(event_type)); } while (0 ); _gf_log ("glusterd", "glusterd-sm.c", __FUNCTION__, 1053, GF_LOG_ERROR , "Unable to transition" " state from '%s' to '%s' for event '%s'" , glusterd_friend_sm_state_name_get(peerinfo->state.state) , glusterd_friend_sm_state_name_get(state[event_type].next_state ), glusterd_friend_sm_event_name_get(event_type)); } while (0 ) |
1052 | glusterd_friend_sm_state_name_get(state[event_type].next_state),do { do { if (0) printf ("Unable to transition" " state from '%s' to '%s' for event '%s'" , glusterd_friend_sm_state_name_get(peerinfo->state.state) , glusterd_friend_sm_state_name_get(state[event_type].next_state ), glusterd_friend_sm_event_name_get(event_type)); } while (0 ); _gf_log ("glusterd", "glusterd-sm.c", __FUNCTION__, 1053, GF_LOG_ERROR , "Unable to transition" " state from '%s' to '%s' for event '%s'" , glusterd_friend_sm_state_name_get(peerinfo->state.state) , glusterd_friend_sm_state_name_get(state[event_type].next_state ), glusterd_friend_sm_event_name_get(event_type)); } while (0 ) |
1053 | glusterd_friend_sm_event_name_get(event_type))do { do { if (0) printf ("Unable to transition" " state from '%s' to '%s' for event '%s'" , glusterd_friend_sm_state_name_get(peerinfo->state.state) , glusterd_friend_sm_state_name_get(state[event_type].next_state ), glusterd_friend_sm_event_name_get(event_type)); } while (0 ); _gf_log ("glusterd", "glusterd-sm.c", __FUNCTION__, 1053, GF_LOG_ERROR , "Unable to transition" " state from '%s' to '%s' for event '%s'" , glusterd_friend_sm_state_name_get(peerinfo->state.state) , glusterd_friend_sm_state_name_get(state[event_type].next_state ), glusterd_friend_sm_event_name_get(event_type)); } while (0 ); |
1054 | goto out; |
1055 | } |
1056 | |
1057 | if (gd_does_peer_affect_quorum (old_state, event_type, |
1058 | peerinfo)) { |
1059 | peerinfo->quorum_contrib = QUORUM_UP; |
1060 | if (peerinfo->quorum_action) { |
1061 | peerinfo->quorum_action = _gf_false; |
1062 | quorum_action = _gf_true; |
1063 | } |
1064 | } |
1065 | |
1066 | ret = glusterd_store_peerinfo (peerinfo); |
1067 | |
1068 | glusterd_destroy_friend_event_context (event); |
1069 | GF_FREE (event)__gf_free (event); |
1070 | if (is_await_conn) |
1071 | break; |
1072 | } |
1073 | if (is_await_conn) |
1074 | break; |
1075 | } |
1076 | |
1077 | ret = 0; |
1078 | out: |
1079 | if (quorum_action) { |
1080 | /* When glusterd is restarted, it needs to wait until the 'friends' view |
1081 | * of the volumes settle, before it starts any of the internal daemons. |
1082 | * |
1083 | * Every friend that was part of the cluster, would send its |
1084 | * cluster-view, 'our' way. For every friend, who belongs to |
1085 | * a partition which has a different cluster-view from our |
1086 | * partition, we may update our cluster-view. For subsequent |
1087 | * friends from that partition would agree with us, if the first |
1088 | * friend wasn't rejected. For every first friend, whom we agreed with, |
1089 | * we would need to start internal daemons/bricks belonging to the |
1090 | * new volumes. |
1091 | * glusterd_spawn_daemons calls functions that are idempotent. ie, |
1092 | * the functions spawn process(es) only if they are not started yet. |
1093 | * |
1094 | * */ |
1095 | glusterd_spawn_daemons ((void*) _gf_false); |
1096 | glusterd_do_quorum_action (); |
1097 | } |
1098 | return ret; |
1099 | } |
1100 | |
1101 | |
1102 | int |
1103 | glusterd_friend_sm_init () |
1104 | { |
1105 | INIT_LIST_HEAD (&gd_friend_sm_queue)do { (&gd_friend_sm_queue)->next = (&gd_friend_sm_queue )->prev = &gd_friend_sm_queue; } while (0); |
1106 | return 0; |
1107 | } |