MCPcopy Create free account
hub / github.com/ceph/ceph / handle_ready_connect_message_reply_write

Method handle_ready_connect_message_reply_write

src/msg/async/ProtocolV1.cc:2573–2594  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

2571}
2572
2573CtPtr 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
2596CtPtr ProtocolV1::wait_seq() {
2597 ldout(cct, 20) << __func__ << dendl;

Callers

nothing calls this directly

Calls 2

queue_acceptMethod · 0.80

Tested by

no test coverage detected