Lines Matching refs:blocking
52 bool IsolatedFlush(bool hardFlush, bool blocking) {return false;}
60 bool Flush(bool completeFlush, int propagation=-1, bool blocking=true)
61 {return ChannelFlush(DEFAULT_CHANNEL, completeFlush, propagation, blocking);}
62 bool IsolatedFlush(bool hardFlush, bool blocking)
64 bool ChannelFlush(const std::string &channel, bool hardFlush, int propagation=-1, bool blocking=true)
71 return attached && propagation ? attached->ChannelFlush(channel, hardFlush, propagation-1, blocking) : false;
88 size_t Put2(const byte *begin, size_t length, int messageEnd, bool blocking)
93 size_t ChannelPut2(const std::string &channel, const byte *begin, size_t length, int messageEnd, bool blocking)
103 virtual bool Flush(bool hardFlush, int propagation=-1, bool blocking=true) =0;
106 bool IsolatedFlush(bool hardFlush, bool blocking) {assert(false); return false;}
125 bool Flush(bool hardFlush, int propagation=-1, bool blocking=true)
126 {return this->ChannelFlush(DEFAULT_CHANNEL, hardFlush, propagation, blocking);}
127 bool MessageSeriesEnd(int propagation=-1, bool blocking=true)
128 {return this->ChannelMessageSeriesEnd(DEFAULT_CHANNEL, propagation, blocking);}
131 size_t Put2(const byte *begin, size_t length, int messageEnd, bool blocking)
132 {return this->ChannelPut2(DEFAULT_CHANNEL, begin, length, messageEnd, blocking);}
133 size_t PutModifiable2(byte *inString, size_t length, int messageEnd, bool blocking)
134 {return this->ChannelPutModifiable2(DEFAULT_CHANNEL, inString, length, messageEnd, blocking);}
143 virtual size_t ChannelPut2(const std::string &channel, const byte *begin, size_t length, int messageEnd, bool blocking) =0;
144 size_t ChannelPutModifiable2(const std::string &channel, byte *begin, size_t length, int messageEnd, bool blocking)
145 {return ChannelPut2(channel, begin, length, messageEnd, blocking);}
147 virtual bool ChannelFlush(const std::string &channel, bool hardFlush, int propagation=-1, bool blocking=true) =0;
192 size_t TransferTo2(BufferedTransformation &target, lword &transferBytes, const std::string &channel=DEFAULT_CHANNEL, bool blocking=true)
194 size_t CopyRangeTo2(BufferedTransformation &target, lword &begin, lword end=LWORD_MAX, const std::string &channel=DEFAULT_CHANNEL, bool blocking=true) const
203 size_t Put2(const byte *begin, size_t length, int messageEnd, bool blocking)