From 3b4c9e525e931a703cc526b3fbe27ee86f2fd70a Mon Sep 17 00:00:00 2001 From: Aravinda VK Date: Wed, 3 Aug 2016 12:16:43 +0530 Subject: eventsapi: Geo-replication User driven events Following Geo-replication Events are added GEOREP_CREATE/GEOREP_START/GEOREP_STOP/GEOREP_DELETE/GEOREP_PAUSE/GEOREP_RESUME { "nodeid": NODEID, "ts": TIMESTAMP, "event": EVENT_TYPE, "message": { "master": MASTER_VOLUME_NAME, "slave": SLAVE_DETAILS } } GEOREP_CONFIG_SET { "nodeid": NODEID, "ts": TIMESTAMP, "event": GEOREP_CONFIG_SET, "message": { "master": MASTER_VOLUME_NAME, "slave": SLAVE_DETAILS, "option": OPTION_NAME, "value": OPTION_VALUE } } GEOREP_CONFIG_RESET { "nodeid": NODEID, "ts": TIMESTAMP, "event": GEOREP_CONFIG_RESET, "message": { "master": MASTER_VOLUME_NAME, "slave": SLAVE_DETAILS, "option": OPTION_NAME } } BUG: 1363591 Change-Id: I78c81aabd022ebb042b3eae3c6b5a284a6c2801f Signed-off-by: Aravinda VK Reviewed-on: http://review.gluster.org/15077 Smoke: Gluster Build System CentOS-regression: Gluster Build System NetBSD-regression: NetBSD Build System Reviewed-by: Kotresh HR --- cli/src/cli-cmd-volume.c | 125 +++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 125 insertions(+) (limited to 'cli') diff --git a/cli/src/cli-cmd-volume.c b/cli/src/cli-cmd-volume.c index 77635b76530..b7f95f3ae7b 100644 --- a/cli/src/cli-cmd-volume.c +++ b/cli/src/cli-cmd-volume.c @@ -1950,6 +1950,14 @@ cli_cmd_volume_gsync_set_cbk (struct cli_state *state, struct cli_cmd_word *word rpc_clnt_procedure_t *proc = NULL; call_frame_t *frame = NULL; cli_local_t *local = NULL; +#if (USE_EVENTS) + int ret1 = -1; + int cmd_type = -1; + int tmpi = 0; + char *tmp = NULL; + char *events_str = NULL; + int event_type = -1; +#endif proc = &cli_rpc_prog->proctable [GLUSTER_CLI_GSYNC_SET]; @@ -1975,6 +1983,123 @@ out: if (ret && parse_err == 0) cli_out (GEOREP" command failed"); +#if (USE_EVENTS) + if (ret == 0) { + events_str = gf_strdup (""); + + /* Type of Geo-rep Action - Create, Start etc */ + ret1 = dict_get_int32 (options, "type", &cmd_type); + if (ret1) + cmd_type = -1; + + /* Only capture Events for modification commands */ + switch (cmd_type) { + case GF_GSYNC_OPTION_TYPE_CREATE: + event_type = EVENT_GEOREP_CREATE; + break; + case GF_GSYNC_OPTION_TYPE_START: + event_type = EVENT_GEOREP_START; + break; + case GF_GSYNC_OPTION_TYPE_STOP: + event_type = EVENT_GEOREP_STOP; + break; + case GF_GSYNC_OPTION_TYPE_PAUSE: + event_type = EVENT_GEOREP_PAUSE; + break; + case GF_GSYNC_OPTION_TYPE_RESUME: + event_type = EVENT_GEOREP_RESUME; + break; + case GF_GSYNC_OPTION_TYPE_DELETE: + event_type = EVENT_GEOREP_DELETE; + break; + case GF_GSYNC_OPTION_TYPE_CONFIG: + ret1 = dict_get_str (options, "subop", &tmp); + if (ret1) + tmp = ""; + + /* For Config Set additionally capture key and value */ + /* For Config Reset capture key */ + if (strcmp (tmp, "set") == 0) { + event_type = EVENT_GEOREP_CONFIG_SET; + + ret1 = dict_get_str (options, "op_name", &tmp); + if (ret1) + tmp = ""; + + gf_asprintf (&events_str, "%soption=%s;", + events_str, tmp); + + ret1 = dict_get_str (options, "op_value", &tmp); + if (ret1) + tmp = ""; + + gf_asprintf (&events_str, "%svalue=%s;", + events_str, tmp); + } else if (strcmp (tmp, "del") == 0) { + event_type = EVENT_GEOREP_CONFIG_RESET; + + ret1 = dict_get_str (options, "op_name", &tmp); + if (ret1) + tmp = ""; + + gf_asprintf (&events_str, "%soption=%s;", + events_str, tmp); + } + break; + default: + break; + } + + if (event_type > -1) { + /* Capture all optional arguments used */ + ret1 = dict_get_int32 (options, "force", &tmpi); + if (ret1 == 0) + gf_asprintf (&events_str, "%sforce=%d;", + events_str, tmpi); + + ret1 = dict_get_int32 (options, "push_pem", &tmpi); + if (ret1 == 0) + gf_asprintf (&events_str, "%spush_pem=%d;", + events_str, tmpi); + + ret1 = dict_get_int32 (options, "no_verify", &tmpi); + if (ret1 == 0) + gf_asprintf (&events_str, "%sno_verify=%d;", + events_str, tmpi); + + ret1 = dict_get_int32 (options, "ssh_port", &tmpi); + if (ret1 == 0) + gf_asprintf (&events_str, "%sssh_port=%d;", + events_str, tmpi); + + ret1 = dict_get_int32 (options, "reset-sync-time", + &tmpi); + if (ret1 == 0) + gf_asprintf (&events_str, + "%sreset_sync_time=%d;", + events_str, tmpi); + + /* Capture Master and Slave Info */ + ret1 = dict_get_str (options, "master", &tmp); + if (ret1) + tmp = ""; + gf_asprintf (&events_str, "%smaster=%s;", + events_str, tmp); + + ret1 = dict_get_str (options, "slave", &tmp); + if (ret1) + tmp = ""; + gf_asprintf (&events_str, "%sslave=%s", + events_str, tmp); + + gf_event (event_type, "%s", events_str); + } + + /* Allocated by gf_strdup and gf_asprintf */ + GF_FREE (events_str); + } +#endif + CLI_STACK_DESTROY (frame); return ret; -- cgit