diff options
| author | 2019-06-06 20:22:56 +0100 | |
|---|---|---|
| committer | 2019-06-06 20:22:56 +0100 | |
| commit | 0f7b040165e5b3e8e59e2df9acf6c30183b04458 (patch) | |
| tree | 3e72ab2c784e079b4d258c47ff09341eb50af406 /src | |
| parent | Only trigger read/write threads once (diff) | |
| signature | ||
call timer callbacks and expire cach objects on main thread
Diffstat (limited to 'src')
| -rw-r--r-- | src/IRCBot.py | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/IRCBot.py b/src/IRCBot.py index 80446601..8b6d19b1 100644 --- a/src/IRCBot.py +++ b/src/IRCBot.py @@ -282,9 +282,9 @@ class Bot(object): self._event_queue.put(lambda: None) break + self.trigger(self._check) + events = self._read_poll.poll(self.get_poll_timeout()) - self._timers.call() - self.cache.expire() for func, func_queue in self._trigger_functions: try: @@ -315,9 +315,10 @@ class Bot(object): self.log.warn("Recieved EPOLLHUP for %s", [str(server)]) server.disconnect() - self.trigger(self._check_servers) + def _check(self): + self._timers.call() + self.cache.expire() - def _check_servers(self): throttle_filled = False for server in list(self.servers.values()): if server.read_timed_out(): |
