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++;