kieker.monitoring.core.controller.tcp

Class AbstractTcpReader

java.lang.Object

kieker.monitoring.core.controller.tcp.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 org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor and Description
AbstractTcpReader(int port, int bufferCapacity, org.slf4j.Logger logger) Constructs a new TCP reader.
AbstractTcpReader(int port, int bufferCapacity, org.slf4j.Logger logger, boolean respawn) Constructs a new TCP reader.

Method Summary

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 org.slf4j.Logger logger

Constructor Detail

AbstractTcpReader

public AbstractTcpReader(int port,
                         int bufferCapacity,
                         org.slf4j.Logger 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

AbstractTcpReader

public AbstractTcpReader(int port,
                         int bufferCapacity,
                         org.slf4j.Logger logger,
                         boolean respawn)

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

respawn - respawn reading after connection is lost

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()