Commit c99f39ab authored by Martin Sustrik's avatar Martin Sustrik

Merge branch 'master' of git@github.com:sustrik/zeromq2

parents 37d83719 cb78991f
...@@ -48,6 +48,7 @@ case "${host_os}" in ...@@ -48,6 +48,7 @@ case "${host_os}" in
AC_CHECK_LIB(socket, main) AC_CHECK_LIB(socket, main)
AC_CHECK_LIB(nsl, main) AC_CHECK_LIB(nsl, main)
AC_CHECK_LIB(rt, main) AC_CHECK_LIB(rt, main)
AC_CHECK_LIB(uuid, main)
CPPFLAGS="-D_REENTRANT -D_PTHREADS $CPPFLAGS" CPPFLAGS="-D_REENTRANT -D_PTHREADS $CPPFLAGS"
AC_MSG_CHECKING([wheter atomic operations can be used]) AC_MSG_CHECKING([wheter atomic operations can be used])
AC_COMPILE_IFELSE([AC_LANG_PROGRAM( AC_COMPILE_IFELSE([AC_LANG_PROGRAM(
......
...@@ -30,10 +30,12 @@ ...@@ -30,10 +30,12 @@
#include <fcntl.h> #include <fcntl.h>
#include <unistd.h> #include <unistd.h>
#include <limits.h> #include <limits.h>
#include <algorithm>
#include "devpoll.hpp" #include "devpoll.hpp"
#include "err.hpp" #include "err.hpp"
#include "config.hpp" #include "config.hpp"
#include "i_poll_events.hpp"
zmq::devpoll_t::devpoll_t () zmq::devpoll_t::devpoll_t ()
{ {
...@@ -156,11 +158,11 @@ void zmq::devpoll_t::stop () ...@@ -156,11 +158,11 @@ void zmq::devpoll_t::stop ()
stopping = true; stopping = true;
} }
bool zmq::devpoll_t::loop () void zmq::devpoll_t::loop ()
{ {
// According to the poll(7d) man page, we can retrieve // According to the poll(7d) man page, we can retrieve
// no more then (OPEN_MAX - 1) events. // no more then (OPEN_MAX - 1) events.
int nfds = std::min (max_io_events, OPEN_MAX - 1); int nfds = std::min ((int) max_io_events, OPEN_MAX - 1);
while (!stopping) { while (!stopping) {
......
...@@ -37,7 +37,7 @@ namespace zmq ...@@ -37,7 +37,7 @@ namespace zmq
object_t (class dispatcher_t *dispatcher_, int thread_slot_); object_t (class dispatcher_t *dispatcher_, int thread_slot_);
object_t (object_t *parent_); object_t (object_t *parent_);
~object_t (); virtual ~object_t ();
int get_thread_slot (); int get_thread_slot ();
dispatcher_t *get_dispatcher (); dispatcher_t *get_dispatcher ();
......
...@@ -185,3 +185,4 @@ int zmq::tcp_socket_t::read (void *data, int size) ...@@ -185,3 +185,4 @@ int zmq::tcp_socket_t::read (void *data, int size)
} }
#endif #endif
...@@ -293,3 +293,4 @@ unsigned long zmq_stopwatch_stop (void *watch_) ...@@ -293,3 +293,4 @@ unsigned long zmq_stopwatch_stop (void *watch_)
free (watch_); free (watch_);
return (unsigned long) (end - start); return (unsigned long) (end - start);
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment