You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by al...@apache.org on 2006/11/28 23:22:44 UTC
svn commit: r480243 [9/13] - in /incubator/uima/uimaj/trunk/uimaj-cpe/src:
main/java/org/apache/uima/cas_data/impl/vinci/
main/java/org/apache/uima/collection/impl/
main/java/org/apache/uima/collection/impl/base_cpm/container/
main/java/org/apache/uima...
Modified: incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/CPMThreadGroup.java
URL: http://svn.apache.org/viewvc/incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/CPMThreadGroup.java?view=diff&rev=480243&r1=480242&r2=480243
==============================================================================
--- incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/CPMThreadGroup.java (original)
+++ incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/CPMThreadGroup.java Tue Nov 28 14:22:38 2006
@@ -75,9 +75,8 @@
System.out.println("ThreadGroup.uncaughtException()-Got Error");
if (UIMAFramework.getLogger().isLoggable(Level.SEVERE)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.SEVERE, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_unhandled_error__SEVERE",
- new Object[] { Thread.currentThread().getName(), e.getClass().getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_unhandled_error__SEVERE",
+ new Object[] { Thread.currentThread().getName(), e.getClass().getName() });
}
try {
@@ -90,8 +89,8 @@
} catch (Throwable tr) {
if (UIMAFramework.getLogger().isLoggable(Level.FINER)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINER, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_exception__FINER",
- new Object[] { Thread.currentThread().getName(), tr.getClass().getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_exception__FINER",
+ new Object[] { Thread.currentThread().getName(), tr.getClass().getName() });
tr.printStackTrace();
}
}
Modified: incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/ConsumerCasUtils.java
URL: http://svn.apache.org/viewvc/incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/ConsumerCasUtils.java?view=diff&rev=480243&r1=480242&r2=480243
==============================================================================
--- incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/ConsumerCasUtils.java (original)
+++ incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/ConsumerCasUtils.java Tue Nov 28 14:22:38 2006
@@ -69,11 +69,11 @@
public static String getStringFeatValue(CAS aCasView, String aTypeS, String aFeatS) {
String result = null;
FSIterator idIter = aCasView.getAnnotationIndex(aCasView.getTypeSystem().getType(aTypeS))
- .iterator();
+ .iterator();
while (idIter != null && idIter.isValid()) {
org.apache.uima.cas.FeatureStructure idFS = idIter.get();
result = idFS.getStringValue(aCasView.getTypeSystem().getFeatureByFullName(
- aTypeS + ":" + aFeatS));
+ aTypeS + ":" + aFeatS));
idIter.moveToNext();
}
return result;
Modified: incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/DebugControlThread.java
URL: http://svn.apache.org/viewvc/incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/DebugControlThread.java?view=diff&rev=480243&r1=480242&r2=480243
==============================================================================
--- incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/DebugControlThread.java (original)
+++ incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/DebugControlThread.java Tue Nov 28 14:22:38 2006
@@ -55,25 +55,25 @@
if (fileName == null) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_checkpoint_target_not_defined__FINEST",
- new Object[] { Thread.currentThread().getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_checkpoint_target_not_defined__FINEST",
+ new Object[] { Thread.currentThread().getName() });
}
throw new RuntimeException(CpmLocalizedMessage.getLocalizedMessage(
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_EXP_target_checkpoint_not_defined__WARNING", new Object[] { Thread
- .currentThread().getName() }));
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_EXP_target_checkpoint_not_defined__WARNING", new Object[] { Thread
+ .currentThread().getName() }));
}
if (cpm == null) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_invalid_cpm_instance__FINEST",
- new Object[] { Thread.currentThread().getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_invalid_cpm_instance__FINEST",
+ new Object[] { Thread.currentThread().getName() });
}
throw new RuntimeException(CpmLocalizedMessage.getLocalizedMessage(
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_EXP_invalid_cpm__WARNING",
- new Object[] { Thread.currentThread().getName() }));
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_EXP_invalid_cpm__WARNING",
+ new Object[] { Thread.currentThread().getName() }));
} else {
new Thread(this).start();
}
@@ -107,9 +107,8 @@
}
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_thread_terminating__FINEST",
- new Object[] { Thread.currentThread().getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_thread_terminating__FINEST",
+ new Object[] { Thread.currentThread().getName() });
}
}
@@ -144,19 +143,19 @@
if (value.trim().equalsIgnoreCase("off") && System.getProperties().containsKey(key)) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST,
- this.getClass().getName(), "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_disabling_key__FINEST",
- new Object[] { Thread.currentThread().getName(), key, value });
+ this.getClass().getName(), "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_disabling_key__FINEST",
+ new Object[] { Thread.currentThread().getName(), key, value });
}
System.getProperties().remove(key);
} else if (value.trim().equalsIgnoreCase("on")
- && !System.getProperties().containsKey(key)) {
+ && !System.getProperties().containsKey(key)) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST,
- this.getClass().getName(), "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_enabling_key__FINEST",
- new Object[] { Thread.currentThread().getName(), key, value });
+ this.getClass().getName(), "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_enabling_key__FINEST",
+ new Object[] { Thread.currentThread().getName(), key, value });
}
System.getProperties().put(key, value);
}
@@ -206,9 +205,9 @@
try {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_show_access_control_file__FINEST",
- new Object[] { Thread.currentThread().getName(), fileName });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_show_access_control_file__FINEST",
+ new Object[] { Thread.currentThread().getName(), fileName });
}
inF = new File(fileName);
byte[] content = new byte[(int) inF.length()];
@@ -220,9 +219,9 @@
} catch (FileNotFoundException e) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_access_control_file_not_found__FINEST",
- new Object[] { Thread.currentThread().getName(), fileName });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_access_control_file_not_found__FINEST",
+ new Object[] { Thread.currentThread().getName(), fileName });
}
return NOTFOUND;
} catch (Exception e) {
Modified: incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/NonThreadedProcessingUnit.java
URL: http://svn.apache.org/viewvc/incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/NonThreadedProcessingUnit.java?view=diff&rev=480243&r1=480242&r2=480243
==============================================================================
--- incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/NonThreadedProcessingUnit.java (original)
+++ incubator/uima/uimaj/trunk/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/cpm/engine/NonThreadedProcessingUnit.java Tue Nov 28 14:22:38 2006
@@ -114,7 +114,7 @@
* queue to write to
*/
public NonThreadedProcessingUnit(CPMEngine acpm, BoundedWorkQueue aInputQueue,
- BoundedWorkQueue aOutputQueue) {
+ BoundedWorkQueue aOutputQueue) {
cpm = acpm;
try {
cpeConfiguration = cpm.getCpeConfig();
@@ -128,13 +128,13 @@
outputQueue = aOutputQueue;
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_initialize_pipeline__FINEST",
- new Object[] { Thread.currentThread().getName(), workQueue.getName(),
- String.valueOf(workQueue.getCurrentSize()) });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_initialize_pipeline__FINEST",
+ new Object[] { Thread.currentThread().getName(), workQueue.getName(),
+ String.valueOf(workQueue.getCurrentSize()) });
}
}
@@ -259,15 +259,9 @@
public void setUimaTimer(UimaTimer aTimer) {
timer = aTimer;
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
- UIMAFramework.getLogger(this.getClass())
- .logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_timer_class__FINEST",
- new Object[] { Thread.currentThread().getName(),
- timer.getClass().getName() });
+ UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_timer_class__FINEST",
+ new Object[] { Thread.currentThread().getName(), timer.getClass().getName() });
}
}
@@ -301,9 +295,8 @@
pc.setStatus(Constants.CAS_PROCESSOR_DISABLED);
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_disabled_cp__FINEST",
- new Object[] { Thread.currentThread().getName(), pc.getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_disabled_cp__FINEST",
+ new Object[] { Thread.currentThread().getName(), pc.getName() });
}
}
}
@@ -322,9 +315,8 @@
pc.setStatus(Constants.CAS_PROCESSOR_DISABLED);
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_disabled_cp__FINEST",
- new Object[] { Thread.currentThread().getName(), pc.getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_disabled_cp__FINEST",
+ new Object[] { Thread.currentThread().getName(), pc.getName() });
}
}
}
@@ -344,9 +336,8 @@
if (pc.getName().equals(aCasProcessorName)) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_enabled_cp__FINEST",
- new Object[] { Thread.currentThread().getName(), pc.getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_enabled_cp__FINEST",
+ new Object[] { Thread.currentThread().getName(), pc.getName() });
}
pc.setStatus(Constants.CAS_PROCESSOR_RUNNING);
}
@@ -361,9 +352,8 @@
{
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_start_analysis__FINEST",
- new Object[] { Thread.currentThread().getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_start_analysis__FINEST",
+ new Object[] { Thread.currentThread().getName() });
}
// String lastDocId = "";
CasProcessor processor = null;
@@ -373,9 +363,9 @@
if (aCasObjectList == null || aCasObjectList[0] == null) {
if (UIMAFramework.getLogger().isLoggable(Level.SEVERE)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.SEVERE, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_invalid_cas_reference__SEVERE",
- new Object[] { Thread.currentThread().getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_invalid_cas_reference__SEVERE",
+ new Object[] { Thread.currentThread().getName() });
}
return false;
}
@@ -388,9 +378,8 @@
// String docid = "";
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_entering_pipeline__FINEST",
- new Object[] { Thread.currentThread().getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_entering_pipeline__FINEST",
+ new Object[] { Thread.currentThread().getName() });
}
ProcessingContainer container = null;
@@ -402,9 +391,8 @@
for (int i = 0; processContainers != null && i < processContainers.size(); i++) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_retrieve_container__FINEST",
- new Object[] { Thread.currentThread().getName(), String.valueOf(i) });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_retrieve_container__FINEST",
+ new Object[] { Thread.currentThread().getName(), String.valueOf(i) });
}
// Retrieve the container. Container manages one or more instances of CAS Processor
container = (ProcessingContainer) processContainers.get(i);
@@ -429,22 +417,22 @@
if (System.getProperty("SHOW_MEMORY") != null) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_show_memory__FINEST",
- new Object[] { Thread.currentThread().getName(),
- String.valueOf(Runtime.getRuntime().totalMemory() / 1024),
- String.valueOf(Runtime.getRuntime().freeMemory() / 1024) });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_show_memory__FINEST",
+ new Object[] { Thread.currentThread().getName(),
+ String.valueOf(Runtime.getRuntime().totalMemory() / 1024),
+ String.valueOf(Runtime.getRuntime().freeMemory() / 1024) });
}
}
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_checkout_cp_from_container__FINEST",
- new Object[] { Thread.currentThread().getName(), containerName });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_checkout_cp_from_container__FINEST",
+ new Object[] { Thread.currentThread().getName(), containerName });
}
threadState = 2004;
// Get the CasProcessor from the pool managed by the container
@@ -452,15 +440,14 @@
if (processor == null) {
if (UIMAFramework.getLogger().isLoggable(Level.SEVERE)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.SEVERE,
- this.getClass().getName(), "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_checkout_null_cp_from_container__SEVERE",
- new Object[] { Thread.currentThread().getName(), containerName });
+ this.getClass().getName(), "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_checkout_null_cp_from_container__SEVERE",
+ new Object[] { Thread.currentThread().getName(), containerName });
}
throw new ResourceProcessException(CpmLocalizedMessage.getLocalizedMessage(
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_EXP_invalid_component_reference__WARNING", new Object[] {
- Thread.currentThread().getName(), "CasProcessor", "NULL" }), null);
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_EXP_invalid_component_reference__WARNING", new Object[] {
+ Thread.currentThread().getName(), "CasProcessor", "NULL" }), null);
}
// Check to see if the CasProcessor is available for processing
// The CasProcessor may have been disabled due to excessive errors and error policy
@@ -469,10 +456,9 @@
if (!isProcessorReady(container.getStatus())) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST,
- this.getClass().getName(), "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_container_not_ready__FINEST",
- new Object[] { Thread.currentThread().getName(), containerName });
+ this.getClass().getName(), "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_container_not_ready__FINEST",
+ new Object[] { Thread.currentThread().getName(), containerName });
}
if (container.getStatus() == Constants.CAS_PROCESSOR_KILLED) {
container.releaseCasProcessor(processor);
@@ -488,18 +474,18 @@
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_checkedout_cp_from_container__FINEST",
- new Object[] { Thread.currentThread().getName(), containerName,
- processor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_checkedout_cp_from_container__FINEST",
+ new Object[] { Thread.currentThread().getName(), containerName,
+ processor.getClass().getName() });
}
// ************************* P E R F O R M A N A L Y S I S *************************
if (processor instanceof CasDataProcessor) {
invokeCasDataCasProcessor(container, processor, aCasObjectList, pTrTemp, isCasObject,
- retry);
+ retry);
isCasObject = false;
} else if (processor instanceof CasObjectProcessor) {
invokeCasObjectCasProcessor(container, processor, aCasObjectList, pTrTemp, isCasObject);
@@ -507,13 +493,13 @@
}
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_analysis_successfull__FINEST",
- new Object[] { Thread.currentThread().getName(), containerName,
- processor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_analysis_successfull__FINEST",
+ new Object[] { Thread.currentThread().getName(), containerName,
+ processor.getClass().getName() });
}
retry = false;
// On successfull processing reset the restart counter. Restart counter determines how
@@ -533,13 +519,13 @@
if (retry == false) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_end_of_batch__FINEST",
- new Object[] { Thread.currentThread().getName(), containerName,
- processor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_end_of_batch__FINEST",
+ new Object[] { Thread.currentThread().getName(), containerName,
+ processor.getClass().getName() });
}
if (isProcessorReady(container.getStatus())) {
@@ -558,29 +544,25 @@
// pipeline
if (processor != null) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
- UIMAFramework.getLogger(this.getClass())
- .logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_release_cp__FINEST",
- new Object[] { Thread.currentThread().getName(),
- containerName, processor.getClass().getName(),
- String.valueOf(casCache == null) });
+ UIMAFramework.getLogger(this.getClass()).logrb(
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_release_cp__FINEST",
+ new Object[] { Thread.currentThread().getName(), containerName,
+ processor.getClass().getName(), String.valueOf(casCache == null) });
}
doReleaseCasProcessor(container, processor);
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
- UIMAFramework.getLogger(this.getClass())
- .logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_ok_release_cp__FINEST",
- new Object[] { Thread.currentThread().getName(),
- containerName, processor.getClass().getName(),
- String.valueOf(casCache == null) });
+ UIMAFramework.getLogger(this.getClass()).logrb(
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_ok_release_cp__FINEST",
+ new Object[] { Thread.currentThread().getName(), containerName,
+ processor.getClass().getName(), String.valueOf(casCache == null) });
}
processor = null;
}
@@ -620,21 +602,19 @@
* @throws Exception
*/
private void postAnalysis(Object[] aCasObjectList, boolean isCasObject, Object[] casObjects,
- ProcessTrace aProcessTr, boolean doneAlready) throws Exception {
+ ProcessTrace aProcessTr, boolean doneAlready) throws Exception {
try {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_pipeline_completed__FINEST",
- new Object[] { Thread.currentThread().getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_pipeline_completed__FINEST",
+ new Object[] { Thread.currentThread().getName() });
}
// Notify Listeners that the entity has been processed.
if (!doneAlready && notifyListeners) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_notify_listeners__FINEST",
- new Object[] { Thread.currentThread().getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_notify_listeners__FINEST",
+ new Object[] { Thread.currentThread().getName() });
}
threadState = 2013;
@@ -643,24 +623,23 @@
threadState = 2014;
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_done_notify_listeners__FINEST",
- new Object[] { Thread.currentThread().getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_done_notify_listeners__FINEST",
+ new Object[] { Thread.currentThread().getName() });
}
}
// enqueue CASes. If the CPM is in shutdown mode due to hard kill dont allow enqueue of CASes
if (outputQueue != null
- && (cpm.isRunning() == true || (cpm.isRunning() == false && cpm
- .isHardKilled() == false))) {
+ && (cpm.isRunning() == true || (cpm.isRunning() == false && cpm.isHardKilled() == false))) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_add_cas_to_queue__FINEST",
- new Object[] { Thread.currentThread().getName(), outputQueue.getName(),
- String.valueOf(outputQueue.getCurrentSize()) });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_add_cas_to_queue__FINEST",
+ new Object[] { Thread.currentThread().getName(), outputQueue.getName(),
+ String.valueOf(outputQueue.getCurrentSize()) });
}
WorkUnit workUnit = new WorkUnit(aCasObjectList);
if (casCache != null && casCache[0] != null) {
@@ -686,49 +665,49 @@
if (System.getProperty("DEBUG_RELEASE") != null) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_done_with_cas__FINEST",
- new Object[] { Thread.currentThread().getName(),
- String.valueOf(Runtime.getRuntime().freeMemory() / 1024) });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_done_with_cas__FINEST",
+ new Object[] { Thread.currentThread().getName(),
+ String.valueOf(Runtime.getRuntime().freeMemory() / 1024) });
}
}
for (int i = 0; i < casObjects.length; i++) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_show_local_cache__FINEST",
- new Object[] { Thread.currentThread().getName(),
- String.valueOf(casCache == null) });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_show_local_cache__FINEST",
+ new Object[] { Thread.currentThread().getName(),
+ String.valueOf(casCache == null) });
}
casObjects[i] = null;
aCasObjectList[i] = null;
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_show_local_cache__FINEST",
- new Object[] { Thread.currentThread().getName(),
- String.valueOf(casCache == null) });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_show_local_cache__FINEST",
+ new Object[] { Thread.currentThread().getName(),
+ String.valueOf(casCache == null) });
}
}
if (System.getProperty("DEBUG_RELEASE") != null) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_show_total_memory__FINEST",
- new Object[] { Thread.currentThread().getName(),
- String.valueOf(Runtime.getRuntime().freeMemory() / 1024) });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_show_total_memory__FINEST",
+ new Object[] { Thread.currentThread().getName(),
+ String.valueOf(Runtime.getRuntime().freeMemory() / 1024) });
}
}
}
@@ -742,27 +721,23 @@
}
private void doEndOfBatch(ProcessingContainer aContainer, CasProcessor aProcessor,
- ProcessTrace aProcessTr, int howManyCases) {
+ ProcessTrace aProcessTr, int howManyCases) {
String containerName = aContainer.getName();
try {
aContainer.isEndOfBatch(aProcessor, howManyCases);
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_end_of_batch_completed__FINEST",
- new Object[] { Thread.currentThread().getName(), containerName });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_end_of_batch_completed__FINEST",
+ new Object[] { Thread.currentThread().getName(), containerName });
}
} catch (Exception ex) {
if (UIMAFramework.getLogger().isLoggable(Level.SEVERE)) {
- UIMAFramework.getLogger(this.getClass()).logrb(
- Level.SEVERE,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_end_of_batch_exception__SEVERE",
- new Object[] { Thread.currentThread().getName(), containerName,
- ex.getMessage() });
+ UIMAFramework.getLogger(this.getClass()).logrb(Level.SEVERE, this.getClass().getName(),
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_end_of_batch_exception__SEVERE",
+ new Object[] { Thread.currentThread().getName(), containerName, ex.getMessage() });
}
}
@@ -787,23 +762,23 @@
* @throws Exception
*/
private boolean handleErrors(Throwable e, ProcessingContainer aContainer,
- CasProcessor aProcessor, ProcessTrace aProcessTrace, Object[] aCasObjectList,
- boolean isCasObject) throws Exception {
+ CasProcessor aProcessor, ProcessTrace aProcessTrace, Object[] aCasObjectList,
+ boolean isCasObject) throws Exception {
boolean retry = true;
String containerName = aContainer.getName();
e.printStackTrace();
if (UIMAFramework.getLogger().isLoggable(Level.SEVERE)) {
UIMAFramework.getLogger(this.getClass()).log(Level.SEVERE, Thread.currentThread().getName(),
- e);
+ e);
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.SEVERE,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_handle_exception__SEVERE",
- new Object[] { Thread.currentThread().getName(), containerName,
- aProcessor.getClass().getName(), e.getMessage() });
+ Level.SEVERE,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_handle_exception__SEVERE",
+ new Object[] { Thread.currentThread().getName(), containerName,
+ aProcessor.getClass().getName(), e.getMessage() });
}
EntityProcessStatusImpl enProcSt = new EntityProcessStatusImpl(aProcessTrace);
@@ -823,13 +798,13 @@
clearCasCache();
}
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.WARNING,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_drop_cas__WARNING",
- new Object[] { Thread.currentThread().getName(), containerName,
- aProcessor.getClass().getName() });
+ Level.WARNING,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_drop_cas__WARNING",
+ new Object[] { Thread.currentThread().getName(), containerName,
+ aProcessor.getClass().getName() });
// Release CASes and notify listeners
cpm.invalidateCASes((CAS[]) aCasObjectList);
@@ -844,9 +819,9 @@
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_container_paused_do_retry__FINEST",
- new Object[] { Thread.currentThread().getName(), containerName });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_container_paused_do_retry__FINEST",
+ new Object[] { Thread.currentThread().getName(), containerName });
}
return true; // retry
@@ -854,9 +829,8 @@
if (e instanceof Exception && pauseContainer(aContainer, (Exception) e, threadId)) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_pausing_container__FINEST",
- new Object[] { Thread.currentThread().getName(), containerName });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_pausing_container__FINEST",
+ new Object[] { Thread.currentThread().getName(), containerName });
}
threadState = 2011;
@@ -883,19 +857,13 @@
}
aContainer.setStatus(Constants.CAS_PROCESSOR_KILLED);
if (UIMAFramework.getLogger().isLoggable(Level.SEVERE)) {
- UIMAFramework.getLogger(this.getClass()).logrb(
- Level.SEVERE,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_abort_cpm__SEVERE",
- new Object[] { Thread.currentThread().getName(),
- aProcessor.getClass().getName() });
+ UIMAFramework.getLogger(this.getClass()).logrb(Level.SEVERE, this.getClass().getName(),
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_abort_cpm__SEVERE",
+ new Object[] { Thread.currentThread().getName(), aProcessor.getClass().getName() });
}
throw new AbortCPMException(CpmLocalizedMessage.getLocalizedMessage(
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_EXP_configured_to_abort__WARNING", new Object[] {
- Thread.currentThread().getName(), containerName }));
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_EXP_configured_to_abort__WARNING",
+ new Object[] { Thread.currentThread().getName(), containerName }));
} // check if the CasProcessor is to be disabled due to excessive errors
catch (AbortCasProcessorException ex) {
retry = false;
@@ -904,14 +872,9 @@
aContainer.resume();
}
if (UIMAFramework.getLogger().isLoggable(Level.SEVERE)) {
- UIMAFramework.getLogger(this.getClass()).logrb(
- Level.SEVERE,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_disable_cp__SEVERE",
- new Object[] { Thread.currentThread().getName(),
- aProcessor.getClass().getName() });
+ UIMAFramework.getLogger(this.getClass()).logrb(Level.SEVERE, this.getClass().getName(),
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_disable_cp__SEVERE",
+ new Object[] { Thread.currentThread().getName(), aProcessor.getClass().getName() });
}
aContainer.setStatus(Constants.CAS_PROCESSOR_DISABLED);
@@ -943,7 +906,7 @@
} catch (Exception ex) {
if (UIMAFramework.getLogger().isLoggable(Level.SEVERE)) {
UIMAFramework.getLogger(this.getClass()).log(Level.SEVERE,
- Thread.currentThread().getName(), e);
+ Thread.currentThread().getName(), e);
}
retry = false;
ex.printStackTrace();
@@ -961,47 +924,45 @@
* @throws Exception
*/
private void invokeCasObjectCasProcessor(ProcessingContainer container, CasProcessor processor,
- Object[] aCasObjectList, ProcessTrace pTrTemp, boolean isCasObject)
- throws Exception {
+ Object[] aCasObjectList, ProcessTrace pTrTemp, boolean isCasObject) throws Exception {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_show_memory__FINEST",
- new Object[] { Thread.currentThread().getName(),
- String.valueOf(Runtime.getRuntime().totalMemory() / 1024),
- String.valueOf(Runtime.getRuntime().freeMemory() / 1024) });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_show_memory__FINEST",
+ new Object[] { Thread.currentThread().getName(),
+ String.valueOf(Runtime.getRuntime().totalMemory() / 1024),
+ String.valueOf(Runtime.getRuntime().freeMemory() / 1024) });
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_invoke_cp_process__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName(),
- processor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_invoke_cp_process__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName(),
+ processor.getClass().getName() });
}
casList = new CAS[aCasObjectList.length];
for (int casIndex = 0; casIndex < aCasObjectList.length; casIndex++) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_initialize_cas__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_initialize_cas__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName() });
}
if (aCasObjectList[casIndex] == null) {
if (UIMAFramework.getLogger().isLoggable(Level.SEVERE)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.SEVERE,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_casobjectlist_is_null__SEVERE",
- new Object[] { Thread.currentThread().getName(), container.getName(),
- String.valueOf(casIndex) });
+ Level.SEVERE,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_casobjectlist_is_null__SEVERE",
+ new Object[] { Thread.currentThread().getName(), container.getName(),
+ String.valueOf(casIndex) });
}
break;
}
@@ -1013,26 +974,26 @@
if (processor instanceof AnalysisEngine) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_call_process__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName(),
- processor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_call_process__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName(),
+ processor.getClass().getName() });
}
threadState = 2005;
pTrTemp.aggregate(((AnalysisEngine) processor).process(casList[casIndex]));
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_call_process_completed__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName(),
- processor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_call_process_completed__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName(),
+ processor.getClass().getName() });
}
} else {
pTrTemp.startEvent(container.getName(), "Process", "");
@@ -1040,24 +1001,24 @@
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_call_process__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName(),
- processor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_call_process__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName(),
+ processor.getClass().getName() });
}
((CasObjectProcessor) processor).processCas(casList[casIndex]);
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_call_process_completed__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName(),
- processor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_call_process_completed__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName(),
+ processor.getClass().getName() });
}
pTrTemp.endEvent(container.getName(), "Process", "success");
}
@@ -1074,7 +1035,7 @@
* @throws Exception
*/
private void convertCasDataToCasObject(int casIndex, String aContainerName,
- Object[] aCasObjectList) throws Exception {
+ Object[] aCasObjectList) throws Exception {
// The following may be true if the CollectionReader is CasData based and this is the first
// CasObject based annotator in the chain.
if (casCache == null || casCache[casIndex] == null) {
@@ -1084,26 +1045,25 @@
while (casList[casIndex] == null) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_get_cas_from_pool__FINEST",
- new Object[] { Thread.currentThread().getName(), aContainerName });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_get_cas_from_pool__FINEST",
+ new Object[] { Thread.currentThread().getName(), aContainerName });
}
// Retrieve a Cas from Cas Pool. Wait max 10 millis for an instance
casList[casIndex] = casPool.getCas(0);
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_got_cas_from_pool__FINEST",
- new Object[] { Thread.currentThread().getName(), aContainerName });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_got_cas_from_pool__FINEST",
+ new Object[] { Thread.currentThread().getName(), aContainerName });
}
}
if (casList[casIndex] != null) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_call_cas_reset__FINEST",
- new Object[] { Thread.currentThread().getName(), aContainerName });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_call_cas_reset__FINEST",
+ new Object[] { Thread.currentThread().getName(), aContainerName });
}
casList[casIndex].reset();
}
@@ -1128,17 +1088,17 @@
* @throws Exception
*/
private void invokeCasDataCasProcessor(ProcessingContainer container, CasProcessor processor,
- Object[] aCasObjectList, ProcessTrace pTrTemp, boolean isCasObject, boolean retry)
- throws Exception {
+ Object[] aCasObjectList, ProcessTrace pTrTemp, boolean isCasObject, boolean retry)
+ throws Exception {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_invoke_cp_process__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName(),
- processor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_invoke_cp_process__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName(),
+ processor.getClass().getName() });
}
pTrTemp.startEvent(container.getName(), "Process", "");
// Check if the CasObject to CasData conversion is necessary
@@ -1167,47 +1127,47 @@
long pStart = System.currentTimeMillis();
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_casobject_class__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName(),
- casObjects.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_casobject_class__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName(),
+ casObjects.getClass().getName() });
}
if (!(casObjects instanceof CasData[])) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_expected_casdata_class__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName(),
- casObjects.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_expected_casdata_class__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName(),
+ casObjects.getClass().getName() });
}
}
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_call_process__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName(),
- processor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_call_process__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName(),
+ processor.getClass().getName() });
}
casObjects = ((CasDataProcessor) processor).process((CasData[]) casObjects);
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_call_process_completed__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName(),
- processor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_call_process_completed__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName(),
+ processor.getClass().getName() });
}
long pEnd = System.currentTimeMillis();
container.incrementTotalTime((pEnd - pStart));
@@ -1234,9 +1194,9 @@
if (!isProcessorReady(aContainer.getStatus())) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_container_not_ready__FINEST",
- new Object[] { Thread.currentThread().getName(), aContainer.getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_container_not_ready__FINEST",
+ new Object[] { Thread.currentThread().getName(), aContainer.getName() });
}
// Skip any CasProcessor that is not ready to process. Cas Processors may be disabled during
// processing
@@ -1258,15 +1218,15 @@
}
private boolean filterOutTheCAS(ProcessingContainer aContainer, boolean isCasObject,
- Object[] aCasObjectList) {
+ Object[] aCasObjectList) {
// Check if any of the Cas'es in the set has a required feature structure.
// This is currently only supported for the CasData instances and provides
// filtering mechanism
if (!isCasObject && !aContainer.processCas(aCasObjectList)) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_skip_CAS__FINEST",
- new Object[] { Thread.currentThread().getName(), aContainer.getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_skip_CAS__FINEST",
+ new Object[] { Thread.currentThread().getName(), aContainer.getName() });
}
aContainer.incrementFilteredCount(aCasObjectList.length);
aContainer.logAbortedCases(aCasObjectList);
@@ -1287,7 +1247,7 @@
* status object that may contain exceptions and trace
*/
protected void notifyListeners(Object aCas, boolean isCasObject,
- EntityProcessStatus aEntityProcStatus) {
+ EntityProcessStatus aEntityProcStatus) {
if (aCas instanceof Object[]) {
for (int i = 0; i < ((Object[]) aCas).length; i++) {
doNotifyListeners(((Object[]) aCas)[i], isCasObject, aEntityProcStatus);
@@ -1309,7 +1269,7 @@
* status object containing exceptions and trace info
*/
protected void doNotifyListeners(Object aCas, boolean isCasObject,
- EntityProcessStatus aEntityProcStatus) {
+ EntityProcessStatus aEntityProcStatus) {
// Notify Listener that the entity has been processed
Object casObjectCopy = aCas;
// Notify ALL listeners
@@ -1324,7 +1284,7 @@
}
// Notify the listener that the Cas has been processed
((CasDataStatusCallbackListener) statCL).entityProcessComplete((CasData) casObjectCopy,
- aEntityProcStatus);
+ aEntityProcStatus);
} else if (statCL instanceof StatusCallbackListener) {
boolean casFromPool = false;
// The cas is of type CasData, need to convert it to CAS
@@ -1342,15 +1302,15 @@
mConverter.casDataToCasContainer((CasData) casObjectCopy, conversionCas, true);
} catch (CollectionException e) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.WARNING,
- this.getClass().getName(), "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_exception_converting_CAS__WARNING",
- new Object[] { Thread.currentThread().getName() });
+ this.getClass().getName(), "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_exception_converting_CAS__WARNING",
+ new Object[] { Thread.currentThread().getName() });
}
casObjectCopy = conversionCas;
}
// Notify the listener that the Cas has been processed
((StatusCallbackListener) statCL).entityProcessComplete((CAS) casObjectCopy,
- aEntityProcStatus);
+ aEntityProcStatus);
if (conversionCas != null) {
if (casFromPool) {
conversionCasArray[0] = conversionCas;
@@ -1373,9 +1333,9 @@
if (casCache[index] != null) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_release_cas_from_cache__FINEST",
- new Object[] { Thread.currentThread().getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_release_cas_from_cache__FINEST",
+ new Object[] { Thread.currentThread().getName() });
}
casPool.releaseCas(casCache[index]);
synchronized (casPool) {
@@ -1384,9 +1344,9 @@
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_release_cas_from_cache_done__FINEST",
- new Object[] { Thread.currentThread().getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_release_cas_from_cache_done__FINEST",
+ new Object[] { Thread.currentThread().getName() });
}
}
}
@@ -1413,10 +1373,9 @@
* exception
*/
private boolean pauseContainer(ProcessingContainer aContainer, Exception aException,
- String aThreadId) {
+ String aThreadId) {
if (aContainer.isRemote() && aContainer.isSingleFencedService()
- && aException.getCause() instanceof ServiceConnectionException
- && aThreadId == null) {
+ && aException.getCause() instanceof ServiceConnectionException && aThreadId == null) {
return true;
}
@@ -1432,7 +1391,7 @@
* @throws Exception
*/
private void handleServiceException(ProcessingContainer aContainer, CasProcessor aProcessor,
- ProcessTrace aProcessTr, Exception ex) throws Exception {
+ ProcessTrace aProcessTr, Exception ex) throws Exception {
if (aProcessor instanceof NetworkCasProcessorImpl) {
((NetworkCasProcessorImpl) aProcessor).collectionProcessComplete(aProcessTr);
}
@@ -1451,25 +1410,25 @@
if (Thread.currentThread().getName().equals(threadId)) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_service_connection_exception__FINEST",
- new Object[] { Thread.currentThread().getName(), aContainer.getName(),
- aProcessor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_service_connection_exception__FINEST",
+ new Object[] { Thread.currentThread().getName(), aContainer.getName(),
+ aProcessor.getClass().getName() });
}
aProcessTr.startEvent(aContainer.getName(), "Process", "");
// Redeploy the CasProcessor
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_redeploy_cp__FINEST",
- new Object[] { Thread.currentThread().getName(), aContainer.getName(),
- aProcessor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_redeploy_cp__FINEST",
+ new Object[] { Thread.currentThread().getName(), aContainer.getName(),
+ aProcessor.getClass().getName() });
}
// Reconnect the CPM to CasProcessor running in fenced mode
cpm.redeployAnalysisEngine(aContainer);
@@ -1480,49 +1439,49 @@
threadId = null;
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_redeploy_cp_done__FINEST",
- new Object[] { Thread.currentThread().getName(), aContainer.getName(),
- aProcessor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_redeploy_cp_done__FINEST",
+ new Object[] { Thread.currentThread().getName(), aContainer.getName(),
+ aProcessor.getClass().getName() });
}
}
} else {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_service_connection_exception__FINEST",
- new Object[] { Thread.currentThread().getName(), aContainer.getName(),
- aProcessor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_service_connection_exception__FINEST",
+ new Object[] { Thread.currentThread().getName(), aContainer.getName(),
+ aProcessor.getClass().getName() });
}
aProcessTr.startEvent(aContainer.getName(), "Process", "");
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_redeploy_cp__FINEST",
- new Object[] { Thread.currentThread().getName(), aContainer.getName(),
- aProcessor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_redeploy_cp__FINEST",
+ new Object[] { Thread.currentThread().getName(), aContainer.getName(),
+ aProcessor.getClass().getName() });
}
// Reconnect the CPM to CasProcessor running in fenced mode
cpm.redeployAnalysisEngine(aContainer);
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_redeploy_cp_done__FINEST",
- new Object[] { Thread.currentThread().getName(), aContainer.getName(),
- aProcessor.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_redeploy_cp_done__FINEST",
+ new Object[] { Thread.currentThread().getName(), aContainer.getName(),
+ aProcessor.getClass().getName() });
}
}
}
@@ -1535,12 +1494,12 @@
* @throws Exception
*/
private void handleSkipCasProcessor(ProcessingContainer aContainer, Object[] aCasObjectList,
- boolean isLastCP) throws Exception {
+ boolean isLastCP) throws Exception {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_skip_CAS__FINEST",
- new Object[] { Thread.currentThread().getName(), aContainer.getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_skip_CAS__FINEST",
+ new Object[] { Thread.currentThread().getName(), aContainer.getName() });
}
if (aContainer.isPaused()) {
aContainer.resume();
@@ -1565,15 +1524,10 @@
releaseCases(casList, isLastCP, aContainer.getName());
} catch (Exception ex2) {
if (UIMAFramework.getLogger().isLoggable(Level.SEVERE)) {
- UIMAFramework.getLogger(this.getClass())
- .logrb(
- Level.SEVERE,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_exception_releasing_cas__SEVERE",
- new Object[] { Thread.currentThread().getName(),
- aContainer.getName() });
+ UIMAFramework.getLogger(this.getClass()).logrb(Level.SEVERE, this.getClass().getName(),
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_exception_releasing_cas__SEVERE",
+ new Object[] { Thread.currentThread().getName(), aContainer.getName() });
throw ex2;
}
}
@@ -1617,13 +1571,13 @@
{
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_releasing_cases__FINEST",
- new Object[] { Thread.currentThread().getName(), aName,
- String.valueOf(relaseCAS), String.valueOf(lastProcessor) });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_releasing_cases__FINEST",
+ new Object[] { Thread.currentThread().getName(), aName, String.valueOf(relaseCAS),
+ String.valueOf(lastProcessor) });
}
if (aCasList == null) {
return;
@@ -1641,20 +1595,20 @@
cpm.releaseCASes((CAS[]) aCasList);
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_done_releasing_cases__FINEST",
- new Object[] { Thread.currentThread().getName(), aName });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_done_releasing_cases__FINEST",
+ new Object[] { Thread.currentThread().getName(), aName });
}
} else {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_casobject_class__FINEST",
- new Object[] { Thread.currentThread().getName(), aName,
- aCasList.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_casobject_class__FINEST",
+ new Object[] { Thread.currentThread().getName(), aName,
+ aCasList.getClass().getName() });
}
}
}
@@ -1671,9 +1625,8 @@
public void stopCasProcessors(boolean kill) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_stop_containers__FINEST",
- new Object[] { Thread.currentThread().getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_stop_containers__FINEST",
+ new Object[] { Thread.currentThread().getName() });
}
// while (consumeQueue());
//
@@ -1689,13 +1642,13 @@
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_show_container_time__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName(),
- String.valueOf(container.getTotalTime()) });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_show_container_time__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName(),
+ String.valueOf(container.getTotalTime()) });
}
synchronized (container) {
// Change the status of this container to KILLED if the CPM has been stopped
@@ -1704,9 +1657,8 @@
if (kill || (!cpm.isRunning() && isProcessorReady(container.getStatus()))) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST, this.getClass().getName(),
- "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_kill_cp__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName() });
+ "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE, "UIMA_CPM_kill_cp__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName() });
}
container.setStatus(Constants.CAS_PROCESSOR_KILLED);
} else {
@@ -1718,13 +1670,13 @@
}
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_container_status__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName(),
- String.valueOf(container.getStatus()) });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_container_status__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName(),
+ String.valueOf(container.getStatus()) });
}
ProcessTrace pTrTemp = new ProcessTrace_impl(cpm.getPerformanceTuningSettings());
pTrTemp.startEvent(container.getName(), "End of Batch", "");
@@ -1734,13 +1686,13 @@
if (deployer != null) {
if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(this.getClass()).logrb(
- Level.FINEST,
- this.getClass().getName(),
- "process",
- CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
- "UIMA_CPM_undeploy_cp_instances__FINEST",
- new Object[] { Thread.currentThread().getName(), container.getName(),
- deployer.getClass().getName() });
+ Level.FINEST,
+ this.getClass().getName(),
+ "process",
+ CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
+ "UIMA_CPM_undeploy_cp_instances__FINEST",
+ new Object[] { Thread.currentThread().getName(), container.getName(),
+ deployer.getClass().getName() });
}
deployer.undeploy();
}