bindAddr(T &socket, std::string &&addr) | RooFit::MultiProcess::Messenger | inlineprivate |
bound_ipc_addresses_ | RooFit::MultiProcess::Messenger | private |
close_MQ_on_destruct_ | RooFit::MultiProcess::Messenger | private |
close_QW_container_on_destruct_ | RooFit::MultiProcess::Messenger | private |
close_this_QW_on_destruct_ | RooFit::MultiProcess::Messenger | private |
create_queue_poller() | RooFit::MultiProcess::Messenger | |
create_worker_poller() | RooFit::MultiProcess::Messenger | |
debug_print(std::string s) | RooFit::MultiProcess::Messenger | private |
Messenger(const ProcessManager &process_manager) | RooFit::MultiProcess::Messenger | explicit |
mq_pull_ | RooFit::MultiProcess::Messenger | private |
mq_pull_poller_ | RooFit::MultiProcess::Messenger | private |
mq_push_ | RooFit::MultiProcess::Messenger | private |
mq_push_poller_ | RooFit::MultiProcess::Messenger | private |
mw_pub_ | RooFit::MultiProcess::Messenger | private |
mw_sub_ | RooFit::MultiProcess::Messenger | private |
mw_sub_poller_ | RooFit::MultiProcess::Messenger | private |
ppoll_sigmask | RooFit::MultiProcess::Messenger | |
publish_from_master_to_workers(T &&item) | RooFit::MultiProcess::Messenger | |
publish_from_master_to_workers(T &&item, T2 &&item2, Ts &&... items) | RooFit::MultiProcess::Messenger | |
qw_pull_ | RooFit::MultiProcess::Messenger | private |
qw_pull_poller_ | RooFit::MultiProcess::Messenger | private |
qw_push_ | RooFit::MultiProcess::Messenger | private |
qw_push_poller_ | RooFit::MultiProcess::Messenger | private |
receive_from_master_on_queue() | RooFit::MultiProcess::Messenger | |
receive_from_master_on_worker(bool *more=nullptr) | RooFit::MultiProcess::Messenger | |
receive_from_queue_on_master() | RooFit::MultiProcess::Messenger | |
receive_from_queue_on_worker() | RooFit::MultiProcess::Messenger | |
receive_from_worker_on_master() | RooFit::MultiProcess::Messenger | |
receive_from_worker_on_queue(std::size_t this_worker_id) | RooFit::MultiProcess::Messenger | |
send_flag_ | RooFit::MultiProcess::Messenger | private |
send_from_master_to_queue() | RooFit::MultiProcess::Messenger | |
send_from_master_to_queue(T item, Ts... items) | RooFit::MultiProcess::Messenger | |
send_from_queue_to_master() | RooFit::MultiProcess::Messenger | |
send_from_queue_to_master(T item, Ts... items) | RooFit::MultiProcess::Messenger | |
send_from_queue_to_worker(std::size_t this_worker_id) | RooFit::MultiProcess::Messenger | |
send_from_queue_to_worker(std::size_t this_worker_id, T item, Ts... items) | RooFit::MultiProcess::Messenger | |
send_from_worker_to_master() | RooFit::MultiProcess::Messenger | |
send_from_worker_to_master(T item, Ts... items) | RooFit::MultiProcess::Messenger | |
send_from_worker_to_queue() | RooFit::MultiProcess::Messenger | |
send_from_worker_to_queue(T item, Ts... items) | RooFit::MultiProcess::Messenger | |
set_send_flag(zmq::send_flags flag) | RooFit::MultiProcess::Messenger | |
test_connections(const ProcessManager &process_manager) | RooFit::MultiProcess::Messenger | |
test_rcv_pipes enum name | RooFit::MultiProcess::Messenger | |
test_receive(X2X expected_ping_value, test_rcv_pipes rcv_pipe, std::size_t worker_id) | RooFit::MultiProcess::Messenger | |
test_send(X2X ping_value, test_snd_pipes snd_pipe, std::size_t worker_id) | RooFit::MultiProcess::Messenger | |
test_snd_pipes enum name | RooFit::MultiProcess::Messenger | |
this_worker_qw_pull_ | RooFit::MultiProcess::Messenger | private |
this_worker_qw_push_ | RooFit::MultiProcess::Messenger | private |
wm_pull_ | RooFit::MultiProcess::Messenger | private |
wm_pull_poller_ | RooFit::MultiProcess::Messenger | private |
wm_push_ | RooFit::MultiProcess::Messenger | private |
~Messenger() | RooFit::MultiProcess::Messenger | |