Trees | Index | Help |
---|
Package twisted :: Package internet :: Module tcp :: Class BaseClient |
|
Ephemeral
--+ |Logger
--+ |object
--+ |FileDescriptor
--+ |_SocketCloser
--+ |Connection
--+ | BaseClient
Client
Method Summary | |
---|---|
See abstract.FileDescriptor.connectionLost(). | |
(internal) Create a non-blocking socket using self.addressFamily, self.socketType. | |
I connect the socket. | |
failIfNotConnected(self,
err)
| |
resolveAddress(self)
| |
startTLS(self,
ctx,
client)
| |
Stop attempt to connect. | |
_connectDone(self)
| |
Called by base classes to continue to next stage of initialization. | |
_setRealAddress(self,
address)
| |
Inherited from Connection | |
| |
Calls self.protocol.dataReceived with all available data. | |
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 is available for writing. | |
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. | |
| |
| |
Called after a loseConnection(), when all data has been written. | |
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) | |
Inherited from _SocketCloser | |
|
Class Variable Summary | |
---|---|
Implements |
__implemented__ = <implementedBy twisted.internet.tcp.Ba...
|
ClassProvides |
__provides__ = <zope.interface.declarations.ClassProvide...
|
int |
addressFamily = 2 |
int |
socketType = 1 |
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 |
bool |
_writeDisconnected = False
|
bool |
_writeDisconnecting = False
|
Inherited from Logger | |
ClassProvides |
__providedBy__ = <zope.interface.declarations.ClassProvi...
|
Inherited from _SocketCloser | |
str |
_socketShutdownMethod = 'shutdown'
|
Method Details |
---|
connectionLost(self, reason)See abstract.FileDescriptor.connectionLost().
|
createInternetSocket(self)(internal) Create a non-blocking socket using self.addressFamily, self.socketType. |
doConnect(self)I connect the socket. Then, call the protocol's makeConnection, and start waiting for data. |
stopConnecting(self)Stop attempt to connect. |
_finishInit(self, whenDone, skt, error, reactor)Called by base classes to continue to next stage of initialization. |
Class Variable Details |
---|
__implemented__
|
__provides__
|
addressFamily
|
socketType
|
Trees | Index | Help |
---|
Generated by Epydoc 2.1 on Sat Apr 14 13:16:51 2007 | http://epydoc.sf.net |