Lines Matching refs:blocking
51 size_t Filter::CopyRangeTo2(BufferedTransformation &target, lword &begin, lword end, const std::string &channel, bool blocking) const
53 return AttachedTransformation()->CopyRangeTo2(target, begin, end, channel, blocking);
56 size_t Filter::TransferTo2(BufferedTransformation &target, lword &transferBytes, const std::string &channel, bool blocking)
58 return AttachedTransformation()->TransferTo2(target, transferBytes, channel, blocking);
68 bool Filter::Flush(bool hardFlush, int propagation, bool blocking)
73 if (IsolatedFlush(hardFlush, blocking))
76 if (OutputFlush(1, hardFlush, propagation, blocking))
82 bool Filter::MessageSeriesEnd(int propagation, bool blocking)
87 if (IsolatedMessageSeriesEnd(blocking))
90 if (ShouldPropagateMessageSeriesEnd() && OutputMessageSeriesEnd(1, propagation, blocking))
102 size_t Filter::OutputModifiable(int outputSite, byte *inString, size_t length, int messageEnd, bool blocking, const std::string &channel)
106 size_t result = AttachedTransformation()->ChannelPutModifiable2(channel, inString, length, messageEnd, blocking);
111 size_t Filter::Output(int outputSite, const byte *inString, size_t length, int messageEnd, bool blocking, const std::string &channel)
115 size_t result = AttachedTransformation()->ChannelPut2(channel, inString, length, messageEnd, blocking);
120 bool Filter::OutputFlush(int outputSite, bool hardFlush, int propagation, bool blocking, const std::string &channel)
122 if (propagation && AttachedTransformation()->ChannelFlush(channel, hardFlush, propagation-1, blocking))
131 bool Filter::OutputMessageSeriesEnd(int outputSite, int propagation, bool blocking, const std::string &channel)
133 if (propagation && AttachedTransformation()->ChannelMessageSeriesEnd(channel, propagation-1, blocking))
158 size_t MeterFilter::PutMaybeModifiable(byte *begin, size_t length, int messageEnd, bool blocking, bool modifiable)
216 size_t MeterFilter::Put2(const byte *begin, size_t length, int messageEnd, bool blocking)
218 return PutMaybeModifiable(const_cast<byte *>(begin), length, messageEnd, blocking, false);
221 size_t MeterFilter::PutModifiable2(byte *begin, size_t length, int messageEnd, bool blocking)
223 return PutMaybeModifiable(begin, length, messageEnd, blocking, true);
226 bool MeterFilter::IsolatedMessageSeriesEnd(bool blocking)
316 bool FilterWithBufferedInput::IsolatedFlush(bool hardFlush, bool blocking)
318 if (!blocking)
328 size_t FilterWithBufferedInput::PutMaybeModifiable(byte *inString, size_t length, int messageEnd, bool blocking, bool modifiable)
330 if (!blocking)
413 Output(1, NULL, 0, messageEnd, blocking);
468 bool ProxyFilter::IsolatedFlush(bool hardFlush, bool blocking)
470 return m_filter.get() ? m_filter->Flush(hardFlush, -1, blocking) : false;
504 size_t RandomNumberSink::Put2(const byte *begin, size_t length, int messageEnd, bool blocking)
510 size_t ArraySink::Put2(const byte *begin, size_t length, int messageEnd, bool blocking)
534 size_t ArrayXorSink::Put2(const byte *begin, size_t length, int messageEnd, bool blocking)
730 size_t HashFilter::Put2(const byte *inString, size_t length, int messageEnd, bool blocking)
834 size_t AuthenticatedEncryptionFilter::ChannelPut2(const std::string &channel, const byte *begin, size_t length, int messageEnd, bool blocking)
837 return StreamTransformationFilter::Put2(begin, length, messageEnd, blocking);
840 return m_hf.Put2(begin, length, 0, blocking);
885 size_t AuthenticatedDecryptionFilter::ChannelPut2(const std::string &channel, const byte *begin, size_t length, int messageEnd, bool blocking)
891 return FilterWithBufferedInput::Put2(begin, length, messageEnd, blocking);
895 return m_hashVerifier.Put2(begin, length, 0, blocking);
924 size_t SignerFilter::Put2(const byte *inString, size_t length, int messageEnd, bool blocking)
1012 size_t Source::PumpAll2(bool blocking)
1016 RETURN_IF_NONZERO(PumpMessages2(messageCount, blocking));
1056 size_t StringStore::TransferTo2(BufferedTransformation &target, lword &transferBytes, const std::string &channel, bool blocking)
1059 size_t blockedBytes = CopyRangeTo2(target, position, transferBytes, channel, blocking);
1065 size_t StringStore::CopyRangeTo2(BufferedTransformation &target, lword &begin, lword end, const std::string &channel, bool blocking) const
1069 size_t blockedBytes = target.ChannelPut2(channel, m_store+i, len, 0, blocking);
1083 size_t RandomNumberStore::TransferTo2(BufferedTransformation &target, lword &transferBytes, const std::string &channel, bool blocking)
1085 if (!blocking)
1095 size_t NullStore::CopyRangeTo2(BufferedTransformation &target, lword &begin, lword end, const std::string &channel, bool blocking) const
1101 size_t blockedBytes = target.ChannelPut2(channel, nullBytes, len, 0, blocking);
1109 size_t NullStore::TransferTo2(BufferedTransformation &target, lword &transferBytes, const std::string &channel, bool blocking)
1112 size_t blockedBytes = NullStore::CopyRangeTo2(target, begin, transferBytes, channel, blocking);