MCPcopy Create free account
hub / github.com/apache/qpid-proton / work_queue

Method work_queue

cpp/examples/multithreaded_client.cpp:96–101  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

94 private:
95
96 proton::work_queue* work_queue() {
97 // Wait till work_queue_ and sender_ are initialized.
98 std::unique_lock<std::mutex> l(lock_);
99 while (!work_queue_) sender_ready_.wait(l);
100 return work_queue_;
101 }
102
103 // == messaging_handler overrides, only called in proton handler thread
104

Callers 7

SenderMethod · 0.45
ReceiverMethod · 0.45
on_sender_openMethod · 0.45
on_sender_openMethod · 0.45
on_connection_openMethod · 0.45
process_timeoutMethod · 0.45
on_sender_openMethod · 0.45

Calls 1

waitMethod · 0.65

Tested by

no test coverage detected