In multicast-discover-servers.py, server and client sockets are set to non-blocking and select timeout is set to 0.1 second.

Signed-off-by: Bala.FA <bala@gluster.com>

1 files changed, 3 insertions, 1 deletions

diff --git a/src/com.gluster.storage.management.gateway.scripts/src/gateway/multicast-discover-servers.py b/src/com.gluster.storage.management.gateway.scripts/src/gateway/multicast-discover-servers.py
index fcbcd738..ded207c0 100755
--- a/src/com.gluster.storage.management.gateway.scripts/src/gateway/multicast-discover-servers.py
+++ b/src/com.gluster.storage.management.gateway.scripts/src/gateway/multicast-discover-servers.py
@@ -37,6 +37,7 @@ def sendMulticastRequest(idString):
 def openServerSocket():
     try:
         server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+        server.setblocking(0)
         server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
         server.bind(('', Globals.SERVER_PORT))
         server.listen(Globals.DEFAULT_BACKLOG)
@@ -64,7 +65,7 @@ def main():
     signal.alarm(Globals.DEFAULT_TIMEOUT)
     while running:
         try:
-            ilist,olist,elist = select.select(rlist, [], [], 0.25)
+            ilist,olist,elist = select.select(rlist, [], [], 0.1)
         except select.error, e:
             Utils.log("failed to read from connections: %s" % str(e))
             break
@@ -72,6 +73,7 @@ def main():
             # handle new connection
             if sock == serverSocket:
                 clientSocket, address = serverSocket.accept()
+                clientSocket.setblocking(0)
                 #print "connection from %s on %s" % (address, clientSocket)
                 rlist.append(clientSocket)
                 continue