From b9caa319e279cd8cd367e0a64308b9e80c4ead3d Mon Sep 17 00:00:00 2001
From: Martin Sustrik <sustrik@250bpm.com>
Date: Tue, 16 Feb 2010 18:30:38 +0100
Subject: Multi-hop REQ/REP, part XI., finalise the XREQ/XREP functionality

---
 src/xrep.hpp | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

(limited to 'src/xrep.hpp')

diff --git a/src/xrep.hpp b/src/xrep.hpp
index 67ab02d..4534463 100644
--- a/src/xrep.hpp
+++ b/src/xrep.hpp
@@ -20,7 +20,10 @@
 #ifndef __ZMQ_XREP_HPP_INCLUDED__
 #define __ZMQ_XREP_HPP_INCLUDED__
 
+#include <map>
+
 #include "socket_base.hpp"
+#include "blob.hpp"
 #include "fq.hpp"
 
 namespace zmq
@@ -34,7 +37,8 @@ namespace zmq
         ~xrep_t ();
 
         //  Overloads of functions from socket_base_t.
-        void xattach_pipes (class reader_t *inpipe_, class writer_t *outpipe_);
+        void xattach_pipes (class reader_t *inpipe_, class writer_t *outpipe_,
+            const blob_t &peer_identity_);
         void xdetach_inpipe (class reader_t *pipe_);
         void xdetach_outpipe (class writer_t *pipe_);
         void xkill (class reader_t *pipe_);
@@ -51,6 +55,10 @@ namespace zmq
         //  Inbound messages are fair-queued.
         fq_t fq;
 
+        //  Outbound pipes indexed by the peer names.
+        typedef std::map <blob_t, class writer_t*> outpipes_t;
+        outpipes_t outpipes;
+
         xrep_t (const xrep_t&);
         void operator = (const xrep_t&);
     };
-- 
cgit v1.2.3