svn commit: r1760304 - /jackrabbit/oak/trunk/oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ChangeProcessor.java

[mreutegg]

Author: mreutegg
Date: Mon Sep 12 08:15:03 2016
New Revision: 1760304

URL: http://svn.apache.org/viewvc?rev=1760304&view=rev
Log:
OAK-4749: Include initial cost in stats for observation processing

Modified:
    
jackrabbit/oak/trunk/oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ChangeProcessor.java

Modified: 
jackrabbit/oak/trunk/oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ChangeProcessor.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ChangeProcessor.java?rev=1760304&r1=1760303&r2=1760304&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ChangeProcessor.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ChangeProcessor.java
 Mon Sep 12 08:15:03 2016
@@ -343,7 +343,10 @@ class ChangeProcessor implements Observe
                     EventIterator events = new EventQueue(namePathMapper, 
info, previousRoot, root,
                             provider.getSubTrees(), Filters.all(filter, 
VISIBLE_FILTER));
 
-                    if (events.hasNext() && runningMonitor.enterIf(running)) {
+                    long time = System.nanoTime();
+                    boolean hasEvents = events.hasNext();
+                    tracker.recordProducerTime(System.nanoTime() - time, 
TimeUnit.NANOSECONDS);
+                    if (hasEvents && runningMonitor.enterIf(running)) {
                         try {
                             CountingIterator countingEvents = new 
CountingIterator(events);
                             eventListener.onEvent(countingEvents);