| 648 | } |
| 649 | |
| 650 | void AsyncConnection::shutdown_socket() { |
| 651 | for (auto &&t : register_time_events) center->delete_time_event(t); |
| 652 | register_time_events.clear(); |
| 653 | if (last_tick_id) { |
| 654 | center->delete_time_event(last_tick_id); |
| 655 | last_tick_id = 0; |
| 656 | } |
| 657 | if (cs) { |
| 658 | center->delete_file_event(cs.fd(), EVENT_READABLE | EVENT_WRITABLE); |
| 659 | cs.shutdown(); |
| 660 | cs.close(); |
| 661 | } |
| 662 | } |
| 663 | |
| 664 | void AsyncConnection::DelayedDelivery::do_request(uint64_t id) |
| 665 | { |
no test coverage detected