Package qpid :: Package messaging :: Module driver :: Class Driver

[frames] | no frames]

classobj Driver

source code

Instance Methods

__init__(self, connection)

source code

wakeup(self)

source code

start(self)

source code

stop(self)

source code

fileno(self)

source code

reading(self)
Called by the Selector I/O thread to determine if the driver needs to wait on the arrival of network data (call self.readable() callback)

source code

writing(self)
Called by the Selector I/O thread to determine if it should block waiting for output bandwidth (call the self.writeable() callback)

source code

timing(self)
Called by the Selector I/O thread to determine if it should wake up the driver (call the timeout() callback

source code

abort(self, exc, info)
Called if the Selector I/O thread hits an unrecoverable error and fails.

source code

readable(self)

source code

close_engine(self, e=None)

source code

update_status(self)

source code

st_closed(self)

source code

st_open(self)

source code

writeable(self)

source code

timeout(self)

source code

schedule(self)

source code

dispatch(self)

source code

connect(self)

source code

Method Details

wakeup(self)

source code

Decorators:

@synchronized

reading(self)

source code

Called by the Selector I/O thread to determine if the driver needs to wait on the arrival of network data (call self.readable() callback)

Decorators:

@synchronized

writing(self)

source code

Called by the Selector I/O thread to determine if it should block waiting for output bandwidth (call the self.writeable() callback)

Decorators:

@synchronized

timing(self)

source code

Called by the Selector I/O thread to determine if it should wake up the driver (call the timeout() callback

Decorators:

@synchronized

abort(self, exc, info)

source code

Called if the Selector I/O thread hits an unrecoverable error and fails.

Decorators:

@synchronized

readable(self)

source code

Decorators:

@synchronized

writeable(self)

source code

Decorators:

@synchronized

timeout(self)

source code

Decorators:

@synchronized