[rhmessaging-commits] rhmessaging commits: r1317 - store/trunk/cpp/tests/jrnl.

[rhmessaging-commits at lists.jboss.org]

Author: kpvdr
Date: 2007-11-15 08:00:56 -0500 (Thu, 15 Nov 2007)
New Revision: 1317

Modified:
   store/trunk/cpp/tests/jrnl/msg_producer.cpp
Log:
Removed debug prints accidentally left in at last checkin

Modified: store/trunk/cpp/tests/jrnl/msg_producer.cpp
===================================================================
--- store/trunk/cpp/tests/jrnl/msg_producer.cpp	2007-11-15 04:21:08 UTC (rev 1316)
+++ store/trunk/cpp/tests/jrnl/msg_producer.cpp	2007-11-15 13:00:56 UTC (rev 1317)
@@ -408,7 +408,7 @@
 void
 msg_producer::jrnl_flush(rhm::journal::jcntl& jc, u_int32_t num_msgs_sent)
 {
-std::cout << "msg_producer::jrnl_flush(" << num_msgs_sent << ")" << std::endl << std::flush;
+//std::cout << "msg_producer::jrnl_flush(" << num_msgs_sent << ")" << std::endl << std::flush;
     // Clear any unsent enqueues in buffer, then wait for all enqueues to return
     unsigned flush_cnt = 0;
     assert(num_msgs_sent == _num_msgs_enq_subm);
@@ -425,7 +425,7 @@
                 throw rhm::journal::jexception(EXCEPTION_BASE+10, ss.str().c_str(), "msg_producer",
                         "jrnl_flush"); 
             }
-std::cout << "+" << std::flush;
+//std::cout << "+" << std::flush;
             jc.get_wr_events();
             usleep(FLUSH_SLEEPTIME);
             flush_cnt++;
@@ -435,7 +435,7 @@
     // Submit deferred dequeues (if any)
     if (_auto_dequeue)
     {
-std::cout << "auto_dequeue: " << _dd_dtok_list.size() << " dequeues waiting. " << std::flush;
+//std::cout << "auto_dequeue: " << _dd_dtok_list.size() << " dequeues waiting. " << std::flush;
         u_int32_t cnt = 0;
         send_deferred_dequeues(jc);
         while (!_dd_dtok_list.empty() && !_interrupt_flag)
@@ -447,11 +447,11 @@
             usleep(1000);
             send_deferred_dequeues(jc);
         }
-std::cout << "auto_dequeue: done. " << std::flush;
+//std::cout << "auto_dequeue: done. " << std::flush;
 
         // Clear any unsent dequeues in buffer, then wait for all dequeues to return
         flush_cnt = 0;
-std::cout << "_num_msgs_deq_subm=" << _num_msgs_deq_subm << std::endl << std::flush;
+//std::cout << "_num_msgs_deq_subm=" << _num_msgs_deq_subm << std::endl << std::flush;
         assert(num_msgs_sent == _num_msgs_deq_subm);
         if (_num_msgs_deq < _num_msgs_deq_subm || _num_txn < _num_txn_subm)
         {
@@ -467,7 +467,7 @@
                     throw rhm::journal::jexception(EXCEPTION_BASE+12, ss.str().c_str(),
                             "msg_producer", "jrnl_flush"); 
                 }
-std::cout << "*" << std::flush;
+//std::cout << "*" << std::flush;
                 jc.get_wr_events();
                 usleep(1000);
                 flush_cnt++;