diff options
| author | Atin Mukherjee <amukherj@redhat.com> | 2016-07-26 16:01:56 +0530 |
|---|---|---|
| committer | Atin Mukherjee <amukherj@redhat.com> | 2016-08-22 06:10:44 -0700 |
| commit | ca18f4bccd090e98ee5342ca05d3c0f9f94e9e2c (patch) | |
| tree | 4ea51c5424f1b0d927292c8b51177da99d1cd213 /xlators/mgmt/glusterd/src/glusterd-handshake.c | |
| parent | fcb5b70b1099d0379b40c81f35750df8bb9545a5 (diff) | |
glusterd: Add async events
As the eventing framework is already in the code, this patch targets to capture
all the async glusterd events which are important to be notified to the higher
layers which consume the eventing framework.
I plan to break this work into two different patches where this patch set covers
the first set of events.
Change-Id: Ie1bd4f6fa84117b26ccb4c75bc4dc68e6ef19134
BUG: 1360809
Signed-off-by: Atin Mukherjee <amukherj@redhat.com>
Reviewed-on: http://review.gluster.org/15015
Smoke: Gluster Build System <jenkins@build.gluster.org>
NetBSD-regression: NetBSD Build System <jenkins@build.gluster.org>
CentOS-regression: Gluster Build System <jenkins@build.gluster.org>
Reviewed-by: Rohan Kanade <rkanade@redhat.com>
Reviewed-by: Samikshan Bairagya <samikshan@gmail.com>
Diffstat (limited to 'xlators/mgmt/glusterd/src/glusterd-handshake.c')
| -rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-handshake.c | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/xlators/mgmt/glusterd/src/glusterd-handshake.c b/xlators/mgmt/glusterd/src/glusterd-handshake.c index 0ea66a027bf..9f162d8afc2 100644 --- a/xlators/mgmt/glusterd/src/glusterd-handshake.c +++ b/xlators/mgmt/glusterd/src/glusterd-handshake.c @@ -984,6 +984,7 @@ __server_event_notify (rpcsvc_request_t *req) gf_msg ("glusterd", GF_LOG_ERROR, EINVAL, GD_MSG_OP_UNSUPPORTED, "Unknown op received in event " "notify"); + gf_event (EVENT_NOTIFY_UNKNOWN_OP, "op=%d", args.op); ret = -1; break; } @@ -1118,6 +1119,8 @@ gd_validate_mgmt_hndsk_req (rpcsvc_request_t *req, dict_t *dict) GD_MSG_HANDSHAKE_REQ_REJECTED, "Rejecting management " "handshake request from unknown peer %s", req->trans->peerinfo.identifier); + gf_event (EVENT_PEER_REJECT, "peer=%s", + req->trans->peerinfo.identifier); return _gf_false; } |