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

Method reset_session

src/msg/async/ProtocolV2.cc:151–174  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

149}
150
151void ProtocolV2::reset_session() {
152 ldout(cct, 1) << __func__ << dendl;
153
154 std::lock_guard<std::mutex> l(connection->write_lock);
155 if (connection->delay_state) {
156 connection->delay_state->discard();
157 }
158
159 connection->dispatch_queue->discard_queue(connection->conn_id);
160 discard_out_queue();
161 connection->outgoing_bl.clear();
162
163 connection->dispatch_queue->queue_remote_reset(connection);
164
165 out_seq = 0;
166 in_seq = 0;
167 client_cookie = 0;
168 server_cookie = 0;
169 connect_seq = 0;
170 peer_global_seq = 0;
171 message_seq = 0;
172 ack_left = 0;
173 can_write = false;
174}
175
176void ProtocolV2::stop() {
177 ldout(cct, 1) << __func__ << dendl;

Callers 1

Calls 4

discard_queueMethod · 0.80
queue_remote_resetMethod · 0.80
discardMethod · 0.45
clearMethod · 0.45

Tested by

no test coverage detected