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

Clear the send queue when disconnected as well.

Browse source
This commit is contained in:
poljar (Damir Jelić) 2018-02-15 15:28:01 +01:00
parent fc25fe54c9
commit afd595b780
2 changed files with 1 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
main.py
View file

@ -257,11 +257,6 @@ def receive_cb(server_name, file_descriptor):
server.disconnect() server.disconnect()
# Queue the failed message for resending
if server.receive_queue:
message = server.receive_queue.popleft()
server.send_queue.appendleft(message)
return W.WEECHAT_RC_OK return W.WEECHAT_RC_OK
if not data: if not data:
@ -274,11 +269,6 @@ def receive_cb(server_name, file_descriptor):
("{prefix}matrix: disconnecting from server...").format( ("{prefix}matrix: disconnecting from server...").format(
prefix=W.prefix("network"))) prefix=W.prefix("network")))
# Queue the failed message for resending
if server.receive_queue:
message = server.receive_queue.popleft()
server.send_queue.appendleft(message)
server.disconnect() server.disconnect()
break break

1
matrix/server.py
View file

@ -334,6 +334,7 @@ class MatrixServer:
self.socket = None self.socket = None
self.connected = False self.connected = False
self.access_token = "" self.access_token = ""
self.send_queue.clear()
self.receive_queue.clear() self.receive_queue.clear()
self.lag = 0 self.lag = 0