Distributed
1.0
▾ distributed
▸ actor
▸ asyncio
▸ batched
▸ bokeh
▸ cfexecutor
▸ cli
▸ client
▾ comm
▸ addressing
▸ core
▸ inproc
▸ registry
▾ tcp
class
BaseTCPBackend
class
BaseTCPConnector
class
BaseTCPListener
class
RequireEncryptionMixin
class
TCP
class
TCPBackend
class
TCPConnector
class
TCPListener
class
TLS
class
TLSBackend
class
TLSConnector
class
TLSListener
▸ tests
▸ ucx
▸ utils
▸ compatibility
▸ config
▸ core
▸ counter
▸ dashboard
▸ deploy
▸ diagnostics
▸ diskutils
▸ event
▸ http
▸ lock
▸ locket
▸ metrics
▸ nanny
▸ node
▸ preloading
▸ process
▸ proctitle
▸ profile
▸ protocol
▸ publish
▸ pubsub
▸ pytest_resourceleaks
▸ queues
▸ recreate_exceptions
▸ scheduler
▸ security
▸ semaphore
▸ sizeof
▸ stealing
▸ system
▸ system_monitor
▸ tests
▸ threadpoolexecutor
▸ utils
▸ utils_comm
▸ utils_perf
▸ utils_test
▸ variable
▸ versions
▸ worker
▸ worker_client
Module tcp
distributed
.
comm
.
tcp
source
link
Classes
class
BaseTCPBackend
class
BaseTCPConnector
class
BaseTCPListener
class
RequireEncryptionMixin
class
TCP
An established communication based on an underlying Tornado IOStream.
class
TCPBackend
class
TCPConnector
class
TCPListener
class
TLS
A TLS-specific version of TCP.
class
TLSBackend
class
TLSConnector
class
TLSListener
Functions
▷
def
convert_stream_closed_error
(
obj, exc
)
Re-raise StreamClosedError as CommClosedError.
source
link
▷
def
get_stream_address
(
comm
)
Get a stream's local address.
source
link
▷
def
set_tcp_timeout
(
comm
)
Set kernel-level TCP timeout on the stream.
source
link
Generated by
nedoc
v0.9 at 2020-12-29 14:05