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/04 03:47:13 UTC
svn commit: r1573845 - in
/incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube:
Cube.java CubePathTrackingDataStore.java
Author: olamy
Date: Tue Mar 4 02:47:12 2014
New Revision: 1573845
URL: http://svn.apache.org/r1573845
Log:
send directly data to remote storage, do not disconnect httpurl connection to be able to reuse connections and not creating so many sockets
Modified:
incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/Cube.java
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/Cube.java
URL: http://svn.apache.org/viewvc/incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/Cube.java?rev=1573845&r1=1573844&r2=1573845&view=diff
==============================================================================
--- incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/Cube.java (original)
+++ incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/Cube.java Tue Mar 4 02:47:12 2014
@@ -161,8 +161,10 @@ public class Cube {
connection.setDoInput(true);
connection.setDoOutput(true);
+ OutputStream output = null;
+
try {
- final OutputStream output = connection.getOutputStream();
+ output = connection.getOutputStream();
try {
// FIXME find a more efficient way to prevent to have all of this in memory
output.write( bytes );
@@ -178,8 +180,8 @@ public class Cube {
}
}
} finally {
- if (connection != null) {
- connection.disconnect();
+ if (output != null) {
+ output.close();
}
}
} catch (final Exception e) {
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=1573845&r1=1573844&r2=1573845&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 Tue Mar 4 02:47:12 2014
@@ -22,6 +22,7 @@ import org.apache.sirona.store.tracking.
import org.apache.sirona.store.tracking.CollectorPathTrackingDataStore;
import org.apache.sirona.tracking.PathTrackingEntry;
+import java.util.Collection;
import java.util.Map;
import java.util.Set;
@@ -34,6 +35,16 @@ public class CubePathTrackingDataStore
{
private final Cube cube = IoCs.findOrCreateInstance( CubeBuilder.class ).build();
+
+ @Override
+ public void store( Collection<PathTrackingEntry> pathTrackingEntries )
+ {
+ for (PathTrackingEntry pathTrackingEntry : pathTrackingEntries)
+ {
+ cube.post( cube.pathTrackingSnapshot( pathTrackingEntry ) );
+ }
+ }
+
@Override
protected void pushEntriesByBatch( Map<String, Set<PathTrackingEntry>> pathTrackingEntries ) {
for ( Map.Entry<String, Set<PathTrackingEntry>> entry : pathTrackingEntries.entrySet())