kieker.analysis.plugin.reader.tcp.util

Class AbstractTcpReader

java.lang.Object

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

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

AbstractRecordTcpReader, SingleSocketRecordReader

public abstract class AbstractTcpReader
extends java.lang.Object
implements java.lang.Runnable

Represents a TCP reader without any knowledge about Kieker in general and records in particular.

Since:

1.13

Author:

Christian Wulf (chw)

Field Summary

Fields

Modifier and Type	Field and Description
protected Log	logger

Constructor Summary

Constructors

Constructor and Description
AbstractTcpReader(int port, int bufferCapacity, Log logger) Constructs a new TCP reader.

Method Summary

Methods

Modifier and Type	Method and Description
int	getPort()
protected abstract boolean	onBufferReceived(java.nio.ByteBuffer buffer)
void	run()
void	terminate() Gracefully terminates this TCP reader.

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final Log logger

Constructor Detail

AbstractTcpReader

public AbstractTcpReader(int port,
                 int bufferCapacity,
                 Log logger)

Constructs a new TCP reader.

Parameters:

port - on which to listen for requests

bufferCapacity - of the used read buffer

logger - for notification to users and developers

Method Detail

run

public final void run()

Specified by:

run in interface java.lang.Runnable

onBufferReceived

protected abstract boolean onBufferReceived(java.nio.ByteBuffer buffer)

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.

terminate

public void terminate()

Gracefully terminates this TCP reader.

getPort

public int getPort()