You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2020/04/27 02:19:50 UTC
[james-project] 14/14: JAMES-3140: remove +1 initiation size for
pushbackInputStream
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 <du...@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-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org