From 047bd130cfd885ce76d4c04914adaa5333f4efe7 Mon Sep 17 00:00:00 2001
From: AJ Lewis <aj.lewis@quantum.com>
Date: Thu, 2 Jan 2014 11:04:43 -0600
Subject: [PATCH] Fix LIBZMQ-576 - Revert "Merge pull request #510 from
 miniway/master"

This reverts commit f27eb67e1abb0484c41050e454404cce30647b63, reversing
changes made to a3ae0d4c16c892a4e6c96d626a7c8b7068450336.

Conflicts:
	src/stream_engine.cpp

Conflicts were around additional defaults to the constructor after the
'terminating' default.  The additional defaults were left alone, and
the 'terminating' default was removed.
---
 src/encoder.hpp       |  5 -----
 src/i_encoder.hpp     |  1 -
 src/stream_engine.cpp | 12 ------------
 src/stream_engine.hpp |  1 -
 4 files changed, 19 deletions(-)

diff --git a/src/encoder.hpp b/src/encoder.hpp
index beae44f3..01ec3660 100644
--- a/src/encoder.hpp
+++ b/src/encoder.hpp
@@ -127,11 +127,6 @@ namespace zmq
             (static_cast <T*> (this)->*next) ();
         }
 
-        inline bool has_data ()
-        {
-            return to_write > 0;
-        }
-
     protected:
 
         //  Prototype of state machine action.
diff --git a/src/i_encoder.hpp b/src/i_encoder.hpp
index 2cfa2a89..e0318e1f 100644
--- a/src/i_encoder.hpp
+++ b/src/i_encoder.hpp
@@ -43,7 +43,6 @@ namespace zmq
         //  Load a new message into encoder.
         virtual void load_msg (msg_t *msg_) = 0;
 
-        virtual bool has_data () = 0;
     };
 
 }
diff --git a/src/stream_engine.cpp b/src/stream_engine.cpp
index cb70680b..00a1bea9 100644
--- a/src/stream_engine.cpp
+++ b/src/stream_engine.cpp
@@ -68,7 +68,6 @@ zmq::stream_engine_t::stream_engine_t (fd_t fd_, const options_t &options_,
     options (options_),
     endpoint (endpoint_),
     plugged (false),
-    terminating (false),
     read_msg (&stream_engine_t::read_identity),
     write_msg (&stream_engine_t::write_identity),
     io_error (false),
@@ -183,11 +182,6 @@ void zmq::stream_engine_t::unplug ()
 
 void zmq::stream_engine_t::terminate ()
 {
-    if (!terminating && encoder && encoder->has_data ()) {
-        //  Give io_thread a chance to send in the buffer
-        terminating = true;
-        return;
-    }
     unplug ();
     delete this;
 }
@@ -314,8 +308,6 @@ void zmq::stream_engine_t::out_event ()
     //  this is necessary to prevent losing incoming messages.
     if (nbytes == -1) {
         reset_pollout (handle);
-        if (unlikely (terminating))
-            terminate ();
         return;
     }
 
@@ -327,10 +319,6 @@ void zmq::stream_engine_t::out_event ()
     if (unlikely (handshaking))
         if (outsize == 0)
             reset_pollout (handle);
-
-    if (unlikely (terminating))
-        if (outsize == 0)
-            terminate ();
 }
 
 void zmq::stream_engine_t::restart_output ()
diff --git a/src/stream_engine.hpp b/src/stream_engine.hpp
index 2b3857d5..631d1cbb 100644
--- a/src/stream_engine.hpp
+++ b/src/stream_engine.hpp
@@ -162,7 +162,6 @@ namespace zmq
         std::string endpoint;
 
         bool plugged;
-        bool terminating;
 
         int (stream_engine_t::*read_msg) (msg_t *msg_);