From 1f1b63ea6d7dfd8b6f819219b43578ebc1acf01d Mon Sep 17 00:00:00 2001 From: jesopo Date: Fri, 7 Jun 2019 08:02:04 +0100 Subject: Checking if we should enable write buffer should be in _fill_throttle() --- src/IRCSocket.py | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) (limited to 'src/IRCSocket.py') diff --git a/src/IRCSocket.py b/src/IRCSocket.py index 0223a7a9..19c72f7e 100644 --- a/src/IRCSocket.py +++ b/src/IRCSocket.py @@ -129,8 +129,12 @@ class Socket(IRCObject.Object): else: self._queued_lines.append(line) - def _fill_throttle(self): + if not self._write_buffer and self._throttle_when_empty: + self._throttle_when_empty = False + self._write_throttling = True + self._recent_sends.clear() + throttle_space = self.throttle_space() if throttle_space: to_buffer = self._queued_lines[:throttle_space] @@ -139,11 +143,6 @@ class Socket(IRCObject.Object): self._immediate_buffer(line) def _send(self) -> typing.List[IRCLine.SentLine]: - if not self._write_buffer and self._throttle_when_empty: - self._throttle_when_empty = False - self._write_throttling = True - self._recent_sends.clear() - bytes_written_i = self._socket.send(self._write_buffer) bytes_written = self._write_buffer[:bytes_written_i] -- cgit v1.3.1-10-gc9f91