Method LoadBaseHeader

library/cpp/neh/tcp2.cpp:194–215

        private:
            size_t LoadBaseHeader(const char* buf, size_t len) {
                size_t useBytes = Min<size_t>(sizeof(TBaseHeader) - Header_.Size(), len);
                Header_.Append(buf, useBytes);
                if (Y_UNLIKELY(sizeof(TBaseHeader) > Header_.Size())) {
                    //base header yet not complete
                    return useBytes;
                }
                {
                    const TBaseHeader& hdr = BaseHeader();
                    if (BaseHeader().HeaderLength > 32000) { //some heuristic header size limit
                        throw yexception() << TStringBuf("to large neh/tcp2 header size: ") << BaseHeader().HeaderLength;
                    }
                    //header completed
                    Header_.Reserve(hdr.HeaderLength);
                }
                const TBaseHeader& hdr = BaseHeader(); //reallocation can move Header_ data to another place, so use fresh 'hdr'
                if (Y_UNLIKELY(hdr.Version != 1)) {
                    throw yexception() << TStringBuf("unsupported protocol version: ") << static_cast<unsigned>(hdr.Version);
                }
                RequireBytesForComplete_ = hdr.HeaderLength - sizeof(TBaseHeader);
                return useBytes + LoadHeader(buf + useBytes, len - useBytes);
            }

            size_t LoadHeader(const char* buf, size_t len) {
                size_t useBytes = Min<size_t>(RequireBytesForComplete_, len);