| 755 | } |
| 756 | |
| 757 | void AsyncConnection::stop(bool queue_reset) { |
| 758 | lock.lock(); |
| 759 | bool need_queue_reset = (state != STATE_CLOSED) && queue_reset; |
| 760 | protocol->stop(); |
| 761 | lock.unlock(); |
| 762 | if (need_queue_reset) dispatch_queue->queue_reset(this); |
| 763 | } |
| 764 | |
| 765 | void AsyncConnection::cleanup() { |
| 766 | shutdown_socket(); |
no test coverage detected