kieker.analysis.plugin.reader.tcp.util

Class SingleSocketRecordReader

java.lang.Object

kieker.analysis.plugin.reader.tcp.util.AbstractTcpReader

kieker.analysis.plugin.reader.tcp.util.SingleSocketRecordReader

All Implemented Interfaces:

java.lang.Runnable

public class SingleSocketRecordReader
extends AbstractTcpReader

Represents a TCP reader which reads and reconstructs Kieker records from a single TCP stream.

Since:

1.13

Author:

Christian Wulf (chw)

Field Summary

Fields inherited from class kieker.analysis.plugin.reader.tcp.util.AbstractTcpReader

logger

Constructor Summary

Constructors

Constructor and Description
SingleSocketRecordReader(int port, int bufferCapacity, Log logger, IRecordReceivedListener listener)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	onBufferReceived(java.nio.ByteBuffer buffer)

Methods inherited from class kieker.analysis.plugin.reader.tcp.util.AbstractTcpReader

getPort, run, terminate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SingleSocketRecordReader

public SingleSocketRecordReader(int port,
                        int bufferCapacity,
                        Log logger,
                        IRecordReceivedListener listener)

Method Detail

onBufferReceived

protected boolean onBufferReceived(java.nio.ByteBuffer buffer)

Specified by:

onBufferReceived in class AbstractTcpReader

Parameters:

buffer - to be read from

Returns:

• true when there were enough bytes to perform the read operation
• false otherwise. In this case, the buffer is reset, compacted, and filled with new content.