jacinle.comm.distrib.controller#

Classes

`BroadcastMessage`	BroadcastMessage(from_identifier, payload)
`ControlMessage`	ControlMessage(sock, identifier, payload, countdown)
`Controller`
`ControllerPeer`	ControllerPeer(info, csock)
`ControllerPipeStorage`
`PipePeer`	PipePeer(addr, port, dsock, pipes, ids)
`UnicastMessage`	UnicastMessage(from_identifier, to_identifier, payload)

Functions

control(pipes)

Class BroadcastMessage

class BroadcastMessage#

Bases: tuple

BroadcastMessage(from_identifier, payload)

__add__(value, /)#: Return self+value.

__init__()#

__mul__(value, /)#: Return self*value.

static __new__(_cls, from_identifier, payload)#: Create new instance of BroadcastMessage(from_identifier, payload)

count(value, /)#: Return number of occurrences of value.

index(value, start=0, stop=9223372036854775807, /)#

Return first index of value.

Raises ValueError if the value is not present.

from_identifier#: Alias for field number 0

payload#: Alias for field number 1

Class ControlMessage

class ControlMessage#

Bases: tuple

ControlMessage(sock, identifier, payload, countdown)

__add__(value, /)#: Return self+value.

__init__()#

__mul__(value, /)#: Return self*value.

static __new__(_cls, sock, identifier, payload, countdown)#: Create new instance of ControlMessage(sock, identifier, payload, countdown)

count(value, /)#: Return number of occurrences of value.

index(value, start=0, stop=9223372036854775807, /)#

Return first index of value.

Raises ValueError if the value is not present.

countdown#: Alias for field number 3

identifier#: Alias for field number 1

payload#: Alias for field number 2

sock#: Alias for field number 0

Class Controller

class Controller[source]#

Bases: object

__init__()[source]#

__new__(**kwargs)#

close_socket(sock)[source]#

finalize()[source]#

initialize(pipes=None)[source]#

socket(socket_type)[source]#

Class ControllerPeer

class ControllerPeer#

Bases: tuple

ControllerPeer(info, csock)

__add__(value, /)#: Return self+value.

__init__()#

__mul__(value, /)#: Return self*value.

static __new__(_cls, info, csock)#: Create new instance of ControllerPeer(info, csock)

count(value, /)#: Return number of occurrences of value.

index(value, start=0, stop=9223372036854775807, /)#

Return first index of value.

Raises ValueError if the value is not present.

csock#: Alias for field number 1

info#: Alias for field number 0

Class ControllerPipeStorage

class ControllerPipeStorage[source]#

Bases: defaultdict

__init__()[source]#

copy() → a shallow copy of D.#

filter_notempty(name)[source]#

filter_notfull(name)[source]#

static fn_filter_notempty(pipe)[source]#

static fn_filter_notfull(pipe)[source]#

pipe_info()[source]#

put(pipe)[source]#

default_factory#: Factory for default value called by __missing__().

Class PipePeer

class PipePeer#

Bases: tuple

PipePeer(addr, port, dsock, pipes, ids)

__add__(value, /)#: Return self+value.

__init__()#

__mul__(value, /)#: Return self*value.

static __new__(_cls, addr, port, dsock, pipes, ids)#: Create new instance of PipePeer(addr, port, dsock, pipes, ids)

count(value, /)#: Return number of occurrences of value.

index(value, start=0, stop=9223372036854775807, /)#

Return first index of value.

Raises ValueError if the value is not present.

addr#: Alias for field number 0

dsock#: Alias for field number 2

ids#: Alias for field number 4

pipes#: Alias for field number 3

port#: Alias for field number 1

Class UnicastMessage

class UnicastMessage#

Bases: tuple

UnicastMessage(from_identifier, to_identifier, payload)

__add__(value, /)#: Return self+value.

__init__()#

__mul__(value, /)#: Return self*value.

static __new__(_cls, from_identifier, to_identifier, payload)#: Create new instance of UnicastMessage(from_identifier, to_identifier, payload)

count(value, /)#: Return number of occurrences of value.

index(value, start=0, stop=9223372036854775807, /)#

Return first index of value.

Raises ValueError if the value is not present.

from_identifier#: Alias for field number 0

payload#: Alias for field number 2

to_identifier#: Alias for field number 1

Functions

control(pipes)[source]#