Method OnReceiveMessage

library/cpp/neh/tcp2.cpp:1280–1301

                }

                void OnReceiveMessage() {
                    DBGOUT("OnReceiveMessage()");
                    const TBaseHeader& hdr = Msg_.BaseHeader();

                    if (hdr.Type == TBaseHeader::Request) {
                        TRequest* reqPtr = new TRequest(TConnectionRef(this), Msg_.Header(), Msg_.Content());
                        IRequestRef req(reqPtr);
                        ReqsState_[reqPtr->RequestHeader().Id] = reqPtr->State;
                        OnRequest(req);
                    } else if (hdr.Type == TBaseHeader::Cancel) {
                        OnCancelRequest(hdr.Id);
                    } else {
                        throw yexception() << "unsupported message type: " << (ui32)hdr.Type;
                    }
                    Msg_.Clear();
                    {
                        TRequestId reqId;
                        while (FinReqs_.Dequeue(&reqId)) {
                            ReqsState_.erase(reqId);
                        }
                    }
                }

                void OnRequest(IRequestRef& r) {
                    DBGOUT("OnRequest()");