jacinle.comm package

Submodules

jacinle.comm.broadcast module

class jacinle.comm.broadcast.BroadcastOutputPipe(name, send_qsize=10, mode='tcp')[source]

Bases: object

activate()[source]
conn_info()[source]
finalize()[source]
initialize()[source]
mainloop_send()[source]
send(payload)[source]
class jacinle.comm.broadcast.BroadcastInputPipe(conn_info)[source]

Bases: object

activate()[source]
finalize()[source]
initialize()[source]
recv()[source]
jacinle.comm.broadcast.make_broadcast_pair(name, nr_workers=None, mode='tcp', send_qsize=10)[source]

jacinle.comm.cs module

class jacinle.comm.cs.ServerPipe(name, send_qsize=0, mode='tcp')[source]

Bases: object

activate(tcp_port=None)[source]
conn_info()[source]
dispatcher
finalize()[source]
initialize(tcp_port=None)[source]
mainloop_recv()[source]
mainloop_send()[source]
send(identifier, msg)[source]
class jacinle.comm.cs.ClientPipe(name, conn_info)[source]

Bases: object

activate()[source]
finalize()[source]
identity
initialize()[source]
query(type, inp=None, do_recv=True)[source]
recv()[source]
jacinle.comm.cs.make_cs_pair(name, nr_clients=None, mode='tcp', send_qsize=10)[source]

jacinle.comm.echo module

class jacinle.comm.echo.EchoToPipe(pipe, identifier)[source]

Bases: object

activate()[source]
echo()[source]
finalize()[source]
initialize()[source]
jacinle.comm.echo.echo_from_pipe(pipe)[source]

jacinle.comm.gather module

class jacinle.comm.gather.GatherOutputPipe(conn_info, send_qsize=10)[source]

Bases: object

activate()[source]
finalize()[source]
initialize()[source]
mainloop_send()[source]
send(payload)[source]
class jacinle.comm.gather.GatherInputPipe(name, mode='tcp')[source]

Bases: object

activate()[source]
conn_info()[source]
finalize()[source]
initialize()[source]
recv()[source]
jacinle.comm.gather.make_gather_pair(name, nr_workers=None, mode='tcp', send_qsize=10)[source]

jacinle.comm.service module

class jacinle.comm.service.Service(configs=None, spec=None)[source]

Bases: object

call(*args, **kwargs)[source]
finalize()[source]
initialize()[source]
serve_socket(name=None, tcp_port=None)[source]
class jacinle.comm.service.SocketServer(service, name, tcp_port=None)[source]

Bases: object

call_get_configs(pipe, identifier, inp)[source]
call_get_conn_info(pipe, identifier, inp)[source]
call_get_identifier(pipe, identifier, inp)[source]
call_get_name(pipe, identifier, inp)[source]
call_get_signature(pipe, identifier, inp)[source]
call_get_spec(pipe, identifier, inp)[source]
call_query(pipe, identifier, feed_dict)[source]
conn_info
serve()[source]
class jacinle.comm.service.SocketClient(name, conn_info)[source]

Bases: object

activate()[source]
call(*args, echo=True, **kwargs)[source]
finalize()[source]
get_client_identifier()[source]
get_configs()[source]
get_server_conn_info()[source]
get_server_identifier()[source]
get_server_name()[source]
get_signature()[source]
get_spec()[source]
initialize()[source]