Allow Logrec_Writer to forward all blocks to next module.

1 files changed, 7 insertions, 6 deletions

diff --git a/examples/C++NPv2/display_logfile.cpp b/examples/C++NPv2/display_logfile.cpp
index 386695ed8f6..809097db918 100644
--- a/examples/C++NPv2/display_logfile.cpp
+++ b/examples/C++NPv2/display_logfile.cpp
@@ -213,12 +213,13 @@ public:
   { return putq (mblk, to); }
 
   virtual int svc () {
-    for (ACE_Message_Block *mb; getq (mb) != -1; mb->release ()) {
-      if (mb->msg_type () == ACE_Message_Block::MB_STOP) {
-        put_next (mb);
-        break;
-      }
-      ACE::write_n (ACE_STDOUT, mb);
+    int stop = 0;
+    for (ACE_Message_Block *mb; !stop && getq (mb) != -1; ) {
+      if (mb->msg_type () == ACE_Message_Block::MB_STOP)
+        stop = 1;
+      else
+        ACE::write_n (ACE_STDOUT, mb);
+      put_next (mb);
     }
     return 0;
   }