From b3eaf0c33c5e55e057b218f03730ac778ddb5e9f Mon Sep 17 00:00:00 2001 From: Yuxin Wang Date: Sun, 30 Sep 2018 11:00:11 -0400 Subject: [PATCH] Make is_running protected member. --- p2pfs/core/server.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/p2pfs/core/server.py b/p2pfs/core/server.py index aa9cec5..a148614 100644 --- a/p2pfs/core/server.py +++ b/p2pfs/core/server.py @@ -16,7 +16,7 @@ class MessageServer: self._compressor = zstd.ZstdCompressor() self._decompressor = zstd.ZstdDecompressor() - self.is_running = True + self._is_running = True def start(self): self._sock.listen(5) @@ -26,18 +26,18 @@ class MessageServer: self._server_started() def stop(self): - self.is_running = False + self._is_running = False self._sock.close() def _listen(self): try: - while self.is_running: + while self._is_running: client, address = self._sock.accept() logger.info('New connection from {}'.format(address)) self._client_connected(client) threading.Thread(target=self._read_message, args=(client,)).start() except ConnectionAbortedError or OSError as e: - if self.is_running: + if self._is_running: # if exception occurred during normal execution logger.error(e) else: