zmq::ypipe_t< T, N > Class Template Reference

#include <ypipe.hpp>

Inheritance diagram for zmq::ypipe_t< T, N >:

Collaboration diagram for zmq::ypipe_t< T, N >:

Public Member Functions
	ypipe_t ()
virtual	~ypipe_t ()
bool	check_read ()
bool	flush ()
bool	probe (bool(*fn)(const T &))
bool	read (T *value_)
bool	unwrite (T *value_)
void	write (const T &value_, bool incomplete_)
Public Member Functions inherited from zmq::ypipe_base_t< T >
virtual	~ypipe_base_t ()

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

Detailed Description

template<typename T, int N>
class zmq::ypipe_t< T, N >

Definition at line 48 of file ypipe.hpp.

Constructor & Destructor Documentation

template<typename T, int N>

zmq::ypipe_t< T, N >::ypipe_t ( )

inline

Definition at line 53 of file ypipe.hpp.

template<typename T, int N>

virtual zmq::ypipe_t< T, N >::~ypipe_t ( )

inlinevirtual

Definition at line 66 of file ypipe.hpp.

template<typename T, int N>

zmq::ypipe_t< T, N >::ypipe_t ( const ypipe_t< T, N > &  )

protected

Member Function Documentation

template<typename T, int N>

bool zmq::ypipe_t< T, N >::check_read ( )

inlinevirtual

Implements zmq::ypipe_base_t< T >.

Definition at line 138 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().

Here is the caller graph for this function:

template<typename T, int N>

bool zmq::ypipe_t< T, N >::flush ( )

inlinevirtual

Implements zmq::ypipe_base_t< T >.

Definition at line 112 of file ypipe.hpp.

Referenced by zmq::mailbox_t::send(), and zmq::mailbox_safe_t::send().

Here is the caller graph for this function:

template<typename T, int N>

const ypipe_t& zmq::ypipe_t< T, N >::operator= ( const ypipe_t< T, N > &  )

protected

template<typename T, int N>

bool zmq::ypipe_t< T, N >::probe ( bool(*)(const T &)  fn )

inlinevirtual

Implements zmq::ypipe_base_t< T >.

Definition at line 179 of file ypipe.hpp.

template<typename T, int N>

bool zmq::ypipe_t< T, N >::read ( T *  value_ )

inlinevirtual

Implements zmq::ypipe_base_t< T >.

Definition at line 163 of file ypipe.hpp.

Referenced by zmq::mailbox_safe_t::mailbox_safe_t(), zmq::mailbox_t::mailbox_t(), zmq::mailbox_t::recv(), and zmq::mailbox_safe_t::recv().

Here is the caller graph for this function:

template<typename T, int N>

bool zmq::ypipe_t< T, N >::unwrite ( T *  value_ )

inlinevirtual

Implements zmq::ypipe_base_t< T >.

Definition at line 100 of file ypipe.hpp.

template<typename T, int N>

void zmq::ypipe_t< T, N >::write ( const T &  value_, bool  incomplete_  )

inlinevirtual

Implements zmq::ypipe_base_t< T >.

Definition at line 83 of file ypipe.hpp.

Referenced by zmq::mailbox_t::send(), and zmq::mailbox_safe_t::send().

Here is the caller graph for this function:

Member Data Documentation

template<typename T, int N>

atomic_ptr_t<T> zmq::ypipe_t< T, N >::c

protected

Definition at line 210 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().

template<typename T, int N>

T* zmq::ypipe_t< T, N >::f

protected

Definition at line 204 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().

template<typename T, int N>

yqueue_t<T, N> zmq::ypipe_t< T, N >::queue

protected

Definition at line 193 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().

template<typename T, int N>

T* zmq::ypipe_t< T, N >::r

protected

Definition at line 201 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().

template<typename T, int N>

T* zmq::ypipe_t< T, N >::w

protected

Definition at line 197 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().