diff options
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: |