30 #ifndef __ZMQ_KQUEUE_HPP_INCLUDED__ 31 #define __ZMQ_KQUEUE_HPP_INCLUDED__ 35 #if defined ZMQ_USE_KQUEUE 53 class kqueue_t :
public poller_base_t
57 typedef void* handle_t;
59 kqueue_t (
const ctx_t &ctx_);
64 void rm_fd (handle_t handle_);
65 void set_pollin (handle_t handle_);
66 void reset_pollin (handle_t handle_);
67 void set_pollout (handle_t handle_);
68 void reset_pollout (handle_t handle_);
72 static int max_fds ();
77 static void worker_routine (
void *arg_);
89 void kevent_add (
fd_t fd_,
short filter_,
void *udata_);
92 void kevent_delete (
fd_t fd_,
short filter_);
103 typedef std::vector <poll_entry_t*> retired_t;
112 kqueue_t (
const kqueue_t&);
113 const kqueue_t &operator = (
const kqueue_t&);
121 typedef kqueue_t poller_t;
static void worker(void *s)