client_test.py 文件源码

def combined_handler(path, path_action, file_id, stream_action, path_input=None, path_output=None, stream_input=None, stream_output=None):
    class _(BaseHTTPRequestHandler):
        def do_POST(self):
            request_path = urlparse(self.path).path
            paths_path = alluxio.client._paths_url_path(path, path_action)
            streams_path = alluxio.client._streams_url_path(
                file_id, stream_action)
            close_path = alluxio.client._streams_url_path(file_id, 'close')
            if request_path == paths_path:
                handle_paths_request(
                    self, path, path_action, input=path_input, output=path_output)
            elif request_path == streams_path:
                handle_streams_request(
                    self, file_id, stream_action, input=stream_input, output=stream_output)
            elif request_path == close_path:
                self.send_response(200)

    return _