twisted.internet.base.ThreadedResolver

class documentation

class ThreadedResolver: (source)

Known subclasses: twisted.names.client.ThreadedResolver

Implements interfaces: twisted.internet.interfaces.IResolverSimple

View In Hierarchy

ThreadedResolver uses a reactor, a threadpool, and socket.gethostbyname to perform name lookups without blocking the reactor thread. It also supports timeouts indepedently from whatever timeout logic socket.gethostbyname might have.
Method __init__ Undocumented
Method get​Host​By​Name See twisted.internet.interfaces.IResolverSimple.getHostByName.
Instance Variable reactor The reactor the threadpool of which will be used to call socket.gethostbyname and the I/O thread of which the result will be delivered.
Method _check​Timeout Undocumented
Method _cleanup Undocumented
Method _fail Undocumented
Instance Variable _running​Queries Undocumented
def __init__(self, reactor): (source)
overridden in twisted.names.client.ThreadedResolver

Undocumented

Parameters
reactor:ReactorBaseUndocumented
def getHostByName(self, name, timeout=(1, 3, 11, 45)): (source)
from twisted.internet.interfaces.IResolverSimple

See twisted.internet.interfaces.IResolverSimple.getHostByName.

Note that the elements of timeout are summed and the result is used as a timeout for the lookup. Any intermediate timeout or retry logic is left up to the platform via socket.gethostbyname.

Parameters
name:strUndocumented
timeout:Sequence[int]Undocumented
Returns
DeferredUndocumented
reactor = (source)
The reactor the threadpool of which will be used to call socket.gethostbyname and the I/O thread of which the result will be delivered.
def _checkTimeout(self, result, name, lookupDeferred): (source)

Undocumented

Parameters
result:objectUndocumented
name:strUndocumented
lookup​Deferred:DeferredUndocumented
def _cleanup(self, name, lookupDeferred): (source)

Undocumented

Parameters
name:strUndocumented
lookup​Deferred:DeferredUndocumented
def _fail(self, name, err): (source)

Undocumented

Parameters
name:strUndocumented
err:strUndocumented
Returns
FailureUndocumented
_runningQueries: Dict[Deferred, Tuple[Deferred, IDelayedCall]] = (source)

Undocumented