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 2024/04/11 16:30:20 UTC
(tika) branch main updated: improve logging in AsyncResource
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 b7a662925 improve logging in AsyncResource
new 87e84f74b Merge remote-tracking branch 'origin/main'
b7a662925 is described below
commit b7a66292536c853389a8a002fa48cd85b1542400
Author: tallison <ta...@apache.org>
AuthorDate: Thu Apr 11 12:30:01 2024 -0400
improve logging in AsyncResource
---
.../main/java/org/apache/tika/server/core/resource/AsyncResource.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/AsyncResource.java b/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/AsyncResource.java
index a4d4ed489..e5c00eb41 100644
--- a/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/AsyncResource.java
+++ b/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/AsyncResource.java
@@ -121,11 +121,14 @@ public class AsyncResource {
try {
boolean offered = asyncProcessor.offer(request.getTuples(), maxQueuePauseMs);
if (offered) {
+ LOG.info("accepted {} tuples, capacity={}", request.getTuples().size(), asyncProcessor.getCapacity());
return ok(request.getTuples().size());
} else {
+ LOG.info("throttling {} tuples, capacity={}", request.getTuples().size(), asyncProcessor.getCapacity());
return throttle(request.getTuples().size());
}
} catch (OfferLargerThanQueueSize e) {
+ LOG.info("throttling {} tuples, capacity={}", request.getTuples().size(), asyncProcessor.getCapacity());
return throttle(request.getTuples().size());
}
}