[james-project] 14/14: JAMES-3140: remove +1 initiation size for pushbackInputStream

[btellier]

This is an automated email from the ASF dual-hosted git repository.

btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit 16bc09187fac5ce8d6e216e95fbd74a881228d43
Author: ducnv <duc91....@gmail.com>
AuthorDate: Fri Apr 24 17:26:25 2020 +0700

    JAMES-3140: remove +1 initiation size for pushbackInputStream
---
 .../java/org/apache/james/blob/cassandra/cache/CachedBlobStore.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CachedBlobStore.java
 
b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CachedBlobStore.java
index 51e8617..3d4abad 100644
--- 
a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CachedBlobStore.java
+++ 
b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CachedBlobStore.java
@@ -96,7 +96,7 @@ public class CachedBlobStore implements BlobStore {
     }
 
     private Publisher<BlobId> saveInCache(BucketName bucketName, InputStream 
inputStream, StoragePolicy storagePolicy) {
-        PushbackInputStream pushbackInputStream = new 
PushbackInputStream(inputStream, sizeThresholdInBytes + 1);
+        PushbackInputStream pushbackInputStream = new 
PushbackInputStream(inputStream, sizeThresholdInBytes);
 
         return Mono.fromCallable(() -> 
fullyReadSmallStream(pushbackInputStream))
             .flatMap(Mono::justOrEmpty)


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org