From 4777fe4010572d381a2ad8eb63df2fc5fb7e6642 Mon Sep 17 00:00:00 2001
From: Martin Hurton <hurtonm@gmail.com>
Date: Thu, 17 Jun 2010 12:45:14 +0200
Subject: pipe: fix bug in rollback() method
The msgs_written variable keeps track how many complete
messages have been written so far. The rollback operation drops all
fragments of the last incomplete message so it shouldn't
change this variable at all.
---
src/pipe.cpp | 1 -
1 file changed, 1 deletion(-)
diff --git a/src/pipe.cpp b/src/pipe.cpp
index 1df64e9..d62085d 100644
--- a/src/pipe.cpp
+++ b/src/pipe.cpp
@@ -176,7 +176,6 @@ void zmq::writer_t::rollback ()
while (pipe->unwrite (&msg)) {
zmq_assert (msg.flags & ZMQ_MSG_MORE);
zmq_msg_close (&msg);
- msgs_written--;
}
if (stalled && endpoint != NULL && !pipe_full()) {
--
cgit v1.2.3