You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2008/11/11 20:08:20 UTC
svn commit: r713114 -
/incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AggregateOutput.cpp
Author: gsim
Date: Tue Nov 11 11:08:19 2008
New Revision: 713114
URL: http://svn.apache.org/viewvc?rev=713114&view=rev
Log:
handle case where doOutput call causes last task to be removed.
Modified:
incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AggregateOutput.cpp
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AggregateOutput.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AggregateOutput.cpp?rev=713114&r1=713113&r2=713114&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AggregateOutput.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AggregateOutput.cpp Tue Nov 11 11:08:19 2008
@@ -47,6 +47,7 @@
//loop until a task generated some output
while (!result) {
result = tasks[next++]->doOutput();
+ if (tasks.empty()) break;
if (next >= tasks.size()) next = next % tasks.size();
if (start == next) break;
}