MCPcopy Create free account
hub / github.com/ByConity/ByConity / readPayload

Method readPayload

src/Core/MySQL/IMySQLReadPacket.cpp:16–27  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

14{
15
16void IMySQLReadPacket::readPayload(ReadBuffer & in, uint8_t & sequence_id)
17{
18 MySQLPacketPayloadReadBuffer payload(in, sequence_id);
19 payload.next();
20 readPayloadImpl(payload);
21 if (!payload.eof())
22 {
23 throw Exception(ErrorCodes::UNKNOWN_PACKET_FROM_CLIENT,
24 "Packet payload is not fully read. Stopped after {} bytes, while {} bytes are in buffer.",
25 payload.count(), payload.available());
26 }
27}
28
29void IMySQLReadPacket::readPayloadWithUnpacked(ReadBuffer & in)
30{

Callers 3

receivePacketMethod · 0.80
tryReceivePacketMethod · 0.80
mainFunction · 0.80

Calls 5

ExceptionClass · 0.50
nextMethod · 0.45
eofMethod · 0.45
countMethod · 0.45
availableMethod · 0.45

Tested by

no test coverage detected