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 2013/02/16 22:50:49 UTC
svn commit: r1446957 - in
/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads:
CompositeTaskRunner.cpp CompositeTaskRunner.h DedicatedTaskRunner.cpp
DedicatedTaskRunner.h TaskRunner.h
Author: tabish
Date: Sat Feb 16 21:50:49 2013
New Revision: 1446957
URL: http://svn.apache.org/r1446957
Log:
Switch to using a 64bit value for shutdown time.
Modified:
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/CompositeTaskRunner.cpp
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/CompositeTaskRunner.h
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/DedicatedTaskRunner.cpp
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/DedicatedTaskRunner.h
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/TaskRunner.h
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/CompositeTaskRunner.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/CompositeTaskRunner.cpp?rev=1446957&r1=1446956&r2=1446957&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/CompositeTaskRunner.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/CompositeTaskRunner.cpp Sat Feb 16 21:50:49 2013
@@ -73,7 +73,7 @@ bool CompositeTaskRunner::isStarted() co
}
////////////////////////////////////////////////////////////////////////////////
-void CompositeTaskRunner::shutdown(unsigned int timeout) {
+void CompositeTaskRunner::shutdown(long long timeout) {
synchronized(&mutex) {
shutDown = true;
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/CompositeTaskRunner.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/CompositeTaskRunner.h?rev=1446957&r1=1446956&r2=1446957&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/CompositeTaskRunner.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/CompositeTaskRunner.h Sat Feb 16 21:50:49 2013
@@ -84,7 +84,7 @@ namespace threads {
*
* @param timeout - Time in Milliseconds to wait for the task to stop.
*/
- virtual void shutdown(unsigned int timeout);
+ virtual void shutdown(long long timeout);
/**
* Shutdown once the task has finished and the TaskRunner's thread has exited.
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/DedicatedTaskRunner.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/DedicatedTaskRunner.cpp?rev=1446957&r1=1446956&r2=1446957&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/DedicatedTaskRunner.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/DedicatedTaskRunner.cpp Sat Feb 16 21:50:49 2013
@@ -71,7 +71,7 @@ bool DedicatedTaskRunner::isStarted() co
}
////////////////////////////////////////////////////////////////////////////////
-void DedicatedTaskRunner::shutdown(unsigned int timeout) {
+void DedicatedTaskRunner::shutdown(long long timeout) {
synchronized(&mutex) {
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/DedicatedTaskRunner.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/DedicatedTaskRunner.h?rev=1446957&r1=1446956&r2=1446957&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/DedicatedTaskRunner.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/DedicatedTaskRunner.h Sat Feb 16 21:50:49 2013
@@ -62,7 +62,7 @@ namespace threads {
*
* @param timeout - Time in Milliseconds to wait for the task to stop.
*/
- virtual void shutdown(unsigned int timeout);
+ virtual void shutdown(long long timeout);
/**
* Shutdown once the task has finished and the TaskRunner's thread has exited.
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/TaskRunner.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/TaskRunner.h?rev=1446957&r1=1446956&r2=1446957&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/TaskRunner.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/threads/TaskRunner.h Sat Feb 16 21:50:49 2013
@@ -47,7 +47,7 @@ namespace threads {
*
* @param timeout - Time in Milliseconds to wait for the task to stop.
*/
- virtual void shutdown(unsigned int timeout) = 0;
+ virtual void shutdown(long long timeout) = 0;
/**
* Shutdown once the task has finished and the TaskRunner's thread has exited.