aboutsummaryrefslogtreecommitdiffstats
path: root/klippy
diff options
context:
space:
mode:
authorKevin O'Connor <kevin@koconnor.net>2019-06-09 14:38:01 -0400
committerKevin O'Connor <kevin@koconnor.net>2019-06-09 18:44:44 -0400
commitafc10400e342cdd29f362d0f8b03af607b62abda (patch)
tree1b0622d2fe88db025e37f92a9f604841dccbce30 /klippy
parent0546c18d27ba47a336c9be409a8dc9d84d99ed3a (diff)
downloadkutter-afc10400e342cdd29f362d0f8b03af607b62abda.tar.gz
kutter-afc10400e342cdd29f362d0f8b03af607b62abda.tar.xz
kutter-afc10400e342cdd29f362d0f8b03af607b62abda.zip
reactor: Be explicit on which handlers are timer_handler vs file_handler
Signed-off-by: Kevin O'Connor <kevin@koconnor.net>
Diffstat (limited to 'klippy')
-rw-r--r--klippy/reactor.py54
1 files changed, 27 insertions, 27 deletions
diff --git a/klippy/reactor.py b/klippy/reactor.py
index bbb2c27d..4c89b0fe 100644
--- a/klippy/reactor.py
+++ b/klippy/reactor.py
@@ -82,23 +82,23 @@ class SelectReactor:
self._g_dispatch = None
self._greenlets = []
# Timers
- def _note_time(self, t):
- nexttime = t.waketime
+ def _note_time(self, timer_handler):
+ nexttime = timer_handler.waketime
if nexttime < self._next_timer:
self._next_timer = nexttime
- def update_timer(self, t, nexttime):
- t.waketime = nexttime
- self._note_time(t)
+ def update_timer(self, timer_handler, nexttime):
+ timer_handler.waketime = nexttime
+ self._note_time(timer_handler)
def register_timer(self, callback, waketime = NEVER):
- handler = ReactorTimer(callback, waketime)
+ timer_handler = ReactorTimer(callback, waketime)
timers = list(self._timers)
- timers.append(handler)
+ timers.append(timer_handler)
self._timers = timers
- self._note_time(handler)
- return handler
- def unregister_timer(self, handler):
+ self._note_time(timer_handler)
+ return timer_handler
+ def unregister_timer(self, timer_handler):
timers = list(self._timers)
- timers.pop(timers.index(handler))
+ timers.pop(timers.index(timer_handler))
self._timers = timers
def _check_timers(self, eventtime):
if eventtime < self._next_timer:
@@ -180,11 +180,11 @@ class SelectReactor:
return ReactorMutex(self, is_locked)
# File descriptors
def register_fd(self, fd, callback):
- handler = ReactorFileHandler(fd, callback)
- self._fds.append(handler)
- return handler
- def unregister_fd(self, handler):
- self._fds.pop(self._fds.index(handler))
+ file_handler = ReactorFileHandler(fd, callback)
+ self._fds.append(file_handler)
+ return file_handler
+ def unregister_fd(self, file_handler):
+ self._fds.pop(self._fds.index(file_handler))
# Main loop
def _dispatch_loop(self):
self._g_dispatch = g_dispatch = greenlet.getcurrent()
@@ -216,16 +216,16 @@ class PollReactor(SelectReactor):
self._fds = {}
# File descriptors
def register_fd(self, fd, callback):
- handler = ReactorFileHandler(fd, callback)
+ file_handler = ReactorFileHandler(fd, callback)
fds = self._fds.copy()
fds[fd] = callback
self._fds = fds
- self._poll.register(handler, select.POLLIN | select.POLLHUP)
- return handler
- def unregister_fd(self, handler):
- self._poll.unregister(handler)
+ self._poll.register(file_handler, select.POLLIN | select.POLLHUP)
+ return file_handler
+ def unregister_fd(self, file_handler):
+ self._poll.unregister(file_handler)
fds = self._fds.copy()
- del fds[handler.fd]
+ del fds[file_handler.fd]
self._fds = fds
# Main loop
def _dispatch_loop(self):
@@ -250,16 +250,16 @@ class EPollReactor(SelectReactor):
self._fds = {}
# File descriptors
def register_fd(self, fd, callback):
- handler = ReactorFileHandler(fd, callback)
+ file_handler = ReactorFileHandler(fd, callback)
fds = self._fds.copy()
fds[fd] = callback
self._fds = fds
self._epoll.register(fd, select.EPOLLIN | select.EPOLLHUP)
- return handler
- def unregister_fd(self, handler):
- self._epoll.unregister(handler.fd)
+ return file_handler
+ def unregister_fd(self, file_handler):
+ self._epoll.unregister(file_handler.fd)
fds = self._fds.copy()
- del fds[handler.fd]
+ del fds[file_handler.fd]
self._fds = fds
# Main loop
def _dispatch_loop(self):