libzmq master
The Intelligent Transport Layer
Public Member Functions | Protected Member Functions | Protected Attributes | Private Types | Private Member Functions | Private Attributes

zmq::own_t Class Reference

#include <own.hpp>

Inheritance diagram for zmq::own_t:
Collaboration diagram for zmq::own_t:

List of all members.

Public Member Functions

 own_t (class ctx_t *parent_, uint32_t tid_)
 own_t (class io_thread_t *io_thread_, const options_t &options_)
ctx_t * get_ctx ()
uint32_t get_tid ()
void inc_seqnum ()
void process_command (struct command_t &cmd_)
void register_term_acks (int count_)
void unregister_term_ack ()

Protected Member Functions

virtual ~own_t ()
class io_thread_t * choose_io_thread (uint64_t affinity_)
void destroy_socket (class socket_base_t *socket_)
struct endpoint_t find_endpoint (const char *addr_)
bool is_terminating ()
void launch_child (own_t *object_)
void launch_sibling (own_t *object_)
void log (const char *format_,...)
virtual void process_activate_read ()
virtual void process_activate_write (uint64_t msgs_read_)
virtual void process_attach (struct i_engine *engine_)
virtual void process_bind (class pipe_t *pipe_)
virtual void process_destroy ()
virtual void process_hiccup (void *pipe_)
virtual void process_pipe_term ()
virtual void process_pipe_term_ack ()
virtual void process_plug ()
virtual void process_reap (class socket_base_t *socket_)
virtual void process_reaped ()
virtual void process_stop ()
void process_term (int linger_)
int register_endpoint (const char *addr_, struct endpoint_t &endpoint_)
void send_activate_read (class pipe_t *destination_)
void send_activate_write (class pipe_t *destination_, uint64_t msgs_read_)
void send_attach (class session_base_t *destination_, struct i_engine *engine_, bool inc_seqnum_=true)
void send_bind (class own_t *destination_, class pipe_t *pipe_, bool inc_seqnum_=true)
void send_done ()
void send_hiccup (class pipe_t *destination_, void *pipe_)
void send_own (class own_t *destination_, class own_t *object_)
void send_pipe_term (class pipe_t *destination_)
void send_pipe_term_ack (class pipe_t *destination_)
void send_plug (class own_t *destination_, bool inc_seqnum_=true)
void send_reap (class socket_base_t *socket_)
void send_reaped ()
void send_stop ()
void send_term (class own_t *destination_, int linger_)
void send_term_ack (class own_t *destination_)
void send_term_req (class own_t *destination_, class own_t *object_)
void terminate ()
void unregister_endpoints (class socket_base_t *socket_)

Protected Attributes

options_t options

Private Types

typedef std::set< own_t * > owned_t

Private Member Functions

 own_t (const own_t &)
void check_term_acks ()
const own_t & operator= (const own_t &)
void process_own (own_t *object_)
void process_seqnum ()
void process_term_ack ()
void process_term_req (own_t *object_)
void set_owner (own_t *owner_)

Private Attributes

owned_t owned
own_t * owner
uint64_t processed_seqnum
atomic_counter_t sent_seqnum
int term_acks
bool terminating

Detailed Description

Definition at line 38 of file own.hpp.

Member Typedef Documentation

typedef std::set<own_t*> zmq::own_t::owned_t [private]

Definition at line 131 of file own.hpp.

Constructor & Destructor Documentation

zmq::own_t::own_t ( class ctx_t *  parent_,
uint32_t  tid_ 
)

Definition at line 25 of file own.cpp.

zmq::own_t::own_t ( class io_thread_t *  io_thread_,
const options_t &  options_ 
)

Definition at line 35 of file own.cpp.

zmq::own_t::~own_t ( ) [protected, virtual]

Definition at line 46 of file own.cpp.

zmq::own_t::own_t ( const own_t &  ) [private]

Member Function Documentation

void zmq::own_t::check_term_acks ( ) [private]

Definition at line 197 of file own.cpp.

References zmq_assert.

zmq::io_thread_t * zmq::object_t::choose_io_thread ( uint64_t  affinity_) [protected, inherited]

Definition at line 160 of file object.cpp.

References zmq::object_t::choose_io_thread().

Referenced by zmq::object_t::choose_io_thread().

Here is the call graph for this function:

Here is the caller graph for this function:

void zmq::object_t::destroy_socket ( class socket_base_t *  socket_) [protected, inherited]

Definition at line 147 of file object.cpp.

zmq::endpoint_t zmq::object_t::find_endpoint ( const char *  addr_) [read, protected, inherited]

Definition at line 142 of file object.cpp.

zmq::ctx_t * zmq::object_t::get_ctx ( ) [inherited]

Definition at line 54 of file object.cpp.

uint32_t zmq::object_t::get_tid ( ) [inherited]

Definition at line 49 of file object.cpp.

Referenced by zmq::ctx_t::destroy_socket(), and zmq::object_t::send_command().

Here is the caller graph for this function:

void zmq::own_t::inc_seqnum ( )

Definition at line 56 of file own.cpp.

Referenced by zmq::ctx_t::find_endpoint(), zmq::tcp_listener_t::in_event(), zmq::ipc_listener_t::in_event(), zmq::object_t::send_attach(), zmq::object_t::send_bind(), zmq::object_t::send_own(), and zmq::object_t::send_plug().

Here is the caller graph for this function:

bool zmq::own_t::is_terminating ( ) [protected]

Definition at line 156 of file own.cpp.

void zmq::own_t::launch_child ( own_t *  object_) [protected]

Definition at line 71 of file own.cpp.

References set_owner().

Here is the call graph for this function:

void zmq::own_t::launch_sibling ( own_t *  object_) [protected]

Definition at line 83 of file own.cpp.

References set_owner().

Here is the call graph for this function:

void zmq::object_t::log ( const char *  format_,
  ... 
) [protected, inherited]

Definition at line 152 of file object.cpp.

const own_t& zmq::own_t::operator= ( const own_t &  ) [private]
void zmq::object_t::process_activate_read ( ) [protected, virtual, inherited]

Reimplemented in zmq::pipe_t.

Definition at line 390 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_activate_write ( uint64_t  msgs_read_) [protected, virtual, inherited]

Reimplemented in zmq::pipe_t.

Definition at line 395 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_attach ( struct i_engine *  engine_) [protected, virtual, inherited]

Reimplemented in zmq::session_base_t.

Definition at line 380 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_bind ( class pipe_t *  pipe_) [protected, virtual, inherited]

Reimplemented in zmq::socket_base_t.

Definition at line 385 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_command ( struct command_t &  cmd_) [inherited]

Definition at line 59 of file object.cpp.

References zmq::command_t::activate_read, zmq::command_t::activate_write, zmq::command_t::args, zmq::command_t::attach, zmq::command_t::bind, zmq::command_t::hiccup, zmq::command_t::own, zmq::command_t::pipe_term, zmq::command_t::pipe_term_ack, zmq::command_t::plug, zmq::command_t::reap, zmq::command_t::reaped, zmq::command_t::stop, zmq::command_t::term, zmq::command_t::term_ack, zmq::command_t::term_req, zmq::command_t::type, and zmq_assert.

Referenced by zmq::reaper_t::in_event(), zmq::io_thread_t::in_event(), and zmq::socket_base_t::process_commands().

Here is the caller graph for this function:

void zmq::own_t::process_destroy ( ) [protected, virtual]

Reimplemented in zmq::socket_base_t.

Definition at line 215 of file own.cpp.

Referenced by zmq::socket_base_t::check_destroy().

Here is the caller graph for this function:

void zmq::object_t::process_hiccup ( void *  pipe_) [protected, virtual, inherited]

Reimplemented in zmq::pipe_t.

Definition at line 400 of file object.cpp.

References zmq_assert.

void zmq::own_t::process_own ( own_t *  object_) [private, virtual]

Reimplemented from zmq::object_t.

Definition at line 124 of file own.cpp.

void zmq::object_t::process_pipe_term ( ) [protected, virtual, inherited]

Reimplemented in zmq::pipe_t.

Definition at line 405 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_pipe_term_ack ( ) [protected, virtual, inherited]

Reimplemented in zmq::pipe_t.

Definition at line 410 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_plug ( ) [protected, virtual, inherited]

Reimplemented in zmq::ipc_connecter_t, zmq::ipc_listener_t, zmq::session_base_t, zmq::tcp_connecter_t, and zmq::tcp_listener_t.

Definition at line 370 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_reap ( class socket_base_t *  socket_) [protected, virtual, inherited]

Reimplemented in zmq::reaper_t.

Definition at line 430 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_reaped ( ) [protected, virtual, inherited]

Reimplemented in zmq::reaper_t.

Definition at line 435 of file object.cpp.

References zmq_assert.

void zmq::own_t::process_seqnum ( ) [private, virtual]

Reimplemented from zmq::object_t.

Definition at line 62 of file own.cpp.

void zmq::object_t::process_stop ( ) [protected, virtual, inherited]

Reimplemented in zmq::io_thread_t, zmq::reaper_t, and zmq::socket_base_t.

Definition at line 365 of file object.cpp.

References zmq_assert.

void zmq::own_t::process_term ( int  linger_) [protected, virtual]

Reimplemented from zmq::object_t.

Reimplemented in zmq::ipc_listener_t, zmq::session_base_t, zmq::socket_base_t, and zmq::tcp_listener_t.

Definition at line 161 of file own.cpp.

References zmq_assert.

Referenced by zmq::session_base_t::proceed_with_term(), zmq::tcp_listener_t::process_term(), zmq::socket_base_t::process_term(), and zmq::ipc_listener_t::process_term().

Here is the caller graph for this function:

void zmq::own_t::process_term_ack ( ) [private, virtual]

Reimplemented from zmq::object_t.

Definition at line 192 of file own.cpp.

void zmq::own_t::process_term_req ( own_t *  object_) [private, virtual]

Reimplemented from zmq::object_t.

Definition at line 101 of file own.cpp.

int zmq::object_t::register_endpoint ( const char *  addr_,
struct endpoint_t &  endpoint_ 
) [protected, inherited]

Definition at line 132 of file object.cpp.

void zmq::own_t::register_term_acks ( int  count_)

Definition at line 178 of file own.cpp.

void zmq::object_t::send_activate_read ( class pipe_t *  destination_) [protected, inherited]

Definition at line 237 of file object.cpp.

References zmq::command_t::activate_read, zmq::command_t::destination, and zmq::command_t::type.

void zmq::object_t::send_activate_write ( class pipe_t *  destination_,
uint64_t  msgs_read_ 
) [protected, inherited]

Definition at line 248 of file object.cpp.

References zmq::command_t::activate_write, zmq::command_t::args, zmq::command_t::destination, and zmq::command_t::type.

void zmq::object_t::send_attach ( class session_base_t *  destination_,
struct i_engine *  engine_,
bool  inc_seqnum_ = true 
) [protected, inherited]

Definition at line 205 of file object.cpp.

References zmq::command_t::args, zmq::command_t::attach, zmq::command_t::destination, inc_seqnum(), and zmq::command_t::type.

Here is the call graph for this function:

void zmq::object_t::send_bind ( class own_t *  destination_,
class pipe_t *  pipe_,
bool  inc_seqnum_ = true 
) [protected, inherited]

Definition at line 221 of file object.cpp.

References zmq::command_t::args, zmq::command_t::bind, zmq::command_t::destination, inc_seqnum(), and zmq::command_t::type.

Here is the call graph for this function:

void zmq::object_t::send_done ( ) [protected, inherited]

Definition at line 354 of file object.cpp.

References zmq::command_t::destination, zmq::command_t::done, zmq::ctx_t::term_tid, and zmq::command_t::type.

void zmq::object_t::send_hiccup ( class pipe_t *  destination_,
void *  pipe_ 
) [protected, inherited]

Definition at line 261 of file object.cpp.

References zmq::command_t::args, zmq::command_t::destination, zmq::command_t::hiccup, and zmq::command_t::type.

void zmq::object_t::send_own ( class own_t *  destination_,
class own_t *  object_ 
) [protected, inherited]

Definition at line 192 of file object.cpp.

References zmq::command_t::args, zmq::command_t::destination, inc_seqnum(), zmq::command_t::own, and zmq::command_t::type.

Here is the call graph for this function:

void zmq::object_t::send_pipe_term ( class pipe_t *  destination_) [protected, inherited]

Definition at line 273 of file object.cpp.

References zmq::command_t::destination, zmq::command_t::pipe_term, and zmq::command_t::type.

void zmq::object_t::send_pipe_term_ack ( class pipe_t *  destination_) [protected, inherited]

Definition at line 284 of file object.cpp.

References zmq::command_t::destination, zmq::command_t::pipe_term_ack, and zmq::command_t::type.

void zmq::object_t::send_plug ( class own_t *  destination_,
bool  inc_seqnum_ = true 
) [protected, inherited]

Definition at line 178 of file object.cpp.

References zmq::command_t::destination, inc_seqnum(), zmq::command_t::plug, and zmq::command_t::type.

Here is the call graph for this function:

void zmq::object_t::send_reap ( class socket_base_t *  socket_) [protected, inherited]

Definition at line 331 of file object.cpp.

References zmq::command_t::args, zmq::command_t::destination, zmq::command_t::reap, and zmq::command_t::type.

void zmq::object_t::send_reaped ( ) [protected, inherited]

Definition at line 343 of file object.cpp.

References zmq::command_t::destination, zmq::command_t::reaped, and zmq::command_t::type.

void zmq::object_t::send_stop ( ) [protected, inherited]

Definition at line 165 of file object.cpp.

References zmq::command_t::destination, zmq::command_t::stop, and zmq::command_t::type.

void zmq::object_t::send_term ( class own_t *  destination_,
int  linger_ 
) [protected, inherited]

Definition at line 308 of file object.cpp.

References zmq::command_t::args, zmq::command_t::destination, zmq::command_t::term, and zmq::command_t::type.

void zmq::object_t::send_term_ack ( class own_t *  destination_) [protected, inherited]

Definition at line 320 of file object.cpp.

References zmq::command_t::destination, zmq::command_t::term_ack, and zmq::command_t::type.

void zmq::object_t::send_term_req ( class own_t *  destination_,
class own_t *  object_ 
) [protected, inherited]

Definition at line 295 of file object.cpp.

References zmq::command_t::args, zmq::command_t::destination, zmq::command_t::term_req, and zmq::command_t::type.

void zmq::own_t::set_owner ( own_t *  owner_) [private]

Definition at line 50 of file own.cpp.

References zmq_assert.

Referenced by launch_child(), and launch_sibling().

Here is the caller graph for this function:

void zmq::own_t::terminate ( ) [protected]

Definition at line 138 of file own.cpp.

void zmq::object_t::unregister_endpoints ( class socket_base_t *  socket_) [protected, inherited]

Definition at line 137 of file object.cpp.

void zmq::own_t::unregister_term_ack ( )

Definition at line 183 of file own.cpp.

References zmq_assert.

Member Data Documentation

options_t zmq::own_t::options [protected]

Definition at line 98 of file own.hpp.

Referenced by zmq::pair_t::pair_t(), zmq::pub_t::pub_t(), zmq::pull_t::pull_t(), zmq::push_t::push_t(), zmq::rep_t::rep_t(), zmq::req_t::req_t(), zmq::sub_t::sub_t(), zmq::xpub_t::xpub_t(), zmq::xrep_t::xrep_t(), zmq::xreq_t::xreq_t(), and zmq::xsub_t::xsub_t().

owned_t zmq::own_t::owned [private]

Definition at line 132 of file own.hpp.

own_t* zmq::own_t::owner [private]

Definition at line 127 of file own.hpp.

uint64_t zmq::own_t::processed_seqnum [private]

Definition at line 123 of file own.hpp.

atomic_counter_t zmq::own_t::sent_seqnum [private]

Definition at line 120 of file own.hpp.

int zmq::own_t::term_acks [private]

Definition at line 135 of file own.hpp.

bool zmq::own_t::terminating [private]

Definition at line 117 of file own.hpp.

The documentation for this class was generated from the following files:
 All Classes Files Functions Variables Typedefs Enumerations Enumerator Friends Defines
Generated on Tue Nov 8 2011 10:17:25 for libzmq by  doxygen 1.7.3