Class t.i.i.a.ConnectedSocket(log.Logger, styles.Ephemeral, object):

Part of twisted.internet.iocpreactor.abstract View Source View In Hierarchy

Known subclasses: twisted.internet.iocpreactor.client.ClientSocket, twisted.internet.iocpreactor.server.ServerSocket

Implements interfaces: twisted.internet.interfaces.IConsumer, twisted.internet.interfaces.IProducer, twisted.internet.interfaces.ITransport

Undocumented

Split Table into Classes Show Methods in One Table

Line # Kind Name Docs
30 Method __init__ Undocumented
46 Method addBufferCallback Undocumented
49 Method removeBufferCallback Undocumented
52 Method callBufferHandlers Undocumented
56 Method handle_connected_write Undocumented
69 Method handle_disconnected_write Undocumented
72 Method writeSequence Write a list of strings to the physical connection.
81 Method handle_connected_loseConnection Undocumented
89 Method handle_disconnecting_loseConnection Undocumented
98 Method handle_connected_shutdown Undocumented
109 Method connectionLost Undocumented
139 Method startReading Undocumented
154 Method stopReading Undocumented
157 Method handle_connected_readDone Undocumented
164 Method handle_disconnecting_readDone Undocumented
167 Method handle_connected_readErr Undocumented
173 Method handle_disconnected_readErr Undocumented
176 Method handle_disconnected_readDone Undocumented
179 Method startWriting Undocumented
190 Method stopWriting Undocumented
193 Method handle_connected_writeDone Undocumented
207 Method handle_connected_writeErr Undocumented
212 Method handle_disconnected_writeErr Undocumented
215 Method handle_disconnected_writeDone Undocumented
220 Method registerProducer Register to receive data from a producer.
234 Method milkProducer Undocumented
239 Method stfuProducer Undocumented
243 Method unregisterProducer Stop consuming data from a producer, without disconnecting.
248 Method stopConsuming Undocumented
254 Method resumeProducing Undocumented
257 Method pauseProducing Undocumented
260 Method stopProducing Stop producing data.
263 Method __repr__ Undocumented
266 Method logPrefix Override this method to insert custom logging behavior. Its

Inherited from Ephemeral:

Line # Kind Name Docs
124 Method __getstate__ Undocumented
131 Method __setstate__ Undocumented
Line # Kind Name Docs
124 Method __getstate__ Undocumented
30 Method __init__ Undocumented
263 Method __repr__ Undocumented
131 Method __setstate__ Undocumented
75 Method _cbDisconnecting Undocumented
94 Method _cbWriteShutdown Undocumented
46 Method addBufferCallback Undocumented
52 Method callBufferHandlers Undocumented
109 Method connectionLost Undocumented
81 Method handle_connected_loseConnection Undocumented
157 Method handle_connected_readDone Undocumented
167 Method handle_connected_readErr Undocumented
98 Method handle_connected_shutdown Undocumented
56 Method handle_connected_write Undocumented
193 Method handle_connected_writeDone Undocumented
207 Method handle_connected_writeErr Undocumented
176 Method handle_disconnected_readDone Undocumented
173 Method handle_disconnected_readErr Undocumented
69 Method handle_disconnected_write Undocumented
215 Method handle_disconnected_writeDone Undocumented
212 Method handle_disconnected_writeErr Undocumented
89 Method handle_disconnecting_loseConnection Undocumented
164 Method handle_disconnecting_readDone Undocumented
266 Method logPrefix Override this method to insert custom logging behavior. Its
234 Method milkProducer Undocumented
257 Method pauseProducing Undocumented
220 Method registerProducer Register to receive data from a producer.
49 Method removeBufferCallback Undocumented
254 Method resumeProducing Undocumented
139 Method startReading Undocumented
179 Method startWriting Undocumented
239 Method stfuProducer Undocumented
248 Method stopConsuming Undocumented
260 Method stopProducing Stop producing data.
154 Method stopReading Undocumented
190 Method stopWriting Undocumented
243 Method unregisterProducer Stop consuming data from a producer, without disconnecting.
72 Method writeSequence Write a list of strings to the physical connection.
def __init__(self, socket, protocol, sockfactory): (source)
Undocumented
def addBufferCallback(self, handler, event): (source)
Undocumented
def removeBufferCallback(self, handler, event): (source)
Undocumented
def callBufferHandlers(self, event, *a, **kw): (source)
Undocumented
def handle_connected_write(self, data): (source)
Undocumented
def handle_disconnected_write(self, data): (source)
Undocumented
def writeSequence(self, iovec): (source)

Write a list of strings to the physical connection.

If possible, make sure that all of the data is written to the socket at once, without first copying it all into a single string.
def handle_connected_loseConnection(self): (source)
Undocumented
def handle_disconnecting_loseConnection(self): (source)
Undocumented
def handle_connected_shutdown(self, write=False, read=False): (source)
Undocumented
def connectionLost(self, reason): (source)
Undocumented
def startReading(self): (source)
Undocumented
def stopReading(self): (source)
Undocumented
def handle_connected_readDone(self, bytes): (source)
Undocumented
def handle_disconnecting_readDone(self, bytes): (source)
Undocumented
def handle_connected_readErr(self, ret, bytes): (source)
Undocumented
def handle_disconnected_readErr(self, ret, bytes): (source)
Undocumented
def handle_disconnected_readDone(self, bytes): (source)
Undocumented
def startWriting(self): (source)
Undocumented
def stopWriting(self): (source)
Undocumented
def handle_connected_writeDone(self, bytes): (source)
Undocumented
def handle_connected_writeErr(self, ret, bytes): (source)
Undocumented
def handle_disconnected_writeErr(self, ret, bytes): (source)
Undocumented
def handle_disconnected_writeDone(self, bytes): (source)
Undocumented
def registerProducer(self, producer, streaming): (source)

Register to receive data from a producer.

This sets self to be a consumer for a producer. When this object runs out of data (as when a send(2) call on a socket succeeds in moving the last data from a userspace buffer into a kernelspace buffer), it will ask the producer to resumeProducing().

For IPullProducer providers, resumeProducing will be called once each time data is required.

For IPushProducer providers, pauseProducing will be called whenever the write buffer fills up and resumeProducing will only be called when it empties.
Parametersproducer (type: IProducer provider )
streamingTrue if producer provides IPushProducer, False if producer provides IPullProducer. (type: bool )
ReturnsNone
def milkProducer(self): (source)
Undocumented
def stfuProducer(self): (source)
Undocumented
def unregisterProducer(self): (source)
Stop consuming data from a producer, without disconnecting.
def stopConsuming(self): (source)
Undocumented
def resumeProducing(self): (source)
Undocumented
def pauseProducing(self): (source)
Undocumented
def stopProducing(self): (source)

Stop producing data.

This tells a producer that its consumer has died, so it must stop producing data for good.
def __repr__(self): (source)
Undocumented
def logPrefix(self): (source)
Override this method to insert custom logging behavior. Its return value will be inserted in front of every line. It may be called more times than the number of output lines.
API Documentation for Twisted, generated by pydoctor at 2008-02-28 08:53:09.