| 616 | } |
| 617 | |
| 618 | void AsyncConnection::fault() |
| 619 | { |
| 620 | shutdown_socket(); |
| 621 | open_write = false; |
| 622 | |
| 623 | // queue delayed items immediately |
| 624 | if (delay_state) |
| 625 | delay_state->flush(); |
| 626 | |
| 627 | recv_start = recv_end = 0; |
| 628 | state_offset = 0; |
| 629 | outgoing_bl.clear(); |
| 630 | } |
| 631 | |
| 632 | void AsyncConnection::_stop() { |
| 633 | writeCallback = {}; |