jacinle.comm.distrib package¶

Submodules¶

jacinle.comm.distrib.controller module¶

class jacinle.comm.distrib.controller.Controller[source]¶

Bases: object

close_socket(sock)[source]¶

finalize()[source]¶

initialize(pipes=None)[source]¶

socket(socket_type)[source]¶

jacinle.comm.distrib.controller.control(pipes)[source]¶

jacinle.comm.distrib.name_server module¶

class jacinle.comm.distrib.name_server.NameServer(host, port, protocal)[source]¶

Bases: object

finalize()[source]¶

initialize()[source]¶

main()[source]¶

main_cleanup()[source]¶

mainloop()[source]¶

jacinle.comm.distrib.name_server.run_name_server(host=None, port=None, protocal=None)[source]¶

jacinle.comm.distrib.pipe module¶

class jacinle.comm.distrib.pipe.DistribInputPipe(name, bufsize=10)[source]¶: Bases: jacinle.comm.distrib.pipe.DistribBroadcastPipeBase

class jacinle.comm.distrib.pipe.DistribOutputPipe(name, bufsize=10)[source]¶: Bases: jacinle.comm.distrib.pipe.DistribBroadcastPipeBase