twisted.internet._glibbase.GlibReactorBase(posixbase.PosixReactorBase, posixbase._PollLikeMixin) class documentationtwisted.internet._glibbase
View Source
(View In Hierarchy)
Known subclasses: twisted.internet.gireactor.GIReactor, twisted.internet.gtk2reactor.Gtk2Reactor
Implements interfaces: twisted.internet.interfaces.IReactorFDSet
Base class for GObject event loop reactors.
Notification for I/O events (reads and writes on file descriptors) is done by the gobject-based event loop. File descriptors are registered with gobject with the appropriate flags for read/write/disconnect notification.
Time-based events, the results of callLater and
callFromThread, are handled differently. Rather than
registering each event with gobject, a single gobject timeout is registered
for the earliest scheduled event, the output of
reactor.timeout(). For example, if there are timeouts in 1, 2
and 3.4 seconds, a single timeout is registered for 1 second in the future.
When this timeout is hit, _simulate is called, which calls the
appropriate Twisted-level handlers, and a new timeout is added to gobject
by the _reschedule method.
To handle callFromThread events, we use a custom waker that
calls _simulate whenever it wakes up.
| Method | __init__ | Undocumented |
| Method | input_add | Undocumented |
| Method | addReader | Add a FileDescriptor
for monitoring of data available to read. |
| Method | addWriter | Add a FileDescriptor
for monitoring ability to write data. |
| Method | getReaders | Retrieve the list of current FileDescriptor
monitored for reading. |
| Method | getWriters | Retrieve the list of current FileDescriptor
monitored for writing. |
| Method | removeAll | Remove monitoring for all registered FileDescriptors. |
| Method | removeReader | Stop monitoring the given FileDescriptor
for reading. |
| Method | removeWriter | Stop monitoring the given FileDescriptor
for writing. |
| Method | iterate | One iteration of the event loop, for trial's use. |
| Method | crash | Crash the reactor. |
| Method | stop | Stop the reactor. |
| Method | run | Run the reactor. |
| Method | callLater | Schedule a DelayedCall. |
| Instance Variable | _sources | A dictionary mapping FileDescriptor
instances to GSource handles. |
| Instance Variable | _reads | A set of FileDescriptor
instances currently monitored for reading. |
| Instance Variable | _writes | A set of FileDescriptor
instances currently monitored for writing. |
| Instance Variable | _simtag | A GSource handle for the next simulate
call. |
| Method | _handleSignals | Extend the basic signal handling logic to also support handling SIGCHLD to know when to try to reap child processes. |
| Method | _ioEventCallback | Called by event loop when an I/O event occurs. |
| Method | _add | No summary |
| Method | _remove | Remove monitoring the given FileDescriptor
for either reading or writing. If it's still monitored for the other
operation, we re-register the FileDescriptor
for only that operation. |
| Method | _reschedule | Schedule a glib timeout for _simulate. |
| Method | _simulate | Run timers, and then reschedule glib timeout for next scheduled event. |
Inherited from _PollLikeMixin:
| Method | _doReadOrWrite | fd is available for read or write, do the work and raise errors if necessary. |
Inherited from _PollLikeMixin:
| Method | _doReadOrWrite | fd is available for read or write, do the work and raise errors if necessary. |
Inherited from _PollLikeMixin:
| Method | _doReadOrWrite | fd is available for read or write, do the work and raise errors if necessary. |
Inherited from _PollLikeMixin:
| Method | _doReadOrWrite | fd is available for read or write, do the work and raise errors if necessary. |
Inherited from _PollLikeMixin:
| Method | _doReadOrWrite | fd is available for read or write, do the work and raise errors if necessary. |
Extend the basic signal handling logic to also support handling SIGCHLD to know when to try to reap child processes.
Called by event loop when an I/O event occurs.
Add the given FileDescriptor
for monitoring either for reading or writing. If the file is already
monitored for the other operation, we delete the previous registration and
re-register it for both reading and writing.
Add a FileDescriptor
for monitoring of data available to read.
Remove monitoring the given FileDescriptor
for either reading or writing. If it's still monitored for the other
operation, we re-register the FileDescriptor
for only that operation.
One iteration of the event loop, for trial's use.
This is not used for actual reactor runs.
Run timers, and then reschedule glib timeout for next scheduled event.