mac-op commented on code in PR #25:
URL: https://github.com/apache/uima-uimacpp/pull/25#discussion_r1727999872
##########
src/framework/annotator_mgr.cpp:
##########
@@ -583,7 +576,185 @@ namespace uima {
}
UIMA_ANNOTATOR_TIMING(iv_clTimerLaunchProcess.stop());
- return(utRetVal);
+ return utRetVal;
+ }
+
+ CAS *AnnotatorManager::processUntilNextOutputCas() {
+ unique_ptr<Flow> flow{};
+ while (true) {
+ CAS *currentCas = nullptr;
+ Step nextStep;
+ flow = nullptr;
+
+ // get a cas from the stack
+ if (casIterStack.empty())
+ return nullptr;
+
+ StackFrame &frame = casIterStack.top();
+ try {
+ if (frame.casMultiplier && frame.casMultiplier->hasNext()) {
+ currentCas = &frame.casMultiplier->next();
+ // compute flow for newly produced CAS
+ flow = frame.originalFlow->newCasProduced(*currentCas,
frame.lastEngineKey);
+ }
+ } catch (Exception &exception) {
+ if (!frame.originalFlow->continueOnFailure(frame.lastEngineKey /*
,exception */))
+ throw;
+ }
+
+ if (!currentCas) {
+ // if there is no more output CASes from the stack, take the
original CAS that was processed by
+ // the CAS Multiplier and continue with its flow
+ currentCas = frame.originalCas;
+ flow = std::move(frame.originalFlow);
+ currentCas->setCurrentComponentInfo(nullptr);
+ casIterStack.pop();
+ }
+
+ activeCASes.insert(currentCas);
Review Comment:
Yes you're right, I will fix that.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscr...@uima.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
