Lines Matching refs:blocking
16 size_t MessageQueue::CopyRangeTo2(BufferedTransformation &target, lword &begin, lword end, const std::string &channel, bool blocking) const
21 return m_queue.CopyRangeTo2(target, begin, STDMIN(MaxRetrievable(), end), channel, blocking);
24 size_t MessageQueue::TransferTo2(BufferedTransformation &target, lword &transferBytes, const std::string &channel, bool blocking)
27 size_t blockedBytes = m_queue.TransferTo2(target, transferBytes, channel, blocking);
84 size_t EqualityComparisonFilter::ChannelPut2(const std::string &channel, const byte *inString, size_t length, int messageEnd, bool blocking)
86 if (!blocking)
92 return Output(3, inString, length, messageEnd, blocking, channel);
131 return HandleMismatchDetected(blocking);
135 bool EqualityComparisonFilter::ChannelMessageSeriesEnd(const std::string &channel, int propagation, bool blocking)
141 OutputMessageSeriesEnd(4, propagation, blocking, channel);
153 return Output(2, (const byte *)"\1", 1, 0, blocking) != 0;
160 return HandleMismatchDetected(blocking);
164 bool EqualityComparisonFilter::HandleMismatchDetected(bool blocking)
169 return Output(1, (const byte *)"\0", 1, 0, blocking) != 0;