jacinle.concurrency.zmq_utils#

Functions

bind_to_random_ipc(sock, name)

graceful_close(sock)

iter_recv(meth, sock)

json_dumpb(x)

json_loadb(x)

pull_pyobj(sock[, flag])

push_pyobj(sock, data[, flag])

req_recv_json(sock[, flag, loader])

req_send_and_recv(sock, *payloads)

req_send_json(sock, *payloads[, flag, dumper])

router_recv_json(sock[, flag, loader])

router_send_json(sock, identifier, *payloads)

uid()

Functions

bind_to_random_ipc(sock, name)[source]#
graceful_close(sock)[source]#
iter_recv(meth, sock)[source]#
json_dumpb(x)#
json_loadb(x)#
pull_pyobj(sock, flag=zmq.NOBLOCK)[source]#
push_pyobj(sock, data, flag=zmq.NOBLOCK)[source]#
req_recv_json(sock, flag=0, loader=json_loadb)[source]#
req_send_and_recv(sock, *payloads)[source]#
req_send_json(sock, *payloads, flag=0, dumper=json_dumpb)[source]#
router_recv_json(sock, flag=zmq.NOBLOCK, loader=json_loadb)[source]#
router_send_json(sock, identifier, *payloads, flag=0, dumper=json_dumpb)[source]#
uid()[source]#