diff options
| author | 2019-06-07 08:02:04 +0100 | |
|---|---|---|
| committer | 2019-06-07 08:02:22 +0100 | |
| commit | 1f1b63ea6d7dfd8b6f819219b43578ebc1acf01d (patch) | |
| tree | 33b856ceccf4e3c54212895a4476af63cd2ebcb7 | |
| parent | Remove debug print (diff) | |
| signature | ||
Checking if we should enable write buffer should be in _fill_throttle()
| -rw-r--r-- | src/IRCSocket.py | 11 |
1 files changed, 5 insertions, 6 deletions
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] |
