Skip to content
Snippets Groups Projects
Commit 045dbbad authored by Florian Fittkau's avatar Florian Fittkau
Browse files

minor

parent d4b7cc36
Branches
Tags
No related merge requests found
......@@ -6,9 +6,9 @@ import java.net.Socket;
import com.lmax.disruptor.EventHandler;
import explorviz.hpc_monitoring.disruptor.Byte32ArrayEvent;
import explorviz.hpc_monitoring.disruptor.ByteArrayEvent;
public class TCPConnector implements EventHandler<Byte32ArrayEvent> {
public class TCPConnector implements EventHandler<ByteArrayEvent> {
private static final int MESSAGE_BUFFER_SIZE = 65536;
private String providerUrl;
......@@ -76,7 +76,7 @@ public class TCPConnector implements EventHandler<Byte32ArrayEvent> {
}
@Override
public void onEvent(final Byte32ArrayEvent event, final long sequence,
public void onEvent(final ByteArrayEvent event, final long sequence,
final boolean endOfBatch) throws Exception {
sendMessage(event.getValue(), event.getLength());
}
......
......@@ -10,7 +10,7 @@ import com.lmax.disruptor.RingBuffer;
import com.lmax.disruptor.dsl.Disruptor;
import explorviz.hpc_monitoring.byteaccess.UnsafeBits;
import explorviz.hpc_monitoring.disruptor.Byte65536ArrayEvent;
import explorviz.hpc_monitoring.disruptor.ByteArrayEvent;
import explorviz.hpc_monitoring.disruptor.RecordEvent;
import explorviz.hpc_monitoring.filter.counting.CountingThroughputFilter;
import explorviz.hpc_monitoring.record.IRecord;
......@@ -20,7 +20,7 @@ import explorviz.hpc_monitoring.record.events.normal.AfterOperationEvent;
import explorviz.hpc_monitoring.record.events.normal.BeforeOperationEvent;
import gnu.trove.map.hash.TIntObjectHashMap;
public class MessageDistributer implements EventHandler<Byte65536ArrayEvent> {
public class MessageDistributer implements EventHandler<ByteArrayEvent> {
private static final CountingThroughputFilter counter = new CountingThroughputFilter(
"Records per second");
......@@ -45,7 +45,7 @@ public class MessageDistributer implements EventHandler<Byte65536ArrayEvent> {
}
@Override
public void onEvent(final Byte65536ArrayEvent event, final long sequence,
public void onEvent(final ByteArrayEvent event, final long sequence,
final boolean endOfBatch) throws Exception {
final byte[] received = event.getValue();
final int receivedLength = event.getLength();
......
......@@ -12,7 +12,7 @@ import com.lmax.disruptor.EventHandler;
import com.lmax.disruptor.RingBuffer;
import com.lmax.disruptor.dsl.Disruptor;
import explorviz.hpc_monitoring.disruptor.Byte65536ArrayEvent;
import explorviz.hpc_monitoring.disruptor.ByteArrayEvent;
import explorviz.hpc_monitoring.disruptor.RecordEvent;
public final class TCPReader {
......@@ -23,7 +23,7 @@ public final class TCPReader {
private ServerSocketChannel serversocket;
private boolean active = true;
private final RingBuffer<Byte65536ArrayEvent> ringBuffer;
private final RingBuffer<ByteArrayEvent> ringBuffer;
private final ByteBuffer buffer;
......@@ -35,11 +35,11 @@ public final class TCPReader {
buffer = ByteBuffer.allocateDirect(MESSAGE_BUFFER_SIZE);
final ExecutorService exec = Executors.newCachedThreadPool();
final Disruptor<Byte65536ArrayEvent> disruptor = new Disruptor<Byte65536ArrayEvent>(
Byte65536ArrayEvent.EVENT_FACTORY, 32, exec);
final Disruptor<ByteArrayEvent> disruptor = new Disruptor<ByteArrayEvent>(
ByteArrayEvent.EVENT_FACTORY, 32, exec);
@SuppressWarnings("unchecked")
final EventHandler<Byte65536ArrayEvent>[] eventHandlers = new EventHandler[1];
final EventHandler<ByteArrayEvent>[] eventHandlers = new EventHandler[1];
eventHandlers[0] = new MessageDistributer(endReceiver);
disruptor.handleEventsWith(eventHandlers);
ringBuffer = disruptor.start();
......@@ -81,7 +81,7 @@ public final class TCPReader {
private void putInRingBuffer(final byte[] messages, final int readBytes) {
final long hiseq = ringBuffer.next();
final Byte65536ArrayEvent valueEvent = ringBuffer.get(hiseq);
final ByteArrayEvent valueEvent = ringBuffer.get(hiseq);
valueEvent.setValue(messages);
valueEvent.setLength(readBytes);
ringBuffer.publish(hiseq);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment