twisted.internet.process.ProcessReader

Package twisted :: Package internet :: Module process :: Class ProcessReader

Class ProcessReader

 Ephemeral --+    
             |    
    Logger --+    
             |    
FileDescriptor --+
                 |
                ProcessReader

ProcessReader

I am a selectable representation of a process's output pipe, such as stdout and stderr.

Method Summary
	`__init__(self, reactor, proc, name, fileno)` Initialize, specifying a process to connect to.
	`connectionLost(self, reason)` Close my end of the pipe, signal the Process (which signals the ProcessProtocol).
	`dataReceived(self, data)`
	`doRead(self)` This is called when the pipe becomes readable.
	`fileno(self)` Return the fileno() of my process's stderr.
	`writeSomeData(self, data)` Write as much as possible of the given data, immediately.
Inherited from FileDescriptor
	`_postLoseConnection(self)` Called after a loseConnection(), when all data has been written.
	`doWrite(self)` Called when data is available for writing.
	`loseConnection(self)` Close the connection at the next available opportunity.
	`pauseProducing(self)`
	`registerProducer(self, producer, streaming)` Register to receive data from a producer.
	`resumeProducing(self)`
	`startReading(self)` Start waiting for read availability.
	`startWriting(self)` Start waiting for write availability.
	`stopConsuming(self)` Stop consuming data.
	`stopProducing(self)`
	`stopReading(self)` Stop waiting for read availability.
	`stopWriting(self)` Stop waiting for write availability.
	`unregisterProducer(self)` Stop consuming data from a producer, without disconnecting.
	`write(self, data)` Reliably write some data.
	`writeSequence(self, iovec)`
Inherited from Logger
	`logPrefix(self)` Override this method to insert custom logging behavior.
Inherited from Ephemeral
	`__getstate__(self)`
	`__setstate__(self, state)`

Class Variable Summary
Inherited from FileDescriptor
`tuple`	`__implements__` = `(<class twisted.internet.interfaces.IPr...`
`int`	`bufferSize` = 65536
`int`	`connected` = 0
`str`	`dataBuffer` = `''`
`int`	`disconnected` = 0
`int`	`disconnecting` = 0
`int`	`offset` = 0
`NoneType`	`producer` = None
`int`	`producerPaused` = 0
`int`	`streamingProducer` = 0

Method Details

init(self, reactor, proc, name, fileno)
(Constructor)

Initialize, specifying a process to connect to.

Overrides:: twisted.internet.abstract.FileDescriptor.__init__

connectionLost(self, reason)

Close my end of the pipe, signal the Process (which signals the ProcessProtocol).

Overrides:: twisted.internet.abstract.FileDescriptor.connectionLost

doRead(self)

This is called when the pipe becomes readable.

fileno(self)

Return the fileno() of my process's stderr.

Overrides:: twisted.internet.abstract.FileDescriptor.fileno

writeSomeData(self, data)

Write as much as possible of the given data, immediately.

This is called to invoke the lower-level writing functionality, such as a socket's send() method, or a file's write(); this method returns an integer. If positive, it is the number of bytes written; if negative, it indicates the connection was lost.

Overrides:: twisted.internet.abstract.FileDescriptor.writeSomeData (inherited documentation)

Generated by Epydoc 2.0 on Sat May 15 20:08:17 2004

http://epydoc.sf.net