Lines Matching refs:blocking
767 If a method takes a "blocking" parameter, and you
798 size_t Put(byte inByte, bool blocking=true)
799 {return Put(&inByte, 1, blocking);}
801 size_t Put(const byte *inString, size_t length, bool blocking=true)
802 {return Put2(inString, length, 0, blocking);}
805 size_t PutWord16(word16 value, ByteOrder order=BIG_ENDIAN_ORDER, bool blocking=true);
807 size_t PutWord32(word32 value, ByteOrder order=BIG_ENDIAN_ORDER, bool blocking=true);
817 size_t PutModifiable(byte *inString, size_t length, bool blocking=true)
818 {return PutModifiable2(inString, length, 0, blocking);}
820 bool MessageEnd(int propagation=-1, bool blocking=true)
821 {return !!Put2(NULL, 0, propagation < 0 ? -1 : propagation+1, blocking);}
822 size_t PutMessageEnd(const byte *inString, size_t length, int propagation=-1, bool blocking=true)
823 {return Put2(inString, length, propagation < 0 ? -1 : propagation+1, blocking);}
825 //! input multiple bytes for blocking or non-blocking processing
827 virtual size_t Put2(const byte *inString, size_t length, int messageEnd, bool blocking) =0;
828 //! input multiple bytes that may be modified by callee for blocking or non-blocking processing
830 virtual size_t PutModifiable2(byte *inString, size_t length, int messageEnd, bool blocking)
831 {return Put2(inString, length, messageEnd, blocking);}
847 virtual bool IsolatedFlush(bool hardFlush, bool blocking) =0;
848 virtual bool IsolatedMessageSeriesEnd(bool blocking) {return false;}
863 virtual bool Flush(bool hardFlush, int propagation=-1, bool blocking=true);
866 virtual bool MessageSeriesEnd(int propagation=-1, bool blocking=true);
970 virtual size_t TransferTo2(BufferedTransformation &target, lword &byteCount, const std::string &channel=DEFAULT_CHANNEL, bool blocking=true) =0;
972 virtual size_t CopyRangeTo2(BufferedTransformation &target, lword &begin, lword end=LWORD_MAX, const std::string &channel=DEFAULT_CHANNEL, bool blocking=true) const =0;
974 size_t TransferMessagesTo2(BufferedTransformation &target, unsigned int &messageCount, const std::string &channel=DEFAULT_CHANNEL, bool blocking=true);
976 size_t TransferAllTo2(BufferedTransformation &target, const std::string &channel=DEFAULT_CHANNEL, bool blocking=true);
986 size_t ChannelPut(const std::string &channel, byte inByte, bool blocking=true)
987 {return ChannelPut(channel, &inByte, 1, blocking);}
988 size_t ChannelPut(const std::string &channel, const byte *inString, size_t length, bool blocking=true)
989 {return ChannelPut2(channel, inString, length, 0, blocking);}
991 size_t ChannelPutModifiable(const std::string &channel, byte *inString, size_t length, bool blocking=true)
992 {return ChannelPutModifiable2(channel, inString, length, 0, blocking);}
994 size_t ChannelPutWord16(const std::string &channel, word16 value, ByteOrder order=BIG_ENDIAN_ORDER, bool blocking=true);
995 size_t ChannelPutWord32(const std::string &channel, word32 value, ByteOrder order=BIG_ENDIAN_ORDER, bool blocking=true);
997 bool ChannelMessageEnd(const std::string &channel, int propagation=-1, bool blocking=true)
998 {return !!ChannelPut2(channel, NULL, 0, propagation < 0 ? -1 : propagation+1, blocking);}
999 size_t ChannelPutMessageEnd(const std::string &channel, const byte *inString, size_t length, int propagation=-1, bool blocking=true)
1000 {return ChannelPut2(channel, inString, length, propagation < 0 ? -1 : propagation+1, blocking);}
1004 virtual size_t ChannelPut2(const std::string &channel, const byte *begin, size_t length, int messageEnd, bool blocking);
1005 virtual size_t ChannelPutModifiable2(const std::string &channel, byte *begin, size_t length, int messageEnd, bool blocking);
1007 virtual bool ChannelFlush(const std::string &channel, bool hardFlush, int propagation=-1, bool blocking=true);
1008 virtual bool ChannelMessageSeriesEnd(const std::string &channel, int propagation=-1, bool blocking=true);
1040 byte m_buf[4]; // for ChannelPutWord16 and ChannelPutWord32, to ensure buffer isn't deallocated before non-blocking operation completes