Skip to content
Snippets Groups Projects
Commit 189d685c authored by Ken Payson's avatar Ken Payson
Browse files

Added timeout to port server

parent c1bfe124
No related branches found
No related tags found
No related merge requests found
...@@ -42,7 +42,7 @@ import time ...@@ -42,7 +42,7 @@ import time
# increment this number whenever making a change to ensure that # increment this number whenever making a change to ensure that
# the changes are picked up by running CI servers # the changes are picked up by running CI servers
# note that all changes must be backwards compatible # note that all changes must be backwards compatible
_MY_VERSION = 8 _MY_VERSION = 9
if len(sys.argv) == 2 and sys.argv[1] == 'dump_version': if len(sys.argv) == 2 and sys.argv[1] == 'dump_version':
...@@ -110,6 +110,11 @@ keep_running = True ...@@ -110,6 +110,11 @@ keep_running = True
class Handler(BaseHTTPServer.BaseHTTPRequestHandler): class Handler(BaseHTTPServer.BaseHTTPRequestHandler):
def setup(self):
# If the client is unreachable for 5 seconds, close the connection
self.timeout = 5
BaseHTTPServer.BaseHTTPRequestHandler.setup(self)
def do_GET(self): def do_GET(self):
global keep_running global keep_running
......
...@@ -1094,10 +1094,6 @@ def _shut_down_legacy_server(legacy_server_port): ...@@ -1094,10 +1094,6 @@ def _shut_down_legacy_server(legacy_server_port):
def _start_port_server(port_server_port): def _start_port_server(port_server_port):
# Temporary patch to switch the port_server port
# see https://github.com/grpc/grpc/issues/7145
_shut_down_legacy_server(32767)
# check if a compatible port server is running # check if a compatible port server is running
# if incompatible (version mismatch) ==> start a new one # if incompatible (version mismatch) ==> start a new one
# if not running ==> start a new one # if not running ==> start a new one
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment