Lines Matching refs:blocking
25 size_t TransferTo2(BufferedTransformation &target, lword &transferBytes, const std::string &channel=DEFAULT_CHANNEL, bool blocking=true);
26 size_t CopyRangeTo2(BufferedTransformation &target, lword &begin, lword end=LWORD_MAX, const std::string &channel=DEFAULT_CHANNEL, bool blocking=true) const;
29 bool Flush(bool hardFlush, int propagation=-1, bool blocking=true);
30 bool MessageSeriesEnd(int propagation=-1, bool blocking=true);
41 size_t Output(int outputSite, const byte *inString, size_t length, int messageEnd, bool blocking, const std::string &channel=DEFAULT_CHANNEL);
42 size_t OutputModifiable(int outputSite, byte *inString, size_t length, int messageEnd, bool blocking, const std::string &channel=DEFAULT_CHANNEL);
43 bool OutputMessageEnd(int outputSite, int propagation, bool blocking, const std::string &channel=DEFAULT_CHANNEL);
44 bool OutputFlush(int outputSite, bool hardFlush, int propagation, bool blocking, const std::string &channel=DEFAULT_CHANNEL);
45 bool OutputMessageSeriesEnd(int outputSite, int propagation, bool blocking, const std::string &channel=DEFAULT_CHANNEL);
102 size_t Put2(const byte *begin, size_t length, int messageEnd, bool blocking);
103 size_t PutModifiable2(byte *inString, size_t length, int messageEnd, bool blocking);
104 bool IsolatedMessageSeriesEnd(bool blocking);
107 size_t PutMaybeModifiable(byte *inString, size_t length, int messageEnd, bool blocking, bool modifiable);
153 size_t Put2(const byte *inString, size_t length, int messageEnd, bool blocking)
155 return PutMaybeModifiable(const_cast<byte *>(inString), length, messageEnd, blocking, false);
157 size_t PutModifiable2(byte *inString, size_t length, int messageEnd, bool blocking)
159 return PutMaybeModifiable(inString, length, messageEnd, blocking, true);
162 bool IsolatedFlush(bool hardFlush, bool blocking);
194 size_t PutMaybeModifiable(byte *begin, size_t length, int messageEnd, bool blocking, bool modifiable);
233 size_t Put2(const byte *inString, size_t length, int messageEnd, bool blocking)
235 if (!blocking)
241 IsolatedMessageEnd(blocking);
242 Output(0, NULL, 0, messageEnd, blocking);
248 virtual bool IsolatedMessageEnd(bool blocking) =0;
296 size_t Put2(const byte *begin, size_t length, int messageEnd, bool blocking);
352 size_t ChannelPut2(const std::string &channel, const byte *begin, size_t length, int messageEnd, bool blocking);
371 size_t ChannelPut2(const std::string &channel, const byte *begin, size_t length, int messageEnd, bool blocking);
394 size_t Put2(const byte *begin, size_t length, int messageEnd, bool blocking);
470 size_t Put2(const byte *begin, size_t length, int messageEnd, bool blocking)
471 {return m_target ? m_target->Put2(begin, length, GetPassSignals() ? messageEnd : 0, blocking) : 0;}
472 bool Flush(bool hardFlush, int propagation=-1, bool blocking=true)
473 {return m_target && GetPassSignals() ? m_target->Flush(hardFlush, propagation, blocking) : false;}
474 bool MessageSeriesEnd(int propagation=-1, bool blocking=true)
475 {return m_target && GetPassSignals() ? m_target->MessageSeriesEnd(propagation, blocking) : false;}
479 size_t ChannelPut2(const std::string &channel, const byte *begin, size_t length, int messageEnd, bool blocking)
480 {return m_target ? m_target->ChannelPut2(channel, begin, length, GetPassSignals() ? messageEnd : 0, blocking) : 0;}
481 size_t ChannelPutModifiable2(const std::string &channel, byte *begin, size_t length, int messageEnd, bool blocking)
482 {return m_target ? m_target->ChannelPutModifiable2(channel, begin, length, GetPassSignals() ? messageEnd : 0, blocking) : 0;}
483 bool ChannelFlush(const std::string &channel, bool completeFlush, int propagation=-1, bool blocking=true)
484 {return m_target && GetPassSignals() ? m_target->ChannelFlush(channel, completeFlush, propagation, blocking) : false;}
485 bool ChannelMessageSeriesEnd(const std::string &channel, int propagation=-1, bool blocking=true)
486 {return m_target && GetPassSignals() ? m_target->ChannelMessageSeriesEnd(channel, propagation, blocking) : false;}
509 size_t Put2(const byte *begin, size_t length, int messageEnd, bool blocking)
510 {return m_owner.AttachedTransformation()->Put2(begin, length, m_passSignal ? messageEnd : 0, blocking);}
511 size_t PutModifiable2(byte *begin, size_t length, int messageEnd, bool blocking)
512 {return m_owner.AttachedTransformation()->PutModifiable2(begin, length, m_passSignal ? messageEnd : 0, blocking);}
515 bool Flush(bool hardFlush, int propagation=-1, bool blocking=true)
516 {return m_passSignal ? m_owner.AttachedTransformation()->Flush(hardFlush, propagation, blocking) : false;}
517 bool MessageSeriesEnd(int propagation=-1, bool blocking=true)
518 {return m_passSignal ? m_owner.AttachedTransformation()->MessageSeriesEnd(propagation, blocking) : false;}
522 size_t ChannelPut2(const std::string &channel, const byte *begin, size_t length, int messageEnd, bool blocking)
523 {return m_owner.AttachedTransformation()->ChannelPut2(channel, begin, length, m_passSignal ? messageEnd : 0, blocking);}
524 size_t ChannelPutModifiable2(const std::string &channel, byte *begin, size_t length, int messageEnd, bool blocking)
525 {return m_owner.AttachedTransformation()->ChannelPutModifiable2(channel, begin, length, m_passSignal ? messageEnd : 0, blocking);}
526 bool ChannelFlush(const std::string &channel, bool completeFlush, int propagation=-1, bool blocking=true)
527 {return m_passSignal ? m_owner.AttachedTransformation()->ChannelFlush(channel, completeFlush, propagation, blocking) : false;}
528 bool ChannelMessageSeriesEnd(const std::string &channel, int propagation=-1, bool blocking=true)
529 {return m_passSignal ? m_owner.AttachedTransformation()->ChannelMessageSeriesEnd(channel, propagation, blocking) : false;}
542 bool IsolatedFlush(bool hardFlush, bool blocking);
595 size_t Put2(const byte *begin, size_t length, int messageEnd, bool blocking)
626 size_t Put2(const byte *begin, size_t length, int messageEnd, bool blocking);
644 size_t Put2(const byte *begin, size_t length, int messageEnd, bool blocking);
659 size_t Put2(const byte *begin, size_t length, int messageEnd, bool blocking);
674 CRYPTOPP_DLL size_t TransferTo2(BufferedTransformation &target, lword &transferBytes, const std::string &channel=DEFAULT_CHANNEL, bool blocking=true);
675 CRYPTOPP_DLL size_t CopyRangeTo2(BufferedTransformation &target, lword &begin, lword end=LWORD_MAX, const std::string &channel=DEFAULT_CHANNEL, bool blocking=true) const;
697 size_t TransferTo2(BufferedTransformation &target, lword &transferBytes, const std::string &channel=DEFAULT_CHANNEL, bool blocking=true);
698 size_t CopyRangeTo2(BufferedTransformation &target, lword &begin, lword end=LWORD_MAX, const std::string &channel=DEFAULT_CHANNEL, bool blocking=true) const
717 size_t TransferTo2(BufferedTransformation &target, lword &transferBytes, const std::string &channel=DEFAULT_CHANNEL, bool blocking=true);
718 size_t CopyRangeTo2(BufferedTransformation &target, lword &begin, lword end=LWORD_MAX, const std::string &channel=DEFAULT_CHANNEL, bool blocking=true) const;
737 virtual size_t Pump2(lword &byteCount, bool blocking=true) =0;
738 virtual size_t PumpMessages2(unsigned int &messageCount, bool blocking=true) =0;
739 virtual size_t PumpAll2(bool blocking=true);
760 size_t Pump2(lword &byteCount, bool blocking=true)
761 {return m_store.TransferTo2(*AttachedTransformation(), byteCount, DEFAULT_CHANNEL, blocking);}
762 size_t PumpMessages2(unsigned int &messageCount, bool blocking=true)
763 {return m_store.TransferMessagesTo2(*AttachedTransformation(), messageCount, DEFAULT_CHANNEL, blocking);}
764 size_t PumpAll2(bool blocking=true)
765 {return m_store.TransferAllTo2(*AttachedTransformation(), DEFAULT_CHANNEL, blocking);}