You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2009/11/16 21:26:37 UTC
svn commit: r880945 -
/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp
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();