Lines Matching defs:blocking
216 size_t ByteQueue::Put2(const byte *inString, size_t length, int messageEnd, bool blocking)
335 size_t ByteQueue::TransferTo2(BufferedTransformation &target, lword &transferBytes, const std::string &channel, bool blocking)
337 if (blocking)
361 size_t blockedBytes = walker.TransferTo2(target, transferBytes, channel, blocking);
367 size_t ByteQueue::CopyRangeTo2(BufferedTransformation &target, lword &begin, lword end, const std::string &channel, bool blocking) const
372 size_t blockedBytes = walker.TransferTo2(target, transferBytes, channel, blocking);
509 size_t ByteQueue::Walker::TransferTo2(BufferedTransformation &target, lword &transferBytes, const std::string &channel, bool blocking)
517 blockedBytes = target.ChannelPut2(channel, m_node->buf+m_node->m_head+m_offset, len, 0, blocking);
538 blockedBytes = target.ChannelPut2(channel, m_lazyString, len, 0, blocking);
552 size_t ByteQueue::Walker::CopyRangeTo2(BufferedTransformation &target, lword &begin, lword end, const std::string &channel, bool blocking) const
557 size_t blockedBytes = walker.TransferTo2(target, transferBytes, channel, blocking);