Method LoadHeader

library/cpp/neh/tcp2.cpp:217–248

            }

            size_t LoadHeader(const char* buf, size_t len) {
                size_t useBytes = Min<size_t>(RequireBytesForComplete_, len);
                Header_.Append(buf, useBytes);
                RequireBytesForComplete_ -= useBytes;
                if (RequireBytesForComplete_) {
                    //continue load header
                    Loader_ = &TTcp2Message::LoadHeader;
                    return useBytes;
                }

                const TBaseHeader& hdr = *reinterpret_cast<const TBaseHeader*>(Header_.Data());

                if (hdr.Type == TBaseHeader::Request) {
                    if (Header_.Size() < sizeof(TRequestHeader)) {
                        throw yexception() << TStringBuf("invalid request header size");
                    }
                    InitContentLoading(RequestHeader().ContentLength);
                } else if (hdr.Type == TBaseHeader::Response) {
                    if (Header_.Size() < sizeof(TResponseHeader)) {
                        throw yexception() << TStringBuf("invalid response header size");
                    }
                    InitContentLoading(ResponseHeader().ContentLength);
                } else if (hdr.Type == TBaseHeader::Cancel) {
                    if (Header_.Size() < sizeof(TCancelHeader)) {
                        throw yexception() << TStringBuf("invalid cancel header size");
                    }
                    return useBytes;
                } else {
                    throw yexception() << TStringBuf("unsupported request type: ") << static_cast<unsigned>(hdr.Type);
                }
                return useBytes + (this->*Loader_)(buf + useBytes, len - useBytes);
            }

            void InitContentLoading(size_t contentLength) {
                RequireBytesForComplete_ = contentLength;