| 149 | } |
| 150 | |
| 151 | void 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 | |
| 176 | void ProtocolV2::stop() { |
| 177 | ldout(cct, 1) << __func__ << dendl; |
no test coverage detected