summaryrefslogtreecommitdiff
path: root/src/zmq_connecter.hpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-08-12 09:40:16 +0200
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-08-12 09:40:16 +0200
commit059beca59d39d90a8ee0e1b07f840994962ea89e (patch)
tree007a5d86450c543bb9a362a844ee271115b68c54 /src/zmq_connecter.hpp
parentbda766ab401b6c565fe9c2d0bc80c11bbbe84488 (diff)
listener/connecter/init/session added
Diffstat (limited to 'src/zmq_connecter.hpp')
-rw-r--r--src/zmq_connecter.hpp17
1 files changed, 12 insertions, 5 deletions
diff --git a/src/zmq_connecter.hpp b/src/zmq_connecter.hpp
index d346396..93497cb 100644
--- a/src/zmq_connecter.hpp
+++ b/src/zmq_connecter.hpp
@@ -20,17 +20,21 @@
#ifndef __ZMQ_ZMQ_CONNECTER_HPP_INCLUDED__
#define __ZMQ_ZMQ_CONNECTER_HPP_INCLUDED__
+#include "owned.hpp"
#include "io_object.hpp"
#include "tcp_connecter.hpp"
+#include "options.hpp"
+#include "stdint.hpp"
namespace zmq
{
- class zmq_connecter_t : public io_object_t
+ class zmq_connecter_t : public owned_t, public io_object_t
{
public:
- zmq_connecter_t (class io_thread_t *parent_, object_t *owner_);
+ zmq_connecter_t (class io_thread_t *parent_, object_t *owner_,
+ const options_t &options_);
// Set IP address to connect to.
int set_address (const char *addr_);
@@ -57,9 +61,12 @@ namespace zmq
// Handle corresponding to the listening socket.
handle_t handle;
- // True, if we are waiting for a period of time before trying to
- // reconnect.
- bool waiting;
+ // If true file descriptor is registered with the poller and 'handle'
+ // contains valid value.
+ bool handle_valid;
+
+ // Associated socket options.
+ options_t options;
zmq_connecter_t (const zmq_connecter_t&);
void operator = (const zmq_connecter_t&);