err.hpp File Reference

#include <assert.h>
#include <errno.h>
#include <string.h>
#include <stdlib.h>
#include <stdio.h>
#include "platform.hpp"
#include <netdb.h>
#include "likely.hpp"
#include "../include/zmq.h"

Include dependency graph for err.hpp:

Go to the source code of this file.

Namespaces
	zmq

Macros
#define	alloc_assert(x)
#define	EPROTO   0
#define	errno_assert(x)
#define	gai_assert(x)
#define	posix_assert(x)
#define	zmq_assert(x)

Functions
const char *	zmq::errno_to_string (int errno_)
void	zmq::print_backtrace (void)
void	zmq::zmq_abort (const char *errmsg_)

Macro Definition Documentation

#define alloc_assert

(

x

)

Value:

do {\
        if (unlikely (!x)) {\
            fprintf (stderr, "FATAL ERROR: OUT OF MEMORY (%s:%d)\n",\
                __FILE__, __LINE__);\
            zmq::zmq_abort ("FATAL ERROR: OUT OF MEMORY");\
        }\
    } while (false)

Definition at line 159 of file err.hpp.

Referenced by zmq::trie_t::add(), zmq::mtrie_t::add_helper(), zmq::shared_message_memory_allocator::allocate(), zmq::socket_base_t::bind(), zmq::c_single_allocator::c_single_allocator(), zmq::socket_base_t::connect(), zmq::socks_connecter_t::connect_to_proxy(), zmq::session_base_t::create(), zmq::socket_base_t::create(), zmq::ctx_t::create_socket(), zmq::encoder_base_t< raw_encoder_t >::encoder_base_t(), zmq::stream_engine_t::handshake(), zmq::pipe_t::hiccup(), zmq::tcp_listener_t::in_event(), zmq::ipc_listener_t::in_event(), zmq::socks_connecter_t::in_event(), zmq::io_thread_t::io_thread_t(), zmq::null_mechanism_t::next_handshake_command(), zmq::tcp_connecter_t::open(), zmq::tcp_connecter_t::out_event(), zmq::ipc_connecter_t::out_event(), zmq::pipepair(), zmq::stream_engine_t::plug(), zmq::plain_client_t::produce_initiate(), zmq::plain_server_t::produce_ready(), zmq::yqueue_t< command_t, N >::push(), zmq::reaper_t::reaper_t(), zmq::socket_poller_t::rebuild(), zmq::trie_t::rm(), zmq::mtrie_t::rm_helper(), zmq::session_base_t::start_connecting(), zmq::socket_base_t::term_endpoint(), zmq::yqueue_t< command_t, N >::yqueue_t(), zmq_atomic_counter_new(), zmq_ctx_new(), zmq_poll(), zmq_poller_new(), zmq_stopwatch_start(), and zmq_timers_new().

#define EPROTO   0

Definition at line 58 of file err.hpp.

Referenced by zmq::tcp_listener_t::accept(), zmq::ipc_listener_t::accept(), zmq::v1_decoder_t::eight_byte_size_ready(), zmq::stream_engine_t::next_handshake_command(), zmq::v1_decoder_t::one_byte_size_ready(), zmq::mechanism_t::parse_metadata(), zmq::plain_client_t::process_error(), zmq::null_mechanism_t::process_error_command(), zmq::plain_client_t::process_handshake_command(), zmq::plain_server_t::process_handshake_command(), zmq::null_mechanism_t::process_handshake_command(), zmq::stream_engine_t::process_handshake_command(), zmq::plain_server_t::process_hello(), zmq::plain_server_t::process_initiate(), zmq::plain_client_t::process_ready(), zmq::plain_client_t::process_welcome(), zmq::null_mechanism_t::receive_and_process_zap_reply(), and zmq::plain_server_t::receive_and_process_zap_reply().

#define errno_assert

(

x

)

Value:

do {\
        if (unlikely (!(x))) {\
            const char *errstr = strerror (errno);\
            fprintf (stderr, "%s (%s:%d)\n", errstr, __FILE__, __LINE__);\
            zmq::zmq_abort (errstr);\
        }\
    } while (false)

Definition at line 129 of file err.hpp.

Referenced by zmq::tcp_listener_t::accept(), zmq::ipc_listener_t::accept(), zmq::socks_connecter_t::check_proxy_connection(), zmq::session_base_t::clean_pipes(), zmq::tcp_listener_t::close(), zmq::ipc_listener_t::close(), zmq::ipc_connecter_t::close(), zmq::tcp_connecter_t::close(), zmq::socks_connecter_t::close(), zmq::socket_base_t::connect(), zmq::tcp_connecter_t::connect(), zmq::ipc_connecter_t::connect(), zmq::ctx_t::connect_inproc_sockets(), zmq::raw_decoder_t::decode(), zmq::dish_t::dish_t(), zmq::dist_t::distribute(), zmq::v1_decoder_t::eight_byte_size_ready(), zmq::enable_ipv4_mapping(), zmq::encoder_base_t< raw_encoder_t >::encode(), zmq::get_peer_ip_address(), zmq::socket_base_t::getsockopt(), zmq::stream_engine_t::identity_msg(), zmq::udp_engine_t::in_event(), zmq::reaper_t::in_event(), zmq::tcp_listener_t::in_event(), zmq::io_thread_t::in_event(), zmq::ipc_listener_t::in_event(), zmq::signaler_t::make_fdpair(), zmq::stream_engine_t::mechanism_ready(), zmq::null_mechanism_t::next_handshake_command(), zmq::clock_t::now_us(), zmq::v1_decoder_t::one_byte_size_ready(), zmq::open_socket(), zmq::udp_engine_t::out_event(), zmq::mechanism_t::peer_identity(), zmq::udp_engine_t::plug(), zmq::session_base_t::process_attach(), zmq::plain_client_t::process_handshake_command(), zmq::null_mechanism_t::process_handshake_command(), zmq::plain_server_t::process_handshake_command(), zmq::pipe_t::process_hiccup(), zmq::stream_engine_t::process_identity_msg(), zmq::pipe_t::process_pipe_term_ack(), zmq::plain_client_t::produce_hello(), zmq::plain_client_t::produce_initiate(), zmq::stream_engine_t::produce_ping_message(), zmq::stream_engine_t::produce_pong_message(), zmq::plain_server_t::produce_ready(), zmq::plain_server_t::produce_welcome(), zmq::radio_session_t::pull_msg(), zmq::dish_session_t::pull_msg(), zmq::session_base_t::push_msg(), zmq::radio_session_t::push_msg(), zmq::dish_session_t::push_msg(), zmq::raw_decoder_t::raw_decoder_t(), zmq::null_mechanism_t::receive_and_process_zap_reply(), zmq::plain_server_t::receive_and_process_zap_reply(), zmq::mailbox_t::recv(), zmq::signaler_t::recv(), zmq::mailbox_safe_t::recv(), zmq::signaler_t::recv_failable(), zmq::fq_t::recvpipe(), zmq::pipe_t::rollback(), zmq::signaler_t::send(), zmq::xsub_t::send_subscription(), zmq::dish_t::send_subscriptions(), zmq::null_mechanism_t::send_zap_request(), zmq::plain_server_t::send_zap_request(), zmq::lb_t::sendpipe(), zmq::tcp_listener_t::set_address(), zmq::set_ip_type_of_service(), zmq::set_tcp_receive_buffer(), zmq::set_tcp_send_buffer(), zmq::v2_decoder_t::size_ready(), zmq::session_base_t::start_connecting(), zmq::stream_engine_t::stream_engine_t(), zmq::tcp_read(), zmq::tcp_write(), zmq::ctx_t::terminate(), thread_routine(), zmq::tune_tcp_keepalives(), zmq::tune_tcp_maxrt(), zmq::tune_tcp_socket(), zmq::unblock_socket(), zmq::v1_decoder_t::v1_decoder_t(), zmq::v2_decoder_t::v2_decoder_t(), zmq::signaler_t::wait(), zmq::socket_poller_t::wait(), zmq::stream_engine_t::write_credential(), zmq::stream_engine_t::write_subscription_msg(), zmq::session_base_t::write_zap_msg(), zmq::dealer_t::xattach_pipe(), zmq::router_t::xattach_pipe(), zmq::stream_t::xhas_in(), zmq::xsub_t::xhas_in(), zmq::router_t::xhas_in(), zmq::dish_t::xhas_in(), zmq::dish_t::xjoin(), zmq::dish_t::xleave(), zmq::rep_t::xrecv(), zmq::req_t::xrecv(), zmq::stream_t::xrecv(), zmq::pair_t::xrecv(), zmq::xsub_t::xrecv(), zmq::router_t::xrecv(), zmq::xpub_t::xrecv(), zmq::dish_t::xrecv(), zmq::req_t::xsend(), zmq::stream_t::xsend(), zmq::pair_t::xsend(), zmq::xsub_t::xsend(), zmq::server_t::xsend(), zmq::router_t::xsend(), zmq::sub_t::xsetsockopt(), zmq::xpub_t::xsetsockopt(), zmq::xsub_t::xsub_t(), zmq::session_base_t::zap_connect(), zmq_poll(), zmq_recv(), zmq_recviov(), zmq_send(), zmq_send_const(), zmq_sendiov(), zmq::dish_t::~dish_t(), zmq::raw_decoder_t::~raw_decoder_t(), zmq::signaler_t::~signaler_t(), zmq::stream_engine_t::~stream_engine_t(), zmq::udp_engine_t::~udp_engine_t(), zmq::v1_decoder_t::~v1_decoder_t(), zmq::v2_decoder_t::~v2_decoder_t(), and zmq::xsub_t::~xsub_t().

#define gai_assert

(

x

)

Value:

do {\
        if (unlikely (x)) {\
            const char *errstr = gai_strerror (x);\
            fprintf (stderr, "%s (%s:%d)\n", errstr, __FILE__, __LINE__);\
            zmq::zmq_abort (errstr);\
        }\
    } while (false)

Definition at line 149 of file err.hpp.

#define posix_assert

(

x

)

Value:

do {\
        if (unlikely (x)) {\
            const char *errstr = strerror (x);\
            fprintf (stderr, "%s (%s:%d)\n", errstr, __FILE__, __LINE__);\
            zmq::zmq_abort (errstr);\
        }\
    } while (false)

Definition at line 139 of file err.hpp.

Referenced by zmq::condition_variable_t::broadcast(), zmq::condition_variable_t::condition_variable_t(), zmq::mutex_t::lock(), zmq::mutex_t::mutex_t(), zmq::thread_t::setSchedulingParameters(), zmq::thread_t::start(), zmq::thread_t::stop(), thread_routine(), zmq::mutex_t::try_lock(), zmq::mutex_t::unlock(), zmq::condition_variable_t::wait(), zmq::condition_variable_t::~condition_variable_t(), and zmq::mutex_t::~mutex_t().

#define zmq_assert

(

x

)

Value:

do {\
        if (unlikely (!(x))) {\
            fprintf (stderr, "Assertion failed: %s (%s:%d)\n", #x, \
                __FILE__, __LINE__);\
            zmq::zmq_abort (#x);\
        }\
    } while (false)

Definition at line 119 of file err.hpp.

Referenced by zmq::tcp_listener_t::accept(), zmq::ipc_listener_t::accept(), zmq::trie_t::add(), zmq::mechanism_t::add_property(), zmq::msg_t::add_refs(), zmq::trie_t::apply_helper(), zmq::session_base_t::attach_pipe(), zmq::socket_base_t::bind(), zmq::shared_message_memory_allocator::call_dec_ref(), zmq::poller_base_t::cancel_timer(), zmq::socks_connecter_t::check_proxy_connection(), zmq::pipe_t::check_read(), zmq::own_t::check_term_acks(), zmq::session_base_t::clean_pipes(), zmq::tcp_listener_t::close(), zmq::ipc_listener_t::close(), zmq::tcp_connecter_t::close(), zmq::ipc_connecter_t::close(), zmq::msg_t::close(), zmq::socks_connecter_t::close(), zmq::socket_base_t::connect(), zmq::tcp_connecter_t::connect(), zmq::ctx_t::connect_inproc_sockets(), zmq::socks_connecter_t::connect_to_proxy(), zmq::msg_t::copy(), zmq::ctx_t::ctx_t(), zmq::socks_choice_decoder_t::decode(), zmq::decoder_base_t< v2_decoder_t, shared_message_memory_allocator >::decode(), zmq::socks_response_decoder_t::decode(), zmq::stream_engine_t::decode_and_push(), zmq::socks_request_encoder_t::encode(), zmq::session_base_t::engine_error(), zmq::stream_engine_t::error(), zmq::socket_base_t::extract_flags(), zmq::io_thread_t::get_poller(), zmq::options_t::getsockopt(), zmq::stream_engine_t::handshake(), zmq::session_base_t::hiccuped(), zmq::stream_t::identify_peer(), zmq::router_t::identify_peer(), zmq::tcp_listener_t::in_event(), zmq::ipc_listener_t::in_event(), zmq::io_object_t::in_event(), zmq::socks_connecter_t::in_event(), zmq::stream_engine_t::in_event(), zmq::udp_engine_t::init(), zmq::msg_t::init_data(), zmq::msg_t::init_external_storage(), zmq::socks_choice_decoder_t::input(), zmq::socks_response_decoder_t::input(), zmq::ipc_address_t::ipc_address_t(), zmq::ipc_connecter_t::ipc_connecter_t(), zmq::encoder_base_t< raw_encoder_t >::load_msg(), zmq::mailbox_safe_t::mailbox_safe_t(), zmq::mailbox_t::mailbox_t(), zmq::signaler_t::make_fdpair(), zmq::tcp_address_mask_t::match_address(), zmq::stream_engine_t::mechanism_ready(), zmq::socks_response_decoder_t::message_ready(), zmq::null_mechanism_t::next_handshake_command(), zmq::stream_engine_t::next_handshake_command(), zmq::tcp_connecter_t::open(), zmq::ipc_connecter_t::open(), zmq::reaper_t::out_event(), zmq::io_thread_t::out_event(), zmq::io_object_t::out_event(), zmq::socks_connecter_t::out_event(), zmq::stream_engine_t::out_event(), zmq::socket_base_t::out_event(), zmq::socket_base_t::parse_uri(), zmq::session_base_t::pipe_terminated(), zmq::udp_engine_t::plug(), zmq::io_object_t::plug(), zmq::stream_engine_t::plug(), zmq::ypipe_t< command_t, command_pipe_granularity >::probe(), zmq::object_t::process_activate_read(), zmq::object_t::process_activate_write(), zmq::session_base_t::process_attach(), zmq::object_t::process_attach(), zmq::object_t::process_bind(), zmq::object_t::process_command(), zmq::socket_base_t::process_commands(), zmq::pipe_t::process_delimiter(), zmq::stream_engine_t::process_handshake_command(), zmq::object_t::process_hiccup(), zmq::pipe_t::process_hiccup(), zmq::object_t::process_own(), zmq::object_t::process_pipe_term(), zmq::pipe_t::process_pipe_term(), zmq::object_t::process_pipe_term_ack(), zmq::pipe_t::process_pipe_term_ack(), zmq::object_t::process_plug(), zmq::object_t::process_reap(), zmq::object_t::process_reaped(), zmq::object_t::process_seqnum(), zmq::object_t::process_stop(), zmq::own_t::process_term(), zmq::session_base_t::process_term(), zmq::object_t::process_term(), zmq::object_t::process_term_ack(), zmq::object_t::process_term_req(), zmq::plain_server_t::produce_error(), zmq::plain_client_t::produce_hello(), zmq::stream_engine_t::produce_ping_message(), zmq::stream_engine_t::produce_pong_message(), zmq::proxy(), zmq::stream_engine_t::pull_and_encode(), zmq::dbuffer_t< msg_t >::read(), zmq::pipe_t::read(), zmq::session_base_t::read_activated(), zmq::socket_poller_t::rebuild(), zmq::mailbox_t::recv(), zmq::signaler_t::recv(), zmq::signaler_t::recv_failable(), zmq::fq_t::recvpipe(), zmq::msg_t::refcnt(), zmq::tcp_address_t::resolve_hostname(), zmq::tcp_address_t::resolve_interface(), zmq::stream_engine_t::restart_input(), zmq::trie_t::rm(), zmq::mtrie_t::rm_helper(), zmq::msg_t::rm_refs(), zmq::pipe_t::rollback(), zmq::signaler_t::send(), zmq::pipe_t::set_event_sink(), zmq::stream_engine_t::set_handshake_timer(), zmq::own_t::set_owner(), zmq::pipe_t::set_peer(), zmq::options_t::setsockopt(), zmq::mechanism_t::socket_type_string(), zmq::socks_connecter_t::socks_connecter_t(), zmq::socks_request_t::socks_request_t(), zmq::session_base_t::start_connecting(), zmq::tcp_address_t::tcp_address_t(), zmq::tcp_connecter_t::tcp_connecter_t(), zmq::udp_engine_t::terminate(), zmq::ctx_t::terminate(), zmq::pipe_t::terminate(), zmq::reaper_t::timer_event(), zmq::tcp_connecter_t::timer_event(), zmq::io_thread_t::timer_event(), zmq::ipc_connecter_t::timer_event(), zmq::io_object_t::timer_event(), zmq::socks_connecter_t::timer_event(), zmq::socket_base_t::timer_event(), zmq::session_base_t::timer_event(), zmq::io_object_t::unplug(), zmq::stream_engine_t::unplug(), zmq::own_t::unregister_term_ack(), zmq::signaler_t::wait(), zmq::dbuffer_t< msg_t >::write(), zmq::session_base_t::write_activated(), zmq::stream_engine_t::write_credential(), zmq::session_base_t::write_zap_msg(), zmq::pub_t::xattach_pipe(), zmq::stream_t::xattach_pipe(), zmq::pair_t::xattach_pipe(), zmq::gather_t::xattach_pipe(), zmq::push_t::xattach_pipe(), zmq::pull_t::xattach_pipe(), zmq::scatter_t::xattach_pipe(), zmq::xsub_t::xattach_pipe(), zmq::dealer_t::xattach_pipe(), zmq::client_t::xattach_pipe(), zmq::router_t::xattach_pipe(), zmq::server_t::xattach_pipe(), zmq::xpub_t::xattach_pipe(), zmq::radio_t::xattach_pipe(), zmq::dish_t::xattach_pipe(), zmq::stream_t::xhas_in(), zmq::router_t::xhas_in(), zmq::socket_base_t::xhiccuped(), zmq::stream_t::xpipe_terminated(), zmq::server_t::xpipe_terminated(), zmq::router_t::xpipe_terminated(), zmq::socket_base_t::xread_activated(), zmq::stream_t::xrecv(), zmq::server_t::xrecv(), zmq::router_t::xrecv(), zmq::req_t::xsend(), zmq::stream_t::xsend(), zmq::router_t::xsend(), zmq::stream_t::xwrite_activated(), zmq::server_t::xwrite_activated(), zmq::router_t::xwrite_activated(), zmq::socket_base_t::xwrite_activated(), zmq::session_base_t::zap_connect(), zmq::stream_engine_t::zap_msg_available(), zmq::zmq_abort(), zmq_ctx_new(), zmq_ctx_term(), zmq_poll(), zmq_poller_wait(), zmq::ctx_t::~ctx_t(), zmq::dist_t::~dist_t(), zmq::fq_t::~fq_t(), zmq::ipc_connecter_t::~ipc_connecter_t(), zmq::ipc_listener_t::~ipc_listener_t(), zmq::lb_t::~lb_t(), zmq::mtrie_t::~mtrie_t(), zmq::pair_t::~pair_t(), zmq::poller_base_t::~poller_base_t(), zmq::router_t::~router_t(), zmq::server_t::~server_t(), zmq::session_base_t::~session_base_t(), zmq::socket_base_t::~socket_base_t(), zmq::socks_connecter_t::~socks_connecter_t(), zmq::stream_engine_t::~stream_engine_t(), zmq::stream_t::~stream_t(), zmq::tcp_connecter_t::~tcp_connecter_t(), zmq::tcp_listener_t::~tcp_listener_t(), zmq::trie_t::~trie_t(), and zmq::udp_engine_t::~udp_engine_t().