From 5852db451a76905336601c5ba3e4f33006f007fb Mon Sep 17 00:00:00 2001
From: Martin Sustrik <sustrik@fastmq.commkdir>
Date: Mon, 28 Dec 2009 11:51:06 +0100
Subject: PGM code cleanup

---
 src/pgm_receiver.hpp | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

(limited to 'src/pgm_receiver.hpp')

diff --git a/src/pgm_receiver.hpp b/src/pgm_receiver.hpp
index 91169f4..6fadbc3 100644
--- a/src/pgm_receiver.hpp
+++ b/src/pgm_receiver.hpp
@@ -29,7 +29,7 @@
 #endif
 
 #include <map>
-#include <pgm/pgm.h>
+#include <algorithm>
 
 #include "io_object.hpp"
 #include "i_engine.hpp"
@@ -45,8 +45,6 @@ namespace zmq
     
     public:
 
-        //  Creates gm_engine. Underlying PGM connection is initialised
-        //  using network_ parameter.
         pgm_receiver_t (class io_thread_t *parent_, const options_t &options_);
         ~pgm_receiver_t ();
 
@@ -59,11 +57,12 @@ namespace zmq
 
         //  i_poll_events interface implementation.
         void in_event ();
-        void out_event ();
 
     private:
 
-        //  Map to hold TSI, joined and decoder for each peer.
+        //  If joined is true we are already getting messages from the peer.
+        //  It it's false, we are getting data but still we haven't seen
+        //  beginning of a message.
         struct peer_info_t
         {
             bool joined;
@@ -84,8 +83,8 @@ namespace zmq
             }
         };
 
-        typedef std::map <pgm_tsi_t, peer_info_t, tsi_comp> peer_t;
-        peer_t peers;
+        typedef std::map <pgm_tsi_t, peer_info_t, tsi_comp> peers_t;
+        peers_t peers;
 
         //  PGM socket.
         pgm_socket_t pgm_socket;
-- 
cgit v1.2.3