![]() |
libzmq master
The Intelligent Transport Layer
|
#include "../include/zmq.h"
#include <assert.h>
#include <errno.h>
#include <string.h>
#include <stdlib.h>
#include <stdio.h>
#include "platform.hpp"
#include "likely.hpp"
#include <netdb.h>
Go to the source code of this file.
Defines | |
#define | alloc_assert(x) |
#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::zmq_abort (const char *errmsg_) |
#define alloc_assert | ( | x | ) |
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 140 of file err.hpp.
Referenced by zmq::socket_base_t::bind(), zmq::socket_base_t::create(), zmq::session_base_t::create(), zmq::ctx_t::ctx_t(), zmq::decoder_base_t< decoder_t >::decoder_base_t(), zmq::encoder_base_t< encoder_t >::encoder_base_t(), zmq::pipe_t::hiccup(), zmq::tcp_listener_t::in_event(), zmq::ipc_listener_t::in_event(), zmq::io_thread_t::io_thread_t(), zmq::tcp_connecter_t::out_event(), zmq::ipc_connecter_t::out_event(), zmq::yqueue_t< command_t, N >::push(), zmq::reaper_t::reaper_t(), zmq::mtrie_t::rm_helper(), zmq::session_base_t::start_connecting(), zmq::yqueue_t< command_t, N >::yqueue_t(), zmq_init(), zmq_poll(), and zmq_stopwatch_start().
#define errno_assert | ( | x | ) |
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 110 of file err.hpp.
Referenced by zmq::tcp_listener_t::accept(), zmq::ipc_listener_t::accept(), zmq::session_base_t::clean_pipes(), zmq::tcp_listener_t::close(), zmq::tcp_connecter_t::close(), zmq::tcp_connecter_t::connect(), zmq::socket_base_t::connect(), zmq::ipc_connecter_t::connect(), zmq::decoder_t::decoder_t(), zmq::dist_t::distribute(), zmq::decoder_t::eight_byte_size_ready(), zmq::encoder_t::encoder_t(), zmq::socket_base_t::getsockopt(), zmq::lb_t::has_out(), zmq::tcp_listener_t::in_event(), zmq::reaper_t::in_event(), zmq::ipc_listener_t::in_event(), zmq::io_thread_t::in_event(), zmq::ctx_t::log(), zmq::signaler_t::make_fdpair(), zmq::encoder_t::message_ready(), zmq::clock_t::now_us(), zmq::decoder_t::one_byte_size_ready(), zmq::session_base_t::process_attach(), zmq::socket_base_t::process_commands(), zmq::pipe_t::process_hiccup(), zmq::pipe_t::process_pipe_term_ack(), zmq::stream_engine_t::read(), zmq::signaler_t::recv(), zmq::mailbox_t::recv(), zmq::fq_t::recvpipe(), zmq::pipe_t::rollback(), zmq::signaler_t::send(), zmq::lb_t::send(), zmq::tcp_listener_t::set_address(), zmq::signaler_t::signaler_t(), zmq::stream_engine_t::stream_engine_t(), zmq::tcp_connecter_t::tcp_connecter_t(), thread_routine(), zmq::stream_engine_t::write(), zmq::session_base_t::write(), zmq::pair_t::xhas_out(), zmq::xsub_t::xrecv(), zmq::xrep_t::xrecv(), zmq::xpub_t::xrecv(), zmq::req_t::xrecv(), zmq::rep_t::xrecv(), zmq::pair_t::xrecv(), zmq::xrep_t::xsend(), zmq::req_t::xsend(), zmq::pair_t::xsend(), zmq::sub_t::xsetsockopt(), zmq::xsub_t::xsub_t(), zmq_poll(), zmq_recv(), zmq_send(), zmq::decoder_t::~decoder_t(), zmq::encoder_t::~encoder_t(), zmq::signaler_t::~signaler_t(), zmq::stream_engine_t::~stream_engine_t(), and zmq::xsub_t::~xsub_t().
#define gai_assert | ( | x | ) |
#define posix_assert | ( | x | ) |
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 120 of file err.hpp.
Referenced by zmq::mutex_t::lock(), zmq::mutex_t::mutex_t(), zmq::thread_t::start(), zmq::thread_t::stop(), thread_routine(), zmq::mutex_t::unlock(), and zmq::mutex_t::~mutex_t().
#define zmq_assert | ( | x | ) |
do {\ if (unlikely (!(x))) {\ fprintf (stderr, "Assertion failed: %s (%s:%d)\n", #x, \ __FILE__, __LINE__);\ zmq::zmq_abort (#x);\ }\ } while (false)
Definition at line 100 of file err.hpp.
Referenced by zmq::tcp_listener_t::accept(), zmq::ipc_listener_t::accept(), zmq::trie_t::add(), zmq::mtrie_t::add_helper(), zmq::msg_t::add_refs(), zmq::trie_t::apply_helper(), zmq::session_base_t::attach_pipe(), zmq::socket_base_t::bind(), zmq::poller_base_t::cancel_timer(), zmq::pipe_t::check_read(), zmq::own_t::check_term_acks(), zmq::ctx_t::choose_io_thread(), zmq::session_base_t::clean_pipes(), zmq::tcp_listener_t::close(), zmq::tcp_connecter_t::close(), zmq::ipc_listener_t::close(), zmq::ipc_connecter_t::close(), zmq::tcp_connecter_t::connect(), zmq::socket_base_t::connect(), zmq::ctx_t::ctx_t(), zmq::pipe_t::delimit(), zmq::dist_t::distribute(), zmq::stream_engine_t::error(), zmq::socket_base_t::extract_flags(), zmq::io_thread_t::get_poller(), zmq::session_base_t::hiccuped(), zmq::tcp_listener_t::in_event(), zmq::stream_engine_t::in_event(), zmq::ipc_listener_t::in_event(), zmq::io_object_t::in_event(), zmq::ipc_connecter_t::ipc_connecter_t(), zmq::mailbox_t::mailbox_t(), zmq::signaler_t::make_fdpair(), zmq::tcp_connecter_t::open(), zmq::ipc_connecter_t::open(), zmq::stream_engine_t::out_event(), zmq::socket_base_t::out_event(), zmq::reaper_t::out_event(), zmq::io_thread_t::out_event(), zmq::io_object_t::out_event(), zmq::socket_base_t::parse_uri(), zmq::stream_engine_t::plug(), zmq::io_object_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::pipe_t::process_hiccup(), zmq::object_t::process_hiccup(), zmq::object_t::process_own(), zmq::pipe_t::process_pipe_term(), zmq::object_t::process_pipe_term(), zmq::pipe_t::process_pipe_term_ack(), zmq::object_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::session_base_t::process_term(), zmq::own_t::process_term(), zmq::object_t::process_term(), zmq::object_t::process_term_ack(), zmq::object_t::process_term_req(), zmq::session_base_t::read(), zmq::session_base_t::read_activated(), zmq::signaler_t::recv(), zmq::mailbox_t::recv(), zmq::fq_t::recvpipe(), zmq::tcp_address_t::resolve_hostname(), zmq::tcp_address_t::resolve_interface(), zmq::mtrie_t::rm_helper(), zmq::msg_t::rm_refs(), zmq::pipe_t::rollback(), zmq::signaler_t::send(), zmq::lb_t::send(), zmq::xsub_t::send_subscription(), zmq::pipe_t::set_event_sink(), zmq::own_t::set_owner(), zmq::pipe_t::set_peer(), zmq::session_base_t::start_connecting(), zmq::pipe_t::terminate(), zmq::ctx_t::terminate(), zmq::session_base_t::terminated(), zmq::tcp_connecter_t::timer_event(), zmq::socket_base_t::timer_event(), zmq::session_base_t::timer_event(), zmq::reaper_t::timer_event(), zmq::ipc_connecter_t::timer_event(), zmq::io_thread_t::timer_event(), zmq::io_object_t::timer_event(), zmq::stream_engine_t::unplug(), zmq::io_object_t::unplug(), zmq::own_t::unregister_term_ack(), zmq::signaler_t::wait(), zmq::session_base_t::write_activated(), zmq::xsub_t::xattach_pipe(), zmq::xreq_t::xattach_pipe(), zmq::xrep_t::xattach_pipe(), zmq::xpub_t::xattach_pipe(), zmq::push_t::xattach_pipe(), zmq::pull_t::xattach_pipe(), zmq::pair_t::xattach_pipe(), zmq::xsub_t::xhas_in(), zmq::socket_base_t::xhiccuped(), zmq::xpub_t::xread_activated(), zmq::socket_base_t::xread_activated(), zmq::xsub_t::xrecv(), zmq::xrep_t::xrecv(), zmq::rep_t::xrecv(), zmq::xsub_t::xsend(), zmq::xrep_t::xsend(), zmq::xrep_t::xterminated(), zmq::pair_t::xterminated(), zmq::xrep_t::xwrite_activated(), zmq::socket_base_t::xwrite_activated(), zmq_init(), zmq_poll(), zmq_term(), zmq::ctx_t::~ctx_t(), zmq::dist_t::~dist_t(), zmq::fq_t::~fq_t(), zmq::lb_t::~lb_t(), zmq::pair_t::~pair_t(), zmq::poller_base_t::~poller_base_t(), zmq::session_base_t::~session_base_t(), zmq::socket_base_t::~socket_base_t(), zmq::stream_engine_t::~stream_engine_t(), and zmq::xrep_t::~xrep_t().