Method OnReadSome

library/cpp/neh/tcp2.cpp:1238–1278

                }

                void OnReadSome(const TErrorCode& ec, size_t amount, IHandlingContext& ctx) {
                    while (1) {
                        if (ec || !amount) {
                            OnError();
                            return;
                        }

                        try {
                            const char* buff = Buff_.Get();
                            size_t leftBytes = amount;
                            do {
                                size_t useBytes = Msg_.LoadFrom(buff, leftBytes);
                                leftBytes -= useBytes;
                                buff += useBytes;
                                if (Msg_.IsComplete()) {
                                    OnReceiveMessage();
                                }
                            } while (leftBytes);

                            if (amount == BuffSize_) {
                                //try decrease system calls, - re-run ReadSome if has full filled buffer
                                TErrorCode ecR;
                                amount = AS_->ReadSome(Buff_.Get(), BuffSize_, ecR);
                                if (!ecR) {
                                    continue;
                                }
                                if (ecR.Value() == EAGAIN || ecR.Value() == EWOULDBLOCK) {
                                    ctx.ContinueUseHandler();
                                } else {
                                    OnError();
                                }
                            } else {
                                ctx.ContinueUseHandler();
                            }
                        } catch (...) {
                            DBGOUT("exc. " << CurrentExceptionMessage());
                            OnError();
                        }
                        return;
                    }
                }

                void OnReceiveMessage() {
                    DBGOUT("OnReceiveMessage()");