From ec49140717843a4954fc6405054a23d52335250a Mon Sep 17 00:00:00 2001 From: GowthamShanmugasundaram Date: Tue, 21 Aug 2018 08:42:49 +0000 Subject: [PATCH] Modifying provisioner when peer disconnect events occurs Signed-off-by: GowthamShanmugasundaram --- .../gluster_integration/message/callback.py | 22 +++++++++++++++++++ 1 file changed, 22 insertions(+) diff --git a/tendrl/gluster_integration/message/callback.py b/tendrl/gluster_integration/message/callback.py index 8d0bf81..625e97d 100644 --- a/tendrl/gluster_integration/message/callback.py +++ b/tendrl/gluster_integration/message/callback.py @@ -788,6 +788,28 @@ def snapshot_restored(self, event): event["message"] = brick_details self.volume_remove_brick_force(event) + def peer_disconnect(self, event): + try: + # find node id + ip = socket.gethostbyname( + event['message']['peer'] + ) + _node_id = etcd_utils.read( + "/indexes/ip/%s" % ip + ).value + node_context = NS.tendrl.objects.NodeContext( + node_id = _node_id + ).load() + _ptag = "provisioner/%s" % \ + NS.tendrl_context.integration_id + if _ptag in node_context.tags: + node_context.tags.remove(_ptag) + node_context.save() + _index_key = "/indexes/tags/%s" % _ptag + etcd_utils.delete(_index_key) + except(etcd.EtcdException, KeyError) as ex: + pass + def parse_subvolume(subvol): # volume1-replica-2 or volume_1-replica-2 or volume-1-replica-2