Package adams.flow.standalone.rats.input
Class Socket
- java.lang.Object
-
- adams.core.logging.LoggingObject
-
- adams.core.logging.CustomLoggingLevelObject
-
- adams.core.option.AbstractOptionHandler
-
- adams.flow.standalone.rats.input.AbstractRatInput
-
- adams.flow.standalone.rats.input.AbstractBufferedRatInput
-
- adams.flow.standalone.rats.input.Socket
-
- All Implemented Interfaces:
adams.core.AdditionalInformationHandler
,adams.core.CleanUpHandler
,adams.core.Destroyable
,adams.core.GlobalInfoSupporter
,adams.core.logging.LoggingLevelHandler
,adams.core.logging.LoggingSupporter
,adams.core.option.OptionHandler
,adams.core.QuickInfoSupporter
,adams.core.ShallowCopySupporter<AbstractRatInput>
,adams.core.SizeOfHandler
,adams.core.Stoppable
,adams.core.StoppableWithFeedback
,BufferedRatInput
,RatInput
,Serializable
public class Socket extends AbstractBufferedRatInput
Listens on the specified port for incoming data.
Can either output raw byte arrays or strings (using the specified encoding).
-logging-level <OFF|SEVERE|WARNING|INFO|CONFIG|FINE|FINER|FINEST> (property: loggingLevel) The logging level for outputting errors and debugging output. default: WARNING
-max-buffer <int> (property: maxBuffer) The maximum number of items to buffer. default: 65535 minimum: 1
-port <int> (property: port) The port to listen on. default: 8000 minimum: 1 maximum: 65535
-timeout <int> (property: timeout) The timeout in milli-second for waiting on new client connections. default: 3000 minimum: 100
-output-string <boolean> (property: outputString) If enabled, a string with the specified encoding is generated from the incoming byte array. default: false
-encoding <adams.core.base.BaseCharset> (property: encoding) The type of encoding for sending the data. default: Default
- Author:
- FracPete (fracpete at waikato dot ac dot nz)
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description protected Socket
m_Client
the current client socket.protected adams.core.base.BaseCharset
m_Encoding
the encoding to use.protected boolean
m_OutputString
whether to output a string.protected int
m_Port
the port to listen on.protected ServerSocket
m_Server
the socket in use.protected int
m_Timeout
the timeout for the socket.-
Fields inherited from class adams.flow.standalone.rats.input.AbstractBufferedRatInput
m_Buffer, m_Current, m_MaxBuffer, m_PollTimeout
-
Fields inherited from class adams.flow.standalone.rats.input.AbstractRatInput
m_LoggingPrefix, m_Owner, m_ReceptionInterrupted, m_ReceptionRunning, m_Stopped
-
-
Constructor Summary
Constructors Constructor Description Socket()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cleanUp()
Cleans up data structures, frees up memory.void
defineOptions()
Adds options to the internal list of options.protected String
doReceive()
Performs the actual reception of data.String
encodingTipText()
Returns the tip text for this property.Class
generates()
Returns the type of data this scheme generates.adams.core.base.BaseCharset
getEncoding()
Returns the encoding to use.boolean
getOutputString()
Returns whether to output a string.int
getPort()
Returns the port to connect to.String
getQuickInfo()
Returns a quick info about the actor, which will be displayed in the GUI.int
getTimeout()
Returns the timeout in milli-second to wait for new connections.String
globalInfo()
Returns a string describing the object.String
initReception()
Initializes the reception.String
outputStringTipText()
Returns the tip text for this property.String
portTipText()
Returns the tip text for this property.void
setEncoding(adams.core.base.BaseCharset value)
Sets the encoding to use.void
setOutputString(boolean value)
Sets whether to output a string.void
setPort(int value)
Sets the port to connect to.void
setTimeout(int value)
Sets the timeout in milli-second to wait for new connections.void
stopExecution()
Stops the execution.String
timeoutTipText()
Returns the tip text for this property.-
Methods inherited from class adams.flow.standalone.rats.input.AbstractBufferedRatInput
bufferData, getDefaultMaxBuffer, getMaxBuffer, hasPendingOutput, initialize, maxBufferTipText, output, poll, setMaxBuffer, setUp
-
Methods inherited from class adams.flow.standalone.rats.input.AbstractRatInput
canReceive, check, configureLogger, doWait, getAdditionalInformation, getFullName, getOwner, getQueue, getReceptionInterrupted, handleException, interruptReception, isReceptionRunning, isStopped, receive, setOwner, shallowCopy, shallowCopy, updatePrefix
-
Methods inherited from class adams.core.option.AbstractOptionHandler
cleanUpOptions, destroy, finishInit, getDefaultLoggingLevel, getOptionManager, loggingLevelTipText, newOptionManager, reset, setLoggingLevel, toCommandLine, toString
-
Methods inherited from class adams.core.logging.LoggingObject
getLogger, getLoggingLevel, initializeLogging, isLoggingEnabled, sizeOf
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface adams.core.option.OptionHandler
cleanUpOptions, getOptionManager, toCommandLine
-
Methods inherited from interface adams.flow.standalone.rats.input.RatInput
getFullName, getOwner, getReceptionInterrupted, interruptReception, isReceptionRunning, isStopped, receive, setOwner
-
-
-
-
Field Detail
-
m_Port
protected int m_Port
the port to listen on.
-
m_Timeout
protected int m_Timeout
the timeout for the socket.
-
m_Encoding
protected adams.core.base.BaseCharset m_Encoding
the encoding to use.
-
m_OutputString
protected boolean m_OutputString
whether to output a string.
-
m_Server
protected transient ServerSocket m_Server
the socket in use.
-
m_Client
protected transient Socket m_Client
the current client socket.
-
-
Method Detail
-
globalInfo
public String globalInfo()
Returns a string describing the object.- Specified by:
globalInfo
in interfaceadams.core.GlobalInfoSupporter
- Specified by:
globalInfo
in classadams.core.option.AbstractOptionHandler
- Returns:
- a description suitable for displaying in the gui
-
defineOptions
public void defineOptions()
Adds options to the internal list of options.- Specified by:
defineOptions
in interfaceadams.core.option.OptionHandler
- Overrides:
defineOptions
in classAbstractBufferedRatInput
-
setPort
public void setPort(int value)
Sets the port to connect to.- Parameters:
value
- the port
-
getPort
public int getPort()
Returns the port to connect to.- Returns:
- the port
-
portTipText
public String portTipText()
Returns the tip text for this property.- Returns:
- tip text for this property suitable for displaying in the GUI or for listing the options.
-
setTimeout
public void setTimeout(int value)
Sets the timeout in milli-second to wait for new connections.- Parameters:
value
- the timeout in msec
-
getTimeout
public int getTimeout()
Returns the timeout in milli-second to wait for new connections.- Returns:
- the timeout in msec
-
timeoutTipText
public String timeoutTipText()
Returns the tip text for this property.- Returns:
- tip text for this property suitable for displaying in the gui
-
setOutputString
public void setOutputString(boolean value)
Sets whether to output a string.- Parameters:
value
- true if to output a string
-
getOutputString
public boolean getOutputString()
Returns whether to output a string.- Returns:
- true if to output a string
-
outputStringTipText
public String outputStringTipText()
Returns the tip text for this property.- Returns:
- tip text for this property suitable for displaying in the GUI or for listing the options.
-
setEncoding
public void setEncoding(adams.core.base.BaseCharset value)
Sets the encoding to use.- Parameters:
value
- the encoding, e.g. "UTF-8" or "UTF-16", empty string for default
-
getEncoding
public adams.core.base.BaseCharset getEncoding()
Returns the encoding to use.- Returns:
- the encoding, e.g. "UTF-8" or "UTF-16", empty string for default
-
encodingTipText
public String encodingTipText()
Returns the tip text for this property.- Returns:
- tip text for this property suitable for displaying in the GUI or for listing the options.
-
getQuickInfo
public String getQuickInfo()
Returns a quick info about the actor, which will be displayed in the GUI.- Specified by:
getQuickInfo
in interfaceadams.core.QuickInfoSupporter
- Overrides:
getQuickInfo
in classAbstractRatInput
- Returns:
- null if no info available, otherwise short string
-
generates
public Class generates()
Returns the type of data this scheme generates.- Specified by:
generates
in interfaceRatInput
- Specified by:
generates
in classAbstractRatInput
- Returns:
- the type of data
-
initReception
public String initReception()
Initializes the reception.- Specified by:
initReception
in interfaceRatInput
- Overrides:
initReception
in classAbstractRatInput
- Returns:
- null if successfully initialized, otherwise error message
-
doReceive
protected String doReceive()
Performs the actual reception of data.- Specified by:
doReceive
in classAbstractRatInput
- Returns:
- null if successful, otherwise error message
-
stopExecution
public void stopExecution()
Stops the execution.- Specified by:
stopExecution
in interfaceRatInput
- Specified by:
stopExecution
in interfaceadams.core.Stoppable
- Overrides:
stopExecution
in classAbstractBufferedRatInput
-
cleanUp
public void cleanUp()
Cleans up data structures, frees up memory.- Specified by:
cleanUp
in interfaceadams.core.CleanUpHandler
- Overrides:
cleanUp
in classAbstractBufferedRatInput
-
-