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/28 07:18:04 UTC
svn commit: r1582624 -
/incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/DisruptorPathTrackingDataStore.java
Author: olamy
Date: Fri Mar 28 06:18:03 2014
New Revision: 1582624
URL: http://svn.apache.org/r1582624
Log:
numberOfConsumers must be configurable
Modified:
incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/DisruptorPathTrackingDataStore.java
Modified: incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/DisruptorPathTrackingDataStore.java
URL: http://svn.apache.org/viewvc/incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/DisruptorPathTrackingDataStore.java?rev=1582624&r1=1582623&r2=1582624&view=diff
==============================================================================
--- incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/DisruptorPathTrackingDataStore.java (original)
+++ incubator/sirona/trunk/agent/store/cube/src/main/java/org/apache/sirona/cube/DisruptorPathTrackingDataStore.java Fri Mar 28 06:18:03 2014
@@ -53,12 +53,15 @@ public class DisruptorPathTrackingDataSt
Configuration.getProperty( Configuration.CONFIG_PROPERTY_PREFIX + "pathtracking.singlestore", "false" ) );
+
private RingBuffer<PathTrackingEntry> ringBuffer;
private Disruptor<PathTrackingEntry> disruptor;
private int ringBufferSize = 4096;
+ private int numberOfConsumers = 4;
+
@Created
public void initialize()
{
@@ -76,12 +79,8 @@ public class DisruptorPathTrackingDataSt
}, ringBufferSize, exec, ProducerType.SINGLE, new BusySpinWaitStrategy()
);
- // FIXME configurable
- int numberOfConsumers = 4;
-
for ( int i = 0; i < numberOfConsumers; i++ )
{
- System.out.println( "create PathTrackingEntryEventHandler" );
disruptor.handleEventsWith( new PathTrackingEntryEventHandler( i, numberOfConsumers ) );
}
ringBuffer = disruptor.start();
@@ -163,6 +162,26 @@ public class DisruptorPathTrackingDataSt
this.ringBuffer = ringBuffer;
}
+ public int getNumberOfConsumers()
+ {
+ return numberOfConsumers;
+ }
+
+ public void setNumberOfConsumers( int numberOfConsumers )
+ {
+ this.numberOfConsumers = numberOfConsumers;
+ }
+
+ public int getRingBufferSize()
+ {
+ return ringBufferSize;
+ }
+
+ public void setRingBufferSize( int ringBufferSize )
+ {
+ this.ringBufferSize = ringBufferSize;
+ }
+
@Destroying
public void destroy()
{