| 2571 | } |
| 2572 | |
| 2573 | CtPtr ProtocolV1::handle_ready_connect_message_reply_write(int r) { |
| 2574 | ldout(cct, 20) << __func__ << " r=" << r << dendl; |
| 2575 | |
| 2576 | if (r < 0) { |
| 2577 | ldout(cct, 1) << __func__ << " write ready connect message reply failed" |
| 2578 | << dendl; |
| 2579 | return _fault(); |
| 2580 | } |
| 2581 | |
| 2582 | // notify |
| 2583 | connection->dispatch_queue->queue_accept(connection); |
| 2584 | messenger->ms_deliver_handle_fast_accept(connection); |
| 2585 | once_ready = true; |
| 2586 | |
| 2587 | state = ACCEPTING_HANDLED_CONNECT_MSG; |
| 2588 | |
| 2589 | if (wait_for_seq) { |
| 2590 | return wait_seq(); |
| 2591 | } |
| 2592 | |
| 2593 | return server_ready(); |
| 2594 | } |
| 2595 | |
| 2596 | CtPtr ProtocolV1::wait_seq() { |
| 2597 | ldout(cct, 20) << __func__ << dendl; |
nothing calls this directly
no test coverage detected