Updated multicast_response.py to response only if the server is not part of peer list.

1 files changed, 19 insertions, 0 deletions

diff --git a/src/com.gluster.storage.management.server.scripts/src/nodes/multicast_response.py b/src/com.gluster.storage.management.server.scripts/src/nodes/multicast_response.py
index 64bc0899..dba65c07 100644
--- a/src/com.gluster.storage.management.server.scripts/src/nodes/multicast_response.py
+++ b/src/com.gluster.storage.management.server.scripts/src/nodes/multicast_response.py
@@ -16,10 +16,26 @@
 #  along with this program.  If not, see

 #  <http://www.gnu.org/licenses/>.

 

+import os

+import string

+import time

+import Utils

 import socket

 import struct

 import Globals

 

+def isinpeer():

+    command = "gluster peer status"

+    status = Utils.runCommand(command, output=True, root=True)

+    if status["Status"] == 0:

+        return True

+        #lines = status["Stdout"].split("\n")

+        #for line in lines:

+        #    if string.upper(line).startswith("HOSTNAME: %s" % string.upper(socket.gethostname)):

+        #        return True

+    Utils.log("command [%s] failed with [%d:%s]" % (command, status["Status"], os.strerror(status["Status"])))

+    return False

+

 def response(multiCastGroup, port):

     # waiting for the request!

     socketRequest = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)

@@ -33,6 +49,9 @@ def response(multiCastGroup, port):
 

     #TODO: Remove infinite loop and make this as a deamon (service)

     while True:

+        if isinpeer():

+            time.sleep(5)

+            continue

         request = socketRequest.recvfrom(1024)

         if request and request[0].upper() == "SERVERDISCOVERY":

             socketSend.sendto(socket.gethostname(), (multiCastGroup, port))