You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tika.apache.org by ta...@apache.org on 2022/11/17 22:16:35 UTC
[tika] branch main updated: fix another bug in CompositePipesReporter, need to override everything
This is an automated email from the ASF dual-hosted git repository.
tallison pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/tika.git
The following commit(s) were added to refs/heads/main by this push:
new 062efe696 fix another bug in CompositePipesReporter, need to override everything
062efe696 is described below
commit 062efe696c59368a23392d9e5e457d9617638039
Author: tballison <ta...@apache.org>
AuthorDate: Thu Nov 17 17:16:28 2022 -0500
fix another bug in CompositePipesReporter, need to override everything
---
.../org/apache/tika/pipes/CompositePipesReporter.java | 18 ++++++++++++++++++
.../org/apache/tika/pipes/async/AsyncProcessor.java | 2 ++
2 files changed, 20 insertions(+)
diff --git a/tika-core/src/main/java/org/apache/tika/pipes/CompositePipesReporter.java b/tika-core/src/main/java/org/apache/tika/pipes/CompositePipesReporter.java
index dfce28bb7..997e7ca18 100644
--- a/tika-core/src/main/java/org/apache/tika/pipes/CompositePipesReporter.java
+++ b/tika-core/src/main/java/org/apache/tika/pipes/CompositePipesReporter.java
@@ -25,6 +25,7 @@ import org.apache.tika.config.Initializable;
import org.apache.tika.config.InitializableProblemHandler;
import org.apache.tika.config.Param;
import org.apache.tika.exception.TikaConfigException;
+import org.apache.tika.pipes.pipesiterator.TotalCountResult;
public class CompositePipesReporter extends PipesReporter implements Initializable {
@@ -38,6 +39,23 @@ public class CompositePipesReporter extends PipesReporter implements Initializab
}
+ @Override
+ public void report(TotalCountResult totalCountResult) {
+ for (PipesReporter reporter : pipesReporters) {
+ reporter.report(totalCountResult);
+ }
+ }
+
+ @Override
+ public boolean supportsTotalCount() {
+ for (PipesReporter reporter : pipesReporters) {
+ if (reporter.supportsTotalCount()) {
+ return true;
+ }
+ }
+ return false;
+ }
+
@Override
public void error(Throwable t) {
for (PipesReporter reporter : pipesReporters) {
diff --git a/tika-core/src/main/java/org/apache/tika/pipes/async/AsyncProcessor.java b/tika-core/src/main/java/org/apache/tika/pipes/async/AsyncProcessor.java
index 7a71f08c9..17292c047 100644
--- a/tika-core/src/main/java/org/apache/tika/pipes/async/AsyncProcessor.java
+++ b/tika-core/src/main/java/org/apache/tika/pipes/async/AsyncProcessor.java
@@ -116,6 +116,7 @@ public class AsyncProcessor implements Closeable {
new AsyncEmitter(asyncConfig, emitData, emitterManager));
}
} catch (Exception e) {
+ LOG.error("problem initializing AsyncProcessor", e);
executorService.shutdownNow();
asyncConfig.getPipesReporter().error(e);
throw e;
@@ -131,6 +132,7 @@ public class AsyncProcessor implements Closeable {
try {
Thread.sleep(500);
TotalCountResult result = totalCounter.getTotalCount();
+ LOG.trace("counter total {} {} ", result.getStatus(), result.getTotalCount());
pipesReporter.report(result);
status = result.getStatus();
} catch (InterruptedException e) {