summaryrefslogtreecommitdiff
path: root/src/app_thread.hpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-04-29 17:20:23 +0200
committerMartin Sustrik <sustrik@250bpm.com>2010-04-29 17:20:23 +0200
commitc193fd146661b39027c5e3fa0776dcdf8c6af5e2 (patch)
tree0ec001869a7e6519cc1b910de0b26c46308eba96 /src/app_thread.hpp
parent7cb076e56a18cb76c49f17bd34bc73c11e01b705 (diff)
lock-free polling removed; ZMQ_POLL flag removed
Diffstat (limited to 'src/app_thread.hpp')
-rw-r--r--src/app_thread.hpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/app_thread.hpp b/src/app_thread.hpp
index 1c2f47a..b7572da 100644
--- a/src/app_thread.hpp
+++ b/src/app_thread.hpp
@@ -25,6 +25,7 @@
#include "stdint.hpp"
#include "object.hpp"
#include "yarray.hpp"
+#include "fd_signaler.hpp"
namespace zmq
{
@@ -33,8 +34,7 @@ namespace zmq
{
public:
- app_thread_t (class dispatcher_t *dispatcher_, int thread_slot_,
- int flags_);
+ app_thread_t (class dispatcher_t *dispatcher_, int thread_slot_);
~app_thread_t ();
@@ -43,7 +43,7 @@ namespace zmq
void stop ();
// Returns signaler associated with this application thread.
- struct i_signaler *get_signaler ();
+ fd_signaler_t *get_signaler ();
// Processes commands sent to this thread (if any). If 'block' is
// set to true, returns only after at least one command was processed.
@@ -71,7 +71,7 @@ namespace zmq
sockets_t sockets;
// App thread's signaler object.
- struct i_signaler *signaler;
+ fd_signaler_t signaler;
// Timestamp of when commands were processed the last time.
uint64_t last_processing_time;