zmq::dist_t Class Reference

#include <dist.hpp>

Public Member Functions
void	activated (zmq::pipe_t *pipe_)
void	attach (zmq::pipe_t *pipe_)
bool	check_hwm ()
	dist_t ()
bool	has_pipe (zmq::pipe_t *pipe_)
void	match (zmq::pipe_t *pipe_)
void	pipe_terminated (zmq::pipe_t *pipe_)
void	reverse_match ()
int	send_to_all (zmq::msg_t *msg_)
int	send_to_matching (zmq::msg_t *msg_)
void	unmatch ()
	~dist_t ()

Static Public Member Functions
static bool	has_out ()

Private Types
typedef array_t< zmq::pipe_t, 2 >	pipes_t

Private Member Functions
void	distribute (zmq::msg_t *msg_)
bool	write (zmq::pipe_t *pipe_, zmq::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 18 of file dist.hpp.

Member Typedef Documentation

pipes_t

typedef array_t<zmq::pipe_t, 2> zmq::dist_t::pipes_t

private

Definition at line 66 of file dist.hpp.

Constructor & Destructor Documentation

dist_t()

zmq::dist_t::dist_t

(

)

Definition at line 10 of file dist.cpp.

~dist_t()

zmq::dist_t::~dist_t

(

)

Definition at line 15 of file dist.cpp.

Member Function Documentation

activated()

void zmq::dist_t::activated

(

zmq::pipe_t *

pipe_

)

Definition at line 105 of file dist.cpp.

attach()

void zmq::dist_t::attach

(

zmq::pipe_t *

pipe_

)

Definition at line 20 of file dist.cpp.

check_hwm()

bool zmq::dist_t::check_hwm

(

)

Definition at line 212 of file dist.cpp.

distribute()

void zmq::dist_t::distribute ( zmq::msg_t *  msg_ )

private

Definition at line 144 of file dist.cpp.

has_out()

bool zmq::dist_t::has_out ( )

static

Definition at line 191 of file dist.cpp.

has_pipe()

bool zmq::dist_t::has_pipe

(

zmq::pipe_t *

pipe_

)

Definition at line 37 of file dist.cpp.

match()

void zmq::dist_t::match

(

zmq::pipe_t *

pipe_

)

Definition at line 49 of file dist.cpp.

pipe_terminated()

void zmq::dist_t::pipe_terminated

(

zmq::pipe_t *

pipe_

)

Definition at line 85 of file dist.cpp.

reverse_match()

void zmq::dist_t::reverse_match

(

)

Definition at line 64 of file dist.cpp.

send_to_all()

int zmq::dist_t::send_to_all

(

zmq::msg_t *

msg_

)

Definition at line 121 of file dist.cpp.

send_to_matching()

int zmq::dist_t::send_to_matching

(

zmq::msg_t *

msg_

)

Definition at line 127 of file dist.cpp.

unmatch()

void zmq::dist_t::unmatch

(

)

Definition at line 80 of file dist.cpp.

write()

bool zmq::dist_t::write ( zmq::pipe_t *  pipe_, zmq::msg_t *  msg_  )

private

Definition at line 196 of file dist.cpp.

Member Data Documentation

_active

pipes_t::size_type zmq::dist_t::_active

private

Definition at line 75 of file dist.hpp.

_eligible

pipes_t::size_type zmq::dist_t::_eligible

private

Definition at line 82 of file dist.hpp.

_matching

pipes_t::size_type zmq::dist_t::_matching

private

Definition at line 70 of file dist.hpp.

_more

bool zmq::dist_t::_more

private

Definition at line 85 of file dist.hpp.

_pipes

pipes_t zmq::dist_t::_pipes

private

Definition at line 67 of file dist.hpp.

---

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

• dist.hpp
• dist.cpp