reactor: Fix typo
Signed-off-by: Konstantin Vogel <konstantin.vogel@gmx.net>
This commit is contained in:
parent
136283bd14
commit
0d5b96a601
|
@ -240,7 +240,7 @@ class SelectReactor:
|
||||||
# File descriptors
|
# File descriptors
|
||||||
def register_fd(self, fd, read_callback, write_callback=None):
|
def register_fd(self, fd, read_callback, write_callback=None):
|
||||||
file_handler = ReactorFileHandler(fd, read_callback, write_callback)
|
file_handler = ReactorFileHandler(fd, read_callback, write_callback)
|
||||||
self.set_fd_wake(file_handle, True, False)
|
self.set_fd_wake(file_handler, True, False)
|
||||||
return file_handler
|
return file_handler
|
||||||
def unregister_fd(self, file_handler):
|
def unregister_fd(self, file_handler):
|
||||||
if file_handler in self._read_fds:
|
if file_handler in self._read_fds:
|
||||||
|
@ -366,7 +366,7 @@ class EPollReactor(SelectReactor):
|
||||||
def register_fd(self, fd, read_callback, write_callback=None):
|
def register_fd(self, fd, read_callback, write_callback=None):
|
||||||
file_handler = ReactorFileHandler(fd, read_callback, write_callback)
|
file_handler = ReactorFileHandler(fd, read_callback, write_callback)
|
||||||
fds = self._fds.copy()
|
fds = self._fds.copy()
|
||||||
fds[fd] = callback
|
fds[fd] = read_callback
|
||||||
self._fds = fds
|
self._fds = fds
|
||||||
self._epoll.register(fd, select.EPOLLIN | select.EPOLLHUP)
|
self._epoll.register(fd, select.EPOLLIN | select.EPOLLHUP)
|
||||||
return file_handler
|
return file_handler
|
||||||
|
|
Loading…
Reference in New Issue