twisted.internet.unix.ConnectedDatagramPort

class documentation

class ConnectedDatagramPort(DatagramPort): (source)

A connected datagram UNIX socket.

Method	`__init__`	Initialize with address to listen on.
Method	`connectionFailed`	Called when a connection fails. Stop listening on the socket.
Method	`doRead`	Called when my socket is ready for reading.
Method	`getPeer`	Get the remote address of this connection.
Method	`startListening`	Create and bind my socket, and begin listening on it.
Method	`write`	Write a datagram.
Instance Variable	`remoteaddr`	Undocumented

Inherited from DatagramPort:

Method	`__repr__`	Undocumented
Method	`connectionLost`	Cleans up my socket.
Method	`setLogStr`	Initialize the `logstr` attribute to be used by `logPrefix`.
Instance Variable	`connected`	Undocumented
Instance Variable	`logstr`	Undocumented
Instance Variable	`mode`	Undocumented
Instance Variable	`socket`	Undocumented
Method	`_bindSocket`	Prepare and assign a `socket.socket` instance to `self.socket`.

Inherited from _UNIXPort (via DatagramPort):

Method getHost Returns a UNIXAddress.

Inherited from Port (via DatagramPort):

Method	`connect`	'Connect' to remote server.
Method	`getBroadcastAllowed`	Checks if broadcast is currently allowed on this port.
Method	`getHandle`	Return a socket object.
Method	`getHost`	Return the local address of the UDP connection
Method	`logPrefix`	Return the prefix to log with.
Method	`loseConnection`	Close the connection at the next available opportunity.
Method	`setBroadcastAllowed`	Set whether this port may broadcast. This is disabled by default.
Method	`stopListening`	Stop listening on this port.
Method	`writeSequence`	Write a datagram constructed from an iterable of `bytes`.
Instance Variable	`addressFamily`	`socket.AF_INET` or `socket.AF_INET6`, depending on whether this port is listening on an IPv4 address or an IPv6 address.
Instance Variable	`d`	Undocumented
Instance Variable	`interface`	Undocumented
Instance Variable	`maxPacketSize`	Undocumented
Instance Variable	`maxThroughput`	Maximum number of bytes read in one event loop iteration.
Instance Variable	`port`	Undocumented
Instance Variable	`protocol`	Undocumented
Class Method	`_fromListeningDescriptor`	Create a new `Port` based on an existing listening SOCK_DGRAM socket.
Method	`_connectToProtocol`	Undocumented
Method	`_loseConnection`	Undocumented
Method	`_setAddressFamily`	Resolve address family for the socket.
Instance Variable	`_connectedAddr`	Undocumented
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`	Actual port number being listened on. The value will be `None` until this `Port` is listening.

Inherited from BasePort (via DatagramPort, Port):

Method	`createInternetSocket`	Undocumented
Method	`doWrite`	Raises a RuntimeError
Class Variable	`socketType`	Undocumented

Inherited from FileDescriptor (via DatagramPort, Port, BasePort):

Method	`fileno`	File Descriptor number for select().
Method	`loseWriteConnection`	Undocumented
Method	`pauseProducing`	Pause producing data.
Method	`readConnectionLost`	Indicates read connection was lost.
Method	`resumeProducing`	Resume producing data.
Method	`startReading`	Start waiting for read availability.
Method	`startWriting`	Start waiting for write availability.
Method	`stopConsuming`	Stop consuming data.
Method	`stopProducing`	Stop producing data.
Method	`stopReading`	Stop waiting for read availability.
Method	`stopWriting`	Stop waiting for write availability.
Method	`writeConnectionLost`	Indicates write connection was lost.
Method	`writeSomeData`	Write as much as possible of the given data, immediately.
Constant	`SEND_LIMIT`	Undocumented
Class Variable	`bufferSize`	Undocumented
Class Variable	`disconnecting`	Undocumented
Instance Variable	`dataBuffer`	Undocumented
Instance Variable	`disconnected`	Undocumented
Instance Variable	`offset`	Undocumented
Instance Variable	`producer`	Undocumented
Instance Variable	`producerPaused`	Undocumented
Instance Variable	`reactor`	Undocumented
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.
Method	`_postLoseConnection`	Called after a loseConnection(), when all data has been written.
Class Variable	`_writeDisconnected`	Undocumented
Instance Variable	`_tempDataBuffer`	Undocumented
Instance Variable	`_tempDataLen`	Undocumented
Instance Variable	`_writeDisconnecting`	Undocumented

Inherited from _ConsumerMixin (via DatagramPort, Port, BasePort, FileDescriptor):

Method	`registerProducer`	Register to receive data from a producer.
Method	`unregisterProducer`	Stop consuming data from a producer, without disconnecting.
Instance Variable	`streamingProducer`	`bool` or `int`

Inherited from _LogOwner (via DatagramPort, Port, 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.

def __init__(self, addr, proto, maxPacketSize=8192, mode=438, bindAddress=None, reactor=None): (source)

overrides twisted.internet.unix.DatagramPort.__init__

Initialize with address to listen on.

def connectionFailed(self, reason): (source)

Called when a connection fails. Stop listening on the socket.

Parameters
reason:`Failure`	Why the connection failed.

def doRead(self): (source)

from twisted.internet.interfaces.IReadDescriptor

overrides twisted.internet.udp.Port.doRead

Called when my socket is ready for reading.

def getPeer(self): (source)

from twisted.internet.interfaces.ITransport

overrides twisted.internet.abstract.FileDescriptor.getPeer

Get the remote address of this connection.

Treat this method with caution. It is the unfortunate result of the CGI and Jabber standards, but should not be considered reliable for the usual host of reasons; port forwarding, proxying, firewalls, IP masquerading, etc.

Returns
An `IAddress` provider.

def startListening(self): (source)

from twisted.internet.interfaces.IListeningPort

overrides twisted.internet.udp.Port.startListening

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.

def write(self, data): (source)

from twisted.internet.interfaces.IUNIXDatagramTransport

overrides twisted.internet.unix.DatagramPort.write

Write a datagram.

remoteaddr = (source)

Undocumented