30 #ifndef __ZMQ_YPIPE_HPP_INCLUDED__ 31 #define __ZMQ_YPIPE_HPP_INCLUDED__ 35 #include "platform.hpp" 74 #ifdef ZMQ_HAVE_OPENVMS 76 #pragma message disable(UNINIT) 83 inline void write (
const T &value_,
bool incomplete_)
86 queue.back () = value_;
94 #ifdef ZMQ_HAVE_OPENVMS 95 #pragma message restore 105 *value_ =
queue.back ();
119 if (
c.cas (
w,
f) !=
w) {
148 r =
c.cas (&
queue.front (), NULL);
154 if (&
queue.front () ==
r || !
r)
171 *value_ =
queue.front ();
179 inline bool probe (
bool (*fn)(
const T &))
184 return (*fn) (
queue.front ());
bool probe(bool(*fn)(const T &))
void write(const T &value_, bool incomplete_)
const ypipe_t & operator=(const ypipe_t &)