summaryrefslogtreecommitdiffstats
path: root/src/com.gluster.storage.management.server.scripts
diff options
context:
space:
mode:
authorDhandapani <dhandapani@gluster.com>2011-05-05 10:55:03 +0530
committerDhandapani <dhandapani@gluster.com>2011-05-05 10:55:03 +0530
commit5499f8e8b1769deaeef02a44a330c724e2b34dcd (patch)
treec0fb8cd76bf3dc74a7927be3cc60520eb951b02f /src/com.gluster.storage.management.server.scripts
parent9423c6e3c1c4a9f2f128236a7662275a93e05551 (diff)
parent6483de355e5c2204ad99009e4183808e00e17020 (diff)
Merge commit 'upstream/master'
Diffstat (limited to 'src/com.gluster.storage.management.server.scripts')
-rwxr-xr-xsrc/com.gluster.storage.management.server.scripts/src/nodes/PeerAgent.py23
1 files changed, 19 insertions, 4 deletions
diff --git a/src/com.gluster.storage.management.server.scripts/src/nodes/PeerAgent.py b/src/com.gluster.storage.management.server.scripts/src/nodes/PeerAgent.py
index a09e055a..6218e921 100755
--- a/src/com.gluster.storage.management.server.scripts/src/nodes/PeerAgent.py
+++ b/src/com.gluster.storage.management.server.scripts/src/nodes/PeerAgent.py
@@ -181,12 +181,27 @@ def main():
try:
requestString = Socket.readPacket(clientInputStream)
Utils.log('__DEBUG__ Received %s' % repr(requestString))
- responseString = executeCommand(requestString)
- if responseString:
- Socket.writePacket(clientOutputStream, responseString)
+ requestParts = requestString.split(None, 3)
+
+ if "get_file" == requestParts[0]:
+ if len(requestParts) != 2:
+ rs = ResponseXml()
+ rs.appendTagRoute("status.code", "-1")
+ rs.appendTagRoute("status.message", "File path not passed")
+ Socket.writePacket(clientOutputStream, rs.toprettyxml())
+ else:
+ filePath = requestParts[1]
+ fp = open(filePath)
+ clientSocket.sendall(fp.read())
+ fp.close()
clientOutputStream.flush()
else:
- Utils.log('__DEBUG__ empty response string')
+ responseString = executeCommand(requestString)
+ if responseString:
+ Socket.writePacket(clientOutputStream, responseString)
+ clientOutputStream.flush()
+ else:
+ Utils.log('__DEBUG__ empty response string')
Utils.log('__DEBUG__ Closing client %s' % str(clientAddress))
clientSocket.close()
except socket.error, e: