![]() |
libzmq master
The Intelligent Transport Layer
|
#include <ypipe.hpp>
Public Member Functions | |
ypipe_t () | |
virtual | ~ypipe_t () |
bool | check_read () |
bool | flush () |
bool | probe (bool(*fn)(T &)) |
bool | read (T *value_) |
bool | unwrite (T *value_) |
void | write (const T &value_, bool incomplete_) |
Protected Member Functions | |
ypipe_t (const ypipe_t &) | |
const ypipe_t & | operator= (const ypipe_t &) |
Protected Attributes | |
atomic_ptr_t< T > | c |
T * | f |
yqueue_t< T, N > | queue |
T * | r |
T * | w |
zmq::ypipe_t< T, N >::ypipe_t | ( | ) | [inline] |
virtual zmq::ypipe_t< T, N >::~ypipe_t | ( | ) | [inline, virtual] |
zmq::ypipe_t< T, N >::ypipe_t | ( | const ypipe_t< T, N > & | ) | [protected] |
bool zmq::ypipe_t< T, N >::check_read | ( | ) | [inline] |
Definition at line 129 of file ypipe.hpp.
Referenced by zmq::ypipe_t< command_t, command_pipe_granularity >::probe(), and zmq::ypipe_t< command_t, command_pipe_granularity >::read().
bool zmq::ypipe_t< T, N >::flush | ( | ) | [inline] |
const ypipe_t& zmq::ypipe_t< T, N >::operator= | ( | const ypipe_t< T, N > & | ) | [protected] |
bool zmq::ypipe_t< T, N >::probe | ( | bool(*)(T &) | fn | ) | [inline] |
bool zmq::ypipe_t< T, N >::read | ( | T * | value_ | ) | [inline] |
Definition at line 154 of file ypipe.hpp.
Referenced by zmq::mailbox_t::mailbox_t().
bool zmq::ypipe_t< T, N >::unwrite | ( | T * | value_ | ) | [inline] |
void zmq::ypipe_t< T, N >::write | ( | const T & | value_, |
bool | incomplete_ | ||
) | [inline] |
atomic_ptr_t<T> zmq::ypipe_t< T, N >::c [protected] |
Definition at line 201 of file ypipe.hpp.
Referenced by zmq::ypipe_t< command_t, command_pipe_granularity >::check_read(), zmq::ypipe_t< command_t, command_pipe_granularity >::flush(), and zmq::ypipe_t< command_t, command_pipe_granularity >::ypipe_t().
T* zmq::ypipe_t< T, N >::f [protected] |
Definition at line 195 of file ypipe.hpp.
Referenced by zmq::ypipe_t< command_t, command_pipe_granularity >::flush(), zmq::ypipe_t< command_t, command_pipe_granularity >::unwrite(), zmq::ypipe_t< command_t, command_pipe_granularity >::write(), and zmq::ypipe_t< command_t, command_pipe_granularity >::ypipe_t().
yqueue_t<T, N> zmq::ypipe_t< T, N >::queue [protected] |
Definition at line 184 of file ypipe.hpp.
Referenced by zmq::ypipe_t< command_t, command_pipe_granularity >::check_read(), zmq::ypipe_t< command_t, command_pipe_granularity >::probe(), zmq::ypipe_t< command_t, command_pipe_granularity >::read(), zmq::ypipe_t< command_t, command_pipe_granularity >::unwrite(), zmq::ypipe_t< command_t, command_pipe_granularity >::write(), and zmq::ypipe_t< command_t, command_pipe_granularity >::ypipe_t().
T* zmq::ypipe_t< T, N >::r [protected] |
Definition at line 192 of file ypipe.hpp.
Referenced by zmq::ypipe_t< command_t, command_pipe_granularity >::check_read(), and zmq::ypipe_t< command_t, command_pipe_granularity >::ypipe_t().
T* zmq::ypipe_t< T, N >::w [protected] |
Definition at line 188 of file ypipe.hpp.
Referenced by zmq::ypipe_t< command_t, command_pipe_granularity >::flush(), and zmq::ypipe_t< command_t, command_pipe_granularity >::ypipe_t().