You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@sirona.apache.org by ol...@apache.org on 2014/03/03 07:05:00 UTC

svn commit: r1573451 - /incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/CubePathTrackingDataStore.java

Author: olamy
Date: Mon Mar  3 06:04:59 2014
New Revision: 1573451

URL: http://svn.apache.org/r1573451
Log:
unit update
need to think about performance for that

Modified:
    incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/CubePathTrackingDataStore.java

Modified: incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/CubePathTrackingDataStore.java
URL: http://svn.apache.org/viewvc/incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/CubePathTrackingDataStore.java?rev=1573451&r1=1573450&r2=1573451&view=diff
==============================================================================
--- incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/CubePathTrackingDataStore.java (original)
+++ incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/CubePathTrackingDataStore.java Mon Mar  3 06:04:59 2014
@@ -39,7 +39,10 @@ public class CubePathTrackingDataStore
     protected void pushEntriesByBatch( ConcurrentMap<String, Set<PathTrackingEntry>> pathTrackingEntries ) {
         for ( Map.Entry<String, Set<PathTrackingEntry>> entry : pathTrackingEntries.entrySet())
         {
-            cube.post( cube.pathTrackingSnapshot( entry.getValue() ) );
+            for (PathTrackingEntry pathTrackingEntry : entry.getValue())
+            {
+                cube.post( cube.pathTrackingSnapshot( pathTrackingEntry ) );
+            }
         }
     }