| 846 | } |
| 847 | |
| 848 | void container::impl::stop(const proton::error_condition& err) { |
| 849 | { |
| 850 | GUARD(lock_); |
| 851 | if (stopping_) return; // Already stopping |
| 852 | auto_stop_ = true; |
| 853 | stopping_ = true; |
| 854 | // Have to wait until actual reconnect to stop or we leak the connection |
| 855 | if (reconnecting_>0) return; |
| 856 | } |
| 857 | pn_condition_t* error_condition = pn_condition(); |
| 858 | set_error_condition(err, error_condition); |
| 859 | pn_proactor_disconnect(proactor_, error_condition); |
| 860 | pn_condition_free(error_condition); |
| 861 | } |
| 862 | |
| 863 | } |
nothing calls this directly
no test coverage detected