(tika) branch main updated: improve logging in AsyncResource

[tallison]

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 <talli...@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());
         }
     }