From 3e97c0fef49e511dcae400e134876581cdae43f3 Mon Sep 17 00:00:00 2001
From: Martin Sustrik <sustrik@250bpm.com>
Date: Sat, 7 Aug 2010 09:52:34 +0200
Subject: REQ socket implementation is layered on top of XREQ

---
 src/pipe.cpp | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

(limited to 'src/pipe.cpp')

diff --git a/src/pipe.cpp b/src/pipe.cpp
index 14fc753..5780635 100644
--- a/src/pipe.cpp
+++ b/src/pipe.cpp
@@ -269,9 +269,6 @@ void zmq::writer_t::terminate ()
     if (terminating)
         return;
 
-    //  Rollback any unfinished messages.
-    rollback ();
-
     if (msg_store == NULL || (msg_store->empty () && !extra_msg_flag))
         write_delimiter ();
     else
@@ -280,6 +277,9 @@ void zmq::writer_t::terminate ()
 
 void zmq::writer_t::write_delimiter ()
 {
+    //  Rollback any unfinished messages.
+    rollback ();
+
     //  Push delimiter into the pipe.
     //  Trick the compiler to belive that the tag is a valid pointer.
     zmq_msg_t msg;
-- 
cgit v1.2.3