zmq::dist_t Class Reference

#include <dist.hpp>

Collaboration diagram for zmq::dist_t:

List of all members.

Public Member Functions
	dist_t ()
	~dist_t ()
void	activated (class pipe_t *pipe_)
void	attach (class pipe_t *pipe_)
bool	has_out ()
void	match (class pipe_t *pipe_)
int	send_to_all (class msg_t *msg_, int flags_)
int	send_to_matching (class msg_t *msg_, int flags_)
void	terminated (class pipe_t *pipe_)
void	unmatch ()
Private Types
typedef array_t< class pipe_t, 2 >	pipes_t
Private Member Functions
	dist_t (const dist_t &)
void	distribute (class msg_t *msg_, int flags_)
const dist_t &	operator= (const dist_t &)
bool	write (class pipe_t *pipe_, class msg_t *msg_)
Private Attributes
pipes_t::size_type	active
pipes_t::size_type	eligible
pipes_t::size_type	matching
bool	more
pipes_t	pipes

---

Detailed Description

Definition at line 34 of file dist.hpp.

---

Member Typedef Documentation

typedef array_t<class pipe_t, 2> zmq::dist_t::pipes_t [private]

Definition at line 75 of file dist.hpp.

---

Constructor & Destructor Documentation

zmq::dist_t::dist_t

(

)

Definition at line 28 of file dist.cpp.

zmq::dist_t::~dist_t

(

)

Definition at line 36 of file dist.cpp.

References zmq_assert.

zmq::dist_t::dist_t

(

const dist_t &

)

[private]

---

Member Function Documentation

void zmq::dist_t::activated

(

class pipe_t *

pipe_

)

Definition at line 92 of file dist.cpp.

void zmq::dist_t::attach

(

class pipe_t *

pipe_

)

Definition at line 41 of file dist.cpp.

void zmq::dist_t::distribute	(	class msg_t *	msg_,
		int	flags_
	)		[private]

Definition at line 129 of file dist.cpp.

References zmq::msg_t::add_refs(), zmq::msg_t::close(), errno_assert, zmq::msg_t::init(), zmq::msg_t::is_vsm(), zmq::msg_t::rm_refs(), unlikely, and zmq_assert.

Here is the call graph for this function:

bool zmq::dist_t::has_out

(

)

Definition at line 168 of file dist.cpp.

void zmq::dist_t::match

(

class pipe_t *

pipe_

)

Definition at line 59 of file dist.cpp.

Referenced by zmq::xpub_t::mark_as_matching().

Here is the caller graph for this function:

const dist_t& zmq::dist_t::operator=

(

const dist_t &

)

[private]

int zmq::dist_t::send_to_all	(	class msg_t *	msg_,
		int	flags_
	)

Definition at line 106 of file dist.cpp.

int zmq::dist_t::send_to_matching	(	class msg_t *	msg_,
		int	flags_
	)

Definition at line 112 of file dist.cpp.

References zmq::msg_t::flags, and zmq::msg_t::more.

void zmq::dist_t::terminated

(

class pipe_t *

pipe_

)

Definition at line 79 of file dist.cpp.

void zmq::dist_t::unmatch

(

)

Definition at line 74 of file dist.cpp.

bool zmq::dist_t::write	(	class pipe_t *	pipe_,
		class msg_t *	msg_
	)		[private]

Definition at line 173 of file dist.cpp.

References zmq::msg_t::flags, zmq::pipe_t::flush(), zmq::msg_t::more, and zmq::pipe_t::write().

Here is the call graph for this function:

---

Member Data Documentation

pipes_t::size_type zmq::dist_t::active [private]

Definition at line 84 of file dist.hpp.

pipes_t::size_type zmq::dist_t::eligible [private]

Definition at line 91 of file dist.hpp.

pipes_t::size_type zmq::dist_t::matching [private]

Definition at line 79 of file dist.hpp.

bool zmq::dist_t::more [private]

Definition at line 94 of file dist.hpp.

pipes_t zmq::dist_t::pipes [private]

Definition at line 76 of file dist.hpp.

---

The documentation for this class was generated from the following files:

• src/dist.hpp
• src/dist.cpp