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

Method on_connection_open

cpp/src/container_test.cpp:520–533  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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_);

Callers

nothing calls this directly

Calls 2

make_workFunction · 0.85
work_queueMethod · 0.45

Tested by

no test coverage detected