| 518 | test_mt_handler_wq() : wq_(0) {} |
| 519 | |
| 520 | void on_connection_open(proton::connection &c) override { |
| 521 | { |
| 522 | std::unique_lock<std::mutex> l(wqlock_); |
| 523 | // Just record first connection side, inbound or outbound |
| 524 | if (!connection_) { |
| 525 | connection_ = c; |
| 526 | wq_ = &c.work_queue(); |
| 527 | call_do_close_ = make_work(&test_mt_handler_wq::do_close, this); |
| 528 | } |
| 529 | else |
| 530 | return; |
| 531 | } |
| 532 | test_mt_handler::on_connection_open(c); |
| 533 | } |
| 534 | void initiate_close() { |
| 535 | std::unique_lock<std::mutex> l(wqlock_); |
| 536 | wq_->add(call_do_close_); |
nothing calls this directly
no test coverage detected