33 #if !defined ZMQ_HAVE_WINDOWS && !defined ZMQ_HAVE_OPENVMS 40 #include "platform.hpp" 49 #include <sys/types.h> 50 #include <sys/socket.h> 55 const address_t *addr_,
bool delayed_start_) :
56 own_t (io_thread_, options_),
61 delayed_start (delayed_start_),
62 timer_started (false),
64 current_reconnect_ivl(options.reconnect_ivl)
200 return this_interval;
226 if (rc == -1 && errno == EINTR) {
250 #if defined ZMQ_HAVE_HPUX 251 int len =
sizeof (err);
253 socklen_t len =
sizeof (err);
255 int rc = getsockopt (
s, SOL_SOCKET, SO_ERROR, (
char*) &err, &len);
257 if (errno == ENOPROTOOPT)
int get_new_reconnect_ivl()
void send_attach(zmq::session_base_t *destination_, zmq::i_engine *engine_, bool inc_seqnum_=true)
void process_term(int linger_)
void set_pollout(handle_t handle_)
fd_t open_socket(int domain_, int type_, int protocol_)
void unblock_socket(fd_t s_)
const sockaddr * addr() const
void cancel_timer(int id_)
ipc_connecter_t(zmq::io_thread_t *io_thread_, zmq::session_base_t *session_, const options_t &options_, const address_t *addr_, bool delayed_start_)
ZMQ_EXPORT int zmq_errno(void)
void event_connected(const std::string &addr_, int fd_)
socklen_t addrlen() const
void timer_event(int id_)
int current_reconnect_ivl
void event_connect_delayed(const std::string &addr_, int err_)
uint32_t generate_random()
void add_reconnect_timer()
const std::string protocol
void process_term(int linger_)
void add_timer(int timout_, int id_)
void event_closed(const std::string &addr_, int fd_)
void event_connect_retried(const std::string &addr_, int interval_)
handle_t add_fd(fd_t fd_)
union zmq::address_t::@0 resolved
int to_string(std::string &addr_) const
void rm_fd(handle_t handle_)
zmq::session_base_t * session
zmq::socket_base_t * socket