From 3f73e2996579bf19ac67d4230ec5a68b3f9bbafd Mon Sep 17 00:00:00 2001 From: alesapin Date: Mon, 29 Mar 2021 16:59:05 +0300 Subject: [PATCH] Remove unused file --- .../0_stateless/helpers/httpechoserver.py | 99 ------------------- 1 file changed, 99 deletions(-) delete mode 100644 tests/queries/0_stateless/helpers/httpechoserver.py diff --git a/tests/queries/0_stateless/helpers/httpechoserver.py b/tests/queries/0_stateless/helpers/httpechoserver.py deleted file mode 100644 index 28f5de540df..00000000000 --- a/tests/queries/0_stateless/helpers/httpechoserver.py +++ /dev/null @@ -1,99 +0,0 @@ -#!/usr/bin/env python3 - -import sys -import os -import time -import subprocess -import threading -from io import StringIO, SEEK_END -from http.server import BaseHTTPRequestHandler, HTTPServer - -CLICKHOUSE_HOST = os.environ.get('CLICKHOUSE_HOST', '127.0.0.1') -CLICKHOUSE_PORT_HTTP = os.environ.get('CLICKHOUSE_PORT_HTTP', '8123') - -# IP-address of this host accessible from outside world. -HTTP_SERVER_HOST = os.environ.get('HTTP_SERVER_HOST', subprocess.check_output(['hostname', '-i']).decode('utf-8').strip()) -HTTP_SERVER_PORT = int(os.environ.get('CLICKHOUSE_TEST_HOST_EXPOSED_PORT', 51234)) - -# IP address and port of the HTTP server started from this script. -HTTP_SERVER_ADDRESS = (HTTP_SERVER_HOST, HTTP_SERVER_PORT) -HTTP_SERVER_URL_STR = 'http://' + ':'.join(str(s) for s in HTTP_SERVER_ADDRESS) + "/" - -ostream = StringIO() -istream = sys.stdout - -class EchoCSVHTTPServer(BaseHTTPRequestHandler): - def _set_headers(self): - self.send_response(200) - self.send_header('Content-type', 'text/plain') - self.end_headers() - - def do_GET(self): - self._set_headers() - with open(CSV_DATA, 'r') as fl: - ostream.seek(0) - for row in ostream: - self.wfile.write(row + '\n') - return - - def read_chunk(self): - msg = '' - while True: - sym = self.rfile.read(1) - if sym == '': - break - msg += sym.decode('utf-8') - if msg.endswith('\r\n'): - break - length = int(msg[:-2], 16) - if length == 0: - return '' - content = self.rfile.read(length) - self.rfile.read(2) # read sep \r\n - return content.decode('utf-8') - - def do_POST(self): - while True: - chunk = self.read_chunk() - if not chunk: - break - istream.write(chunk) - istream.flush() - text = "" - self._set_headers() - self.wfile.write("ok") - - def log_message(self, format, *args): - return - -def start_server(requests_amount, test_data="Hello,2,-2,7.7\nWorld,2,-5,8.8"): - ostream = StringIO(test_data) - - httpd = HTTPServer(HTTP_SERVER_ADDRESS, EchoCSVHTTPServer) - - def real_func(): - for i in range(requests_amount): - httpd.handle_request() - - t = threading.Thread(target=real_func) - return t - -def run(requests_amount=1): - t = start_server(requests_amount) - t.start() - t.join() - -if __name__ == "__main__": - exception_text = '' - for i in range(1, 5): - try: - run(int(sys.argv[1]) if len(sys.argv) > 1 else 1) - break - except Exception as ex: - exception_text = str(ex) - time.sleep(1) - - if exception_text: - print("Exception: {}".format(exception_text), file=sys.stderr) - os._exit(1) -