Method SendMessages

library/cpp/neh/tcp2.cpp:1389–1421

must be called only after success aquiring output

                //must be called only after success aquiring output
                void SendMessages(bool asioThread) {
                    DBGOUT("TServer::SendMessages(enter)");
                    try {
                        do {
                            NeedCheckOutputQueue_.store(false);
                            TAutoPtr<TOutputData> d;
                            while (OutputData_.Dequeue(&d)) {
                                d->MoveTo(OutputBuffers_);
                                if (!OutputBuffers_.HasFreeSpace()) {
                                    if (!FlushOutputBuffers(asioThread)) {
                                        return;
                                    }
                                }
                            }

                            if (OutputBuffers_.HasData()) {
                                if (!FlushOutputBuffers(asioThread)) {
                                    return;
                                }
                            }

                            OutputLock_.Release();

                            if (!NeedCheckOutputQueue_.load()) {
                                DBGOUT("Server::SendMessages(exit2): " << (int)!OutputLock_.IsLocked());
                                return;
                            }
                        } while (OutputLock_.TryAcquire());
                        DBGOUT("Server::SendMessages(exit1)");
                    } catch (...) {
                        OnError();
                    }
                }

                bool FlushOutputBuffers(bool asioThread) {
                    DBGOUT("FlushOutputBuffers: cnt=" << OutputBuffers_.GetIOvec()->Count() << " c=" << (size_t)this);