activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r880945 - /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp
Date Mon, 16 Nov 2009 20:26:37 GMT
Author: tabish
Date: Mon Nov 16 20:26:36 2009
New Revision: 880945

URL: http://svn.apache.org/viewvc?rev=880945&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQCPP-250

Remove some debug logging and tweak the read check.

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp?rev=880945&r1=880944&r2=880945&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp
Mon Nov 16 20:26:36 2009
@@ -344,12 +344,8 @@
         return;
     }
 
-    std::cout << "Performing a Read Check" << std::endl;
-
     if( !this->members->commandReceived.get() ) {
 
-        std::cout << "Read Check: No Read occurred this period, failed." << std::endl;
-
         // Set the failed state on our async Read Failure Task and wakeup its runner.
         this->members->asyncReadTask->setFailed( true );
         this->members->asyncTasks->wakeup();
@@ -365,12 +361,8 @@
         return;
     }
 
-    std::cout << "Performing Write Check" << std::endl;
-
     if(! this->members->commandSent.get() ) {
 
-        std::cout << "Not Command Sent this period, writing" << std::endl;
-
         this->members->asyncWriteTask->setWrite( true );
         this->members->asyncTasks->wakeup();
     }
@@ -383,8 +375,6 @@
 
     synchronized( &this->members->monitor ) {
 
-        std::cout << "Starting Monitor Threads:" << std::endl;
-
         if( this->members->monitorStarted.get() ) {
             return;
         }
@@ -431,8 +421,6 @@
 
     synchronized( &this->members->monitor ) {
 
-        std::cout << "Stopping Monitor Threads:" << std::endl;
-
         if( this->members->monitorStarted.compareAndSet( true, false ) ) {
 
             this->members->readCheckerTask->cancel();



Mime
View raw message