svn commit: r1732859 - /jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/blob/BlobStoreStats.java

[ch...@apache.org]

Author: chetanm
Date: Mon Feb 29 11:23:47 2016
New Revision: 1732859

URL: http://svn.apache.org/viewvc?rev=1732859&view=rev
Log:
OAK-4010 - Log major operation done in Oak via specific operation logger

Modified:
    jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/blob/BlobStoreStats.java

Modified: jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/blob/BlobStoreStats.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/blob/BlobStoreStats.java?rev=1732859&r1=1732858&r2=1732859&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/blob/BlobStoreStats.java (original)
+++ jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/blob/BlobStoreStats.java Mon Feb 29 11:23:47 2016
@@ -34,12 +34,15 @@ import org.apache.jackrabbit.oak.stats.S
 import org.apache.jackrabbit.oak.stats.StatsOptions;
 import org.apache.jackrabbit.stats.TimeSeriesAverage;
 import org.apache.jackrabbit.stats.TimeSeriesStatsUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import static com.google.common.base.Preconditions.checkNotNull;
 import static org.apache.jackrabbit.oak.commons.IOUtils.humanReadableByteCount;
 
 @SuppressWarnings("Duplicates")
 public class BlobStoreStats extends AnnotatedStandardMBean implements BlobStoreStatsMBean, BlobStatsCollector {
+    private final Logger opsLogger = LoggerFactory.getLogger("org.apache.jackrabbit.oak.operations.blobs");
     private static final String BLOB_DOWNLOAD_COUNT = "BLOB_DOWNLOAD_COUNT";
     private static final String BLOB_UPLOADS = "BLOB_UPLOADS";
     private static final String BLOB_DOWNLOADS = "BLOB_DOWNLOADS";
@@ -89,6 +92,7 @@ public class BlobStoreStats extends Anno
         //it got completed. So acts like a rough approximation
         uploadSizeSeries.mark(size);
         uploadTimeSeries.mark(recordedTimeUnit.convert(timeTaken, unit));
+        opsLogger.debug("Uploaded {} bytes in {} ms", size, unit.toMillis(timeTaken));
     }
 
     @Override
@@ -97,16 +101,19 @@ public class BlobStoreStats extends Anno
 
         downloadSizeSeries.mark(size);
         downloadTimeSeries.mark(recordedTimeUnit.convert(timeTaken, unit));
+        opsLogger.debug("Downloaded {} - {} bytes in {} ms", blobId, size, unit.toMillis(timeTaken));
     }
 
     @Override
     public void uploadCompleted(String blobId) {
         uploadCount.mark();
+        opsLogger.debug("Upload completed - {}", blobId);
     }
 
     @Override
     public void downloadCompleted(String blobId) {
         downloadCount.mark();
+        opsLogger.debug("Download completed - {}", blobId);
     }
 
     //~--------------------------------------< BlobStoreMBean >