fix graceful restart test

This commit is contained in:
clowwindy
2015-08-02 15:12:41 +08:00
parent b28de8e2f1
commit 177c639b19
3 changed files with 5 additions and 4 deletions

View File

@ -274,11 +274,11 @@ class UDPRelay(object):
def handle_periodic(self):
if self._closed:
if self._server_socket:
logging.info('closed UDP port %d', self._listen_port)
self._server_socket.close()
self._server_socket = None
for sock in self._sockets:
sock.close()
logging.info('closed UDP port %d', self._listen_port)
self._cache.sweep()
self._client_fd_to_server_addr.sweep()