You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2009/04/06 19:46:21 UTC
svn commit: r762437 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java
Author: cwiklik
Date: Mon Apr 6 17:46:21 2009
New Revision: 762437
URL: http://svn.apache.org/viewvc?rev=762437&view=rev
Log:
UIMA-1316 Modified to call collectionProcessComplete() on the FlowControllerContainer. The uima core was modified to support this API
Modified:
incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java?rev=762437&r1=762436&r2=762437&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java Mon Apr 6 17:46:21 2009
@@ -426,6 +426,9 @@
Endpoint cEndpoint = null;
if (sendReply && allDelegatesCompletedCollection() && (( cEndpoint = getClientEndpoint()) != null) )
{
+ if ( flowControllerContainer != null ) {
+ flowControllerContainer.collectionProcessComplete();
+ }
sendCpcReply(cEndpoint);
}
}
@@ -1425,6 +1428,8 @@
if (forceToDropTheCas(cacheEntry, aStep)) {
if (casStateEntry.isReplyReceived()) {
if (isSubordinate) {
+ // drop the flow since we no longer need it
+ dropFlow(aCasReferenceId, true);
// Drop the CAS and remove cache entry for it
dropCAS(aCasReferenceId, true);
casDropped = true;