diff options
| author | 2019-02-11 10:00:41 +0000 | |
|---|---|---|
| committer | 2019-02-11 10:00:41 +0000 | |
| commit | 9b44b6cd139f4e47bd57513a3af663cd2eecb571 (patch) | |
| tree | 26ba2b81b2f684acc718c5558dfdda2237d816a5 /src/IRCBot.py | |
| parent | We don't need to send `writebuffer.empty` event any more (src/IRCServer.py) (diff) | |
Shift socket.socket related logic to IRCSocket.py
Diffstat (limited to 'src/IRCBot.py')
| -rw-r--r-- | src/IRCBot.py | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/IRCBot.py b/src/IRCBot.py index 6caf720b..59b3837f 100644 --- a/src/IRCBot.py +++ b/src/IRCBot.py @@ -101,8 +101,9 @@ class Bot(object): def next_send(self) -> typing.Optional[float]: next = None for server in self.servers.values(): - timeout = server.send_throttle_timeout() - if server.waiting_send() and (next == None or timeout < next): + timeout = server.socket.send_throttle_timeout() + if (server.socket.waiting_send() and + (next == None or timeout < next)): next = timeout return next @@ -238,7 +239,8 @@ class Bot(object): self.log.warn( "Disconnected from %s, reconnecting in %d seconds", [str(server), reconnect_delay]) - elif server.waiting_send() and server.throttle_done(): + elif (server.socket.waiting_send() and + server.socket.throttle_done()): self.register_both(server) for sock in list(self.other_sockets.values()): |
