class twisted.internet.tcp.Port(base.BasePort, _SocketCloser): (source)
Known subclasses: twisted.internet.ssl.Port, twisted.internet.unix.Port
A TCP server port, listening for connections.
When a connection is accepted, this will call a factory's buildProtocol with the incoming address as an argument, according to the specification described in twisted.internet.interfaces.IProtocolFactory.
If you wish to change the sort of transport that will be used, the transport attribute will be called with the signature expected for Server.__init__, so it can be replaced.
| Instance Variable | deferred | a deferred created when stopListening is called, and that will fire when connection is lost. This is not to be used it directly: prefer the deferred returned by stopListening instead. |
| Instance Variable | disconnecting | flag indicating that the stopListening method has been called and that no connections should be accepted anymore. |
| Instance Variable | connected | flag set once the listen has successfully been called on the socket. |
| Instance Variable | sessionno | Undocumented |
| Instance Variable | interface | Undocumented |
| Instance Variable | backlog | Undocumented |
| Method | __init__ | Initialize with a numeric port to listen on. |
| Instance Variable | port | Undocumented |
| Instance Variable | factory | Undocumented |
| Instance Variable | addressFamily | Undocumented |
| Method | __repr__ | Undocumented |
| Method | createInternetSocket | Undocumented |
| Method | startListening | Create and bind my socket, and begin listening on it. |
| Instance Variable | socket | Undocumented |
| Instance Variable | numberAccepts | Undocumented |
| Method | doRead | Called when my socket is ready for reading. |
| Method | loseConnection | Stop accepting connections on this port. |
| Method | connectionLost | Cleans up the socket. |
| Method | logPrefix | Returns the name of my class, to prefix log entries with. |
| Method | getHost | Return an IPv4Address or IPv6Address indicating the listening address of this port. |
| Instance Variable | _type | A string describing the connections which will be created by this port. Normally this is "TCP", since this is a TCP port, but when the TLS implementation re-uses this class it overrides the value with "TLS". Only used for logging. |
| Instance Variable | _preexistingSocket | If not None, a socket.socket instance which was created and initialized outside of the reactor and will be used to listen for connections (instead of a new socket being created by this Port). |
| Instance Variable | _realPortNumber | Undocumented |
| Class Variable | _logger | Undocumented |
| Instance Variable | _addressType | Undocumented |
| Class Method | _fromListeningDescriptor | Create a new Port based on an existing listening SOCK_STREAM socket. |
| Instance Variable | _shouldShutdown | Undocumented |
| Method | _buildAddr | Undocumented |
| Method | _logConnectionLostMsg | Log message for closing port |
Inherited from BasePort:
| Class Variable | socketType | Undocumented |
| Method | doWrite | Raises a RuntimeError |
Inherited from FileDescriptor (via BasePort):
| Instance Variable | disconnected | Undocumented |
| Instance Variable | dataBuffer | Undocumented |
| Instance Variable | offset | Undocumented |
| Class Variable | SEND_LIMIT | Undocumented |
| Instance Variable | reactor | Undocumented |
| Instance Variable | producer | Undocumented |
| Method | writeSomeData | Write as much as possible of the given data, immediately. |
| Instance Variable | producerPaused | Undocumented |
| Method | writeConnectionLost | Undocumented |
| Method | readConnectionLost | Undocumented |
| Method | getPeer | Undocumented |
| Method | write | Reliably write some data. |
| Method | writeSequence | Reliably write a sequence of data. |
| Method | loseWriteConnection | Undocumented |
| Method | stopReading | Stop waiting for read availability. |
| Method | stopWriting | Stop waiting for write availability. |
| Method | startReading | Start waiting for read availability. |
| Method | startWriting | Start waiting for write availability. |
| Class Variable | bufferSize | Undocumented |
| Method | stopConsuming | Stop consuming data. |
| Method | resumeProducing | Undocumented |
| Method | pauseProducing | Undocumented |
| Method | stopProducing | Undocumented |
| Method | fileno | File Descriptor number for select(). |
| Instance Variable | _writeDisconnecting | Undocumented |
| Instance Variable | _writeDisconnected | Undocumented |
| Instance Variable | _tempDataBuffer | Undocumented |
| Instance Variable | _tempDataLen | Undocumented |
| Method | _postLoseConnection | Called after a loseConnection(), when all data has been written. |
| Method | _closeWriteConnection | Undocumented |
| Method | _isSendBufferFull | Determine whether the user-space send buffer for this transport is full or not. |
| Method | _maybePauseProducer | Possibly pause a producer, if there is one and the send buffer is full. |
Inherited from _ConsumerMixin (via BasePort, FileDescriptor):
| Instance Variable | streamingProducer | bool or int |
| Method | registerProducer | Register to receive data from a producer. |
| Method | unregisterProducer | Stop consuming data from a producer, without disconnecting. |
Inherited from _LogOwner (via BasePort, FileDescriptor):
| Method | _getLogPrefix | Determine the log prefix to use for messages related to applicationObject, which may or may not be an interfaces.ILoggingContext provider. |
Inherited from _SocketCloser:
| Method | _closeSocket | Undocumented |
stopListening is called, and that will fire when connection is lost. This is not to be used it directly: prefer the deferred returned by stopListening instead.defer.Deferred)
stopListening method has been called and that no connections should be accepted anymore.bool)
bool)
"TCP", since this is a TCP port, but when the TLS implementation re-uses this class it overrides the value with "TLS". Only used for logging.str)
None, a socket.socket instance which was created and initialized outside of the reactor and will be used to listen for connections (instead of a new socket being created by this Port).Initialize with a numeric port to listen on.
Create a new Port based on an existing listening SOCK_STREAM socket.
Arguments are the same as to Port.__init__, except where noted.
| Parameters | reactor | Undocumented |
| fd | An integer file descriptor associated with a listening socket. The socket must be in non-blocking mode. Any additional attributes desired, such as FD_CLOEXEC, must also be set already. | |
| addressFamily | The address family (sometimes called domain) of the existing socket. For example, socket.AF_INET. | |
| factory | Undocumented | |
| Returns | A new instance of cls wrapping the socket given by fd. | |
Undocumented
| Returns | Undocumented (type: str) | |
Create and bind my socket, and begin listening on it.
This is called on unserialization, and must be called after creating a server to begin listening on the specified port.
Called when my socket is ready for reading.
This accepts a connection and calls self.protocol() to handle the wire-level protocol.
Stop accepting connections on this port.
This will shut down the socket and call self.connectionLost(). It returns a deferred which will fire successfully when the port is actually closed, or with a failure if an error occurs shutting down.
Log message for closing port
Cleans up the socket.
Return an IPv4Address or IPv6Address indicating the listening address of this port.