Lines Matching refs:NetworkSink
373 NetworkSink::NetworkSink(unsigned int maxBufferSize, unsigned int autoFlushBound)
382 float NetworkSink::ComputeCurrentSpeed()
395 float NetworkSink::GetMaxObservedSpeed() const
401 unsigned int NetworkSink::GetMaxWaitObjectCount() const
406 void NetworkSink::GetWaitObjects(WaitObjectContainer &container, CallStack const& callStack)
409 LimitedBandwidth::GetWaitObjects(container, CallStack("NetworkSink::GetWaitObjects() - speed limit", &callStack));
411 AccessSender().GetWaitObjects(container, CallStack("NetworkSink::GetWaitObjects() - was blocked", &callStack));
413 AccessSender().GetWaitObjects(container, CallStack("NetworkSink::GetWaitObjects() - buffer not empty", &callStack));
415 AccessSender().GetWaitObjects(container, CallStack("NetworkSink::GetWaitObjects() - EOF pending", &callStack));
418 size_t NetworkSink::Put2(const byte *inString, size_t length, int messageEnd, bool blocking)
423 throw Exception(Exception::OTHER_ERROR, "NetworkSink::Put2() being called after EOF had been sent");
474 lword NetworkSink::DoFlush(unsigned long maxTime, size_t targetSize)
491 CallStack("NetworkSink::DoFlush() - wait send result", 0)))
507 if (sender.MustWaitToSend() && !sender.Wait(timeOut, CallStack("NetworkSink::DoFlush() - wait send", 0)))
537 if (!sender.Wait(timeOut, CallStack("NetworkSink::DoFlush() - wait EOF", 0)))