summaryrefslogtreecommitdiffstats
path: root/com.gluster.storage.management.server.scripts/src/nodes/Socket.py
diff options
context:
space:
mode:
authorShireesh Anjal <anjalshireesh@gmail.com>2011-03-28 06:58:51 -0700
committerShireesh Anjal <anjalshireesh@gmail.com>2011-03-28 06:58:51 -0700
commitbf531d097bc99db08bda4d1a1dec541c57c7933c (patch)
tree253a3fc82d5bac3755fc7e32f8456879b69b9979 /com.gluster.storage.management.server.scripts/src/nodes/Socket.py
parentb27c5d68d3ffa47c92e0fcd7d0873ac2d6b8fca8 (diff)
Preparing src for migration to github
Diffstat (limited to 'com.gluster.storage.management.server.scripts/src/nodes/Socket.py')
-rw-r--r--com.gluster.storage.management.server.scripts/src/nodes/Socket.py47
1 files changed, 0 insertions, 47 deletions
diff --git a/com.gluster.storage.management.server.scripts/src/nodes/Socket.py b/com.gluster.storage.management.server.scripts/src/nodes/Socket.py
deleted file mode 100644
index ba6b6ad0..00000000
--- a/com.gluster.storage.management.server.scripts/src/nodes/Socket.py
+++ /dev/null
@@ -1,47 +0,0 @@
-import socket
-import sys
-import Globals
-
-def openServerSocket(bindAddress="", port=Globals.SERVER_AGENT_PORT):
- sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
- sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
- sock.bind((bindAddress, port))
- sock.listen(1)
- return sock
-
-
-def connectToServer(serverName, port=Globals.SERVER_AGENT_PORT):
- sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
- sock.connect((serverName, port))
- print "__DEBUG__ connected to ", serverName, " on port ", port
- inputStream = sock.makefile("r")
- outputStream = sock.makefile("w")
- return sock, inputStream, outputStream
-
-
-def acceptClient(serverSocket):
- clientSocket, clientAddress = serverSocket.accept()
- clientInputStream = clientSocket.makefile("r")
- clientOutputStream = clientSocket.makefile("w")
- return clientSocket, clientAddress, clientInputStream, clientOutputStream
-
-
-def readPacket(inputStream):
- packetString = ""
- while True:
- line = inputStream.readline()
- print "__DEBUG__", line
- if not line:
- break
- if line.strip() == "":
- # end of input received
- return packetString
- packetString += line
- return packetString
-
-
-def writePacket(outputStream, packetString):
- rv = outputStream.write(packetString.strip() + "\n\n")
- outputStream.flush()
-
-