matrix/weechat-matrix
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Mark some server methods as private.

Browse source
This commit is contained in:
poljar (Damir Jelić) 2018-02-02 10:36:54 +01:00
parent f9df032667
commit e7f229e4a2
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
matrix/server.py
View file

@ -207,7 +207,7 @@ class MatrixServer:
return True return True
except socket.error as error: except socket.error as error:
self.abort_send() self._abort_send()
errno = "error" + str(error.errno) + " " if error.errno else "" errno = "error" + str(error.errno) + " " if error.errno else ""
strerr = error.strerror if error.strerror else "Unknown reason" strerr = error.strerror if error.strerror else "Unknown reason"
@ -228,7 +228,7 @@ class MatrixServer:
return False return False
if sent == 0: if sent == 0:
self.abort_send() self._abort_send()
server_buffer_prnt( server_buffer_prnt(
self, self,
@ -243,15 +243,15 @@ class MatrixServer:
total_sent = total_sent + sent total_sent = total_sent + sent
self.finalize_send() self._finalize_send()
return True return True
def abort_send(self): def _abort_send(self):
self.send_queue.appendleft(self.current_message) self.send_queue.appendleft(self.current_message)
self.current_message = None self.current_message = None
self.send_buffer = "" self.send_buffer = ""
def finalize_send(self): def _finalize_send(self):
# type: (MatrixServer) -> None # type: (MatrixServer) -> None
self.current_message.send_time = time.time() self.current_message.send_time = time.time()
self.receive_queue.append(self.current_message) self.receive_queue.append(self.current_message)