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 7baf7c4bd9acd1187125c9e855a00520431dc28d
Author: Benoit Tellier <btell...@linagora.com>
AuthorDate: Tue Apr 21 16:49:17 2020 +0700

    JAMES-3140 Marking pushbackInputStream is not required
---
 .../java/org/apache/james/blob/cassandra/cache/CacheBlobStore.java     | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CacheBlobStore.java
 
b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CacheBlobStore.java
index 0acc95e..227ddca 100644
--- 
a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CacheBlobStore.java
+++ 
b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CacheBlobStore.java
@@ -144,7 +144,6 @@ public class CacheBlobStore implements BlobStore {
     }
 
     private boolean isALargeStream(PushbackInputStream pushbackInputStream) 
throws IOException {
-        pushbackInputStream.mark(0);
         long skip = pushbackInputStream.skip(sizeThresholdInBytes + 1);
         pushbackInputStream.unread(Math.toIntExact(skip));
         return skip >= sizeThresholdInBytes;
@@ -154,7 +153,7 @@ public class CacheBlobStore implements BlobStore {
      * bytes: byte[] from PushbackInputStream.If PushbackInputStream is empty 
bytes.length == 1
      */
     private boolean isAbleToCache(BucketName bucketName, byte[] bytes, 
StoragePolicy storagePolicy) {
-        return isAbleToCache(bucketName, storagePolicy) && bytes.length <= 
sizeThresholdInBytes && bytes.length > 1;
+        return isAbleToCache(bucketName, storagePolicy) && bytes.length <= 
sizeThresholdInBytes;
     }
 
     private boolean isAbleToCache(BucketName bucketName, StoragePolicy 
storagePolicy) {


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

Reply via email to