zmq::fq_t Class Reference

#include <fq.hpp>

Collaboration diagram for zmq::fq_t:

Public Member Functions
	fq_t ()
	~fq_t ()
void	activated (pipe_t *pipe_)
void	attach (pipe_t *pipe_)
blob_t	get_credential () const
bool	has_in ()
void	pipe_terminated (pipe_t *pipe_)
int	recv (msg_t *msg_)
int	recvpipe (msg_t *msg_, pipe_t **pipe_)

Private Types
typedef array_t< pipe_t, 1 >	pipes_t

Private Member Functions
	fq_t (const fq_t &)
const fq_t &	operator= (const fq_t &)

Private Attributes
pipes_t::size_type	active
pipes_t::size_type	current
pipe_t *	last_in
bool	more
pipes_t	pipes
blob_t	saved_credential

Detailed Description

Definition at line 45 of file fq.hpp.

Member Typedef Documentation

typedef array_t<pipe_t, 1> zmq::fq_t::pipes_t

private

Definition at line 64 of file fq.hpp.

Constructor & Destructor Documentation

zmq::fq_t::fq_t

(

)

Definition at line 36 of file fq.cpp.

zmq::fq_t::~fq_t

(

)

Definition at line 44 of file fq.cpp.

References zmq::array_t< T, ID >::empty(), pipes, and zmq_assert.

Here is the call graph for this function:

zmq::fq_t::fq_t ( const fq_t &  )

private

Member Function Documentation

void zmq::fq_t::activated

(

pipe_t *

pipe_

)

Definition at line 76 of file fq.cpp.

References active, zmq::array_t< T, ID >::index(), pipes, and zmq::array_t< T, ID >::swap().

Referenced by zmq::stream_t::xread_activated(), zmq::gather_t::xread_activated(), zmq::pull_t::xread_activated(), zmq::xsub_t::xread_activated(), zmq::server_t::xread_activated(), zmq::client_t::xread_activated(), zmq::router_t::xread_activated(), zmq::dealer_t::xread_activated(), and zmq::dish_t::xread_activated().

Here is the call graph for this function:

Here is the caller graph for this function:

void zmq::fq_t::attach

(

pipe_t *

pipe_

)

Definition at line 49 of file fq.cpp.

References active, pipes, zmq::array_t< T, ID >::push_back(), zmq::array_t< T, ID >::size(), and zmq::array_t< T, ID >::swap().

Referenced by zmq::stream_t::xattach_pipe(), zmq::gather_t::xattach_pipe(), zmq::pull_t::xattach_pipe(), zmq::xsub_t::xattach_pipe(), zmq::server_t::xattach_pipe(), zmq::client_t::xattach_pipe(), zmq::dealer_t::xattach_pipe(), zmq::router_t::xattach_pipe(), zmq::dish_t::xattach_pipe(), and zmq::router_t::xread_activated().

Here is the call graph for this function:

Here is the caller graph for this function:

zmq::blob_t zmq::fq_t::get_credential

(

)

const

Definition at line 158 of file fq.cpp.

References zmq::pipe_t::get_credential(), last_in, and saved_credential.

Referenced by zmq::gather_t::get_credential(), zmq::pull_t::get_credential(), zmq::xsub_t::get_credential(), zmq::client_t::get_credential(), zmq::dealer_t::get_credential(), zmq::dish_t::get_credential(), zmq::server_t::get_credential(), and zmq::router_t::get_credential().

Here is the call graph for this function:

Here is the caller graph for this function:

bool zmq::fq_t::has_in

(

)

Definition at line 134 of file fq.cpp.

References active, current, more, pipes, and zmq::array_t< T, ID >::swap().

Referenced by zmq::gather_t::xhas_in(), zmq::pull_t::xhas_in(), zmq::server_t::xhas_in(), zmq::client_t::xhas_in(), and zmq::dealer_t::xhas_in().

Here is the call graph for this function:

Here is the caller graph for this function:

const fq_t& zmq::fq_t::operator= ( const fq_t &  )

private

void zmq::fq_t::pipe_terminated

(

pipe_t *

pipe_

)

Definition at line 56 of file fq.cpp.

References active, current, zmq::array_t< T, ID >::erase(), zmq::pipe_t::get_credential(), zmq::array_t< T, ID >::index(), last_in, pipes, saved_credential, and zmq::array_t< T, ID >::swap().

Referenced by zmq::stream_t::xpipe_terminated(), zmq::gather_t::xpipe_terminated(), zmq::pull_t::xpipe_terminated(), zmq::server_t::xpipe_terminated(), zmq::xsub_t::xpipe_terminated(), zmq::client_t::xpipe_terminated(), zmq::router_t::xpipe_terminated(), zmq::dealer_t::xpipe_terminated(), and zmq::dish_t::xpipe_terminated().

Here is the call graph for this function:

Here is the caller graph for this function:

int zmq::fq_t::recv

(

msg_t *

msg_

)

Definition at line 83 of file fq.cpp.

References recvpipe().

Referenced by zmq::xsub_t::xhas_in(), zmq::dish_t::xhas_in(), zmq::pull_t::xrecv(), zmq::xsub_t::xrecv(), and zmq::dish_t::xrecv().

Here is the call graph for this function:

Here is the caller graph for this function:

int zmq::fq_t::recvpipe	(	msg_t *	msg_,
		pipe_t **	pipe_
	)

Definition at line 88 of file fq.cpp.

References active, zmq::msg_t::close(), current, errno_assert, zmq::msg_t::flags, zmq::msg_t::init(), last_in, zmq::msg_t::more, more, pipes, zmq::array_t< T, ID >::swap(), and zmq_assert.

Referenced by recv(), zmq::dealer_t::recvpipe(), zmq::stream_t::xhas_in(), zmq::router_t::xhas_in(), zmq::stream_t::xrecv(), zmq::gather_t::xrecv(), zmq::client_t::xrecv(), zmq::server_t::xrecv(), and zmq::router_t::xrecv().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

pipes_t::size_type zmq::fq_t::active

private

Definition at line 69 of file fq.hpp.

Referenced by activated(), attach(), has_in(), pipe_terminated(), and recvpipe().

pipes_t::size_type zmq::fq_t::current

private

Definition at line 77 of file fq.hpp.

Referenced by has_in(), pipe_terminated(), and recvpipe().

pipe_t* zmq::fq_t::last_in

private

Definition at line 74 of file fq.hpp.

Referenced by get_credential(), pipe_terminated(), and recvpipe().

bool zmq::fq_t::more

private

Definition at line 81 of file fq.hpp.

Referenced by has_in(), and recvpipe().

pipes_t zmq::fq_t::pipes

private

Definition at line 65 of file fq.hpp.

Referenced by activated(), attach(), has_in(), pipe_terminated(), recvpipe(), and ~fq_t().

blob_t zmq::fq_t::saved_credential

private

Definition at line 84 of file fq.hpp.

Referenced by get_credential(), and pipe_terminated().