diff options
| author | Dhandapani <dhandapani@gluster.com> | 2011-05-05 10:55:03 +0530 |
|---|---|---|
| committer | Dhandapani <dhandapani@gluster.com> | 2011-05-05 10:55:03 +0530 |
| commit | 5499f8e8b1769deaeef02a44a330c724e2b34dcd (patch) | |
| tree | c0fb8cd76bf3dc74a7927be3cc60520eb951b02f /src/com.gluster.storage.management.server.scripts | |
| parent | 9423c6e3c1c4a9f2f128236a7662275a93e05551 (diff) | |
| parent | 6483de355e5c2204ad99009e4183808e00e17020 (diff) | |
Merge commit 'upstream/master'
Diffstat (limited to 'src/com.gluster.storage.management.server.scripts')
| -rwxr-xr-x | src/com.gluster.storage.management.server.scripts/src/nodes/PeerAgent.py | 23 |
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: |
