ProtocolV2::ProtocolV2(AsyncConnection *connection)
: Protocol(2, connection),
- temp_buffer(nullptr),
state(NONE),
peer_required_features(0),
client_cookie(0),
next_payload_len(0),
next_tag(static_cast<Tag>(0)),
keepalive(false) {
- temp_buffer = new char[4096];
}
ProtocolV2::~ProtocolV2() {
- delete[] temp_buffer;
}
void ProtocolV2::connect() {
return _fault();
}
- ceph_assert(payload_len <= 4096); // if we need more then we need to increase
- // temp_buffer size as well
-
next_payload_len = payload_len;
INTERCEPT(state == BANNER_CONNECTING ? 5 : 6);