Trees | Index | Help |
---|
Package flumotion :: Package twisted :: Module fdserver :: Class FDClient |
|
Ephemeral
--+ |Logger
--+ |object
--+ |FileDescriptor
--+ |_SocketCloser
--+ |Connection
--+ |BaseClient
--+ |Client
--+ | FDClient
Method Summary | |
---|---|
Calls self.protocol.dataReceived with all available data. | |
Inherited from Client | |
| |
| |
| |
Inherited from BaseClient | |
See abstract.FileDescriptor.connectionLost(). | |
(internal) Create a non-blocking socket using self.addressFamily, self.socketType. | |
I connect the socket. | |
Generic method called when the attemps to connect failed. | |
| |
| |
Stop attempt to connect. | |
Inherited from Connection | |
Return the socket for this connection. | |
| |
| |
Return the prefix to log with when I own the logging thread. | |
| |
| |
| |
Connection.writeSomeData(data) -> #of bytes written | CONNECTION_LOST This writes as much data as possible to the socket and returns either the number of bytes read (which is positive) or a connection error code (which is negative) | |
Inherited from FileDescriptor | |
Called when data can be written. | |
File Descriptor number for select(). | |
Close the connection at the next available opportunity. | |
| |
| |
Register to receive data from a producer. | |
| |
Start waiting for read availability. | |
Start waiting for write availability. | |
Stop consuming data. | |
| |
Stop waiting for read availability. | |
Stop waiting for write availability. | |
Stop consuming data from a producer, without disconnecting. | |
Reliably write some data. | |
| |
Reliably write a sequence of data. | |
Inherited from Ephemeral | |
| |
| |
Inherited from object | |
x.__delattr__('name') <==> del x.name | |
x.__getattribute__('name') <==> x.name | |
x.__hash__() <==> hash(x) | |
T.__new__(S, ...) -> a new object with type S, a subtype of T | |
helper for pickle | |
helper for pickle | |
x.__repr__() <==> repr(x) | |
x.__setattr__('name', value) <==> x.name = value | |
x.__str__() <==> str(x) |
Class Variable Summary | |
---|---|
Inherited from Client | |
int |
addressFamily = 1 |
int |
socketType = 1 |
Inherited from BaseClient | |
Implements |
__implemented__ = <implementedBy twisted.internet.tcp.Ba...
|
ClassProvides |
__provides__ = <zope.interface.declarations.ClassProvide...
|
Inherited from Connection | |
str |
logstr = 'Uninitialized'
|
int |
TLS = 0 |
Inherited from FileDescriptor | |
int |
bufferSize = 65536 |
int |
connected = 0 |
str |
dataBuffer = ''
|
int |
disconnected = 0 |
int |
disconnecting = 0 |
int |
offset = 0 |
NoneType |
producer = None |
int |
producerPaused = 0 |
int |
SEND_LIMIT = 131072 |
int |
streamingProducer = 0 |
Inherited from Logger | |
ClassProvides |
__providedBy__ = <zope.interface.declarations.ClassProvi...
|
Method Details |
---|
doRead(self)Calls self.protocol.dataReceived with all available data. This reads up to self.bufferSize bytes of data from its socket, then calls self.dataReceived(data) to process it. If the connection is not lost through an error in the physical recv(), this function will return the result of the dataReceived call.
|
Trees | Index | Help |
---|
Generated by Epydoc 2.1 on Fri Feb 2 11:29:21 2007 | http://epydoc.sf.net |