| 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 |
no test coverage detected