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 Socketm_Clientthe current client socket.protected adams.core.base.BaseCharsetm_Encodingthe encoding to use.protected booleanm_OutputStringwhether to output a string.protected intm_Portthe port to listen on.protected ServerSocketm_Serverthe socket in use.protected intm_Timeoutthe 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 voidcleanUp()Cleans up data structures, frees up memory.voiddefineOptions()Adds options to the internal list of options.protected StringdoReceive()Performs the actual reception of data.StringencodingTipText()Returns the tip text for this property.Classgenerates()Returns the type of data this scheme generates.adams.core.base.BaseCharsetgetEncoding()Returns the encoding to use.booleangetOutputString()Returns whether to output a string.intgetPort()Returns the port to connect to.StringgetQuickInfo()Returns a quick info about the actor, which will be displayed in the GUI.intgetTimeout()Returns the timeout in milli-second to wait for new connections.StringglobalInfo()Returns a string describing the object.StringinitReception()Initializes the reception.StringoutputStringTipText()Returns the tip text for this property.StringportTipText()Returns the tip text for this property.voidsetEncoding(adams.core.base.BaseCharset value)Sets the encoding to use.voidsetOutputString(boolean value)Sets whether to output a string.voidsetPort(int value)Sets the port to connect to.voidsetTimeout(int value)Sets the timeout in milli-second to wait for new connections.voidstopExecution()Stops the execution.StringtimeoutTipText()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:
globalInfoin interfaceadams.core.GlobalInfoSupporter- Specified by:
globalInfoin 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:
defineOptionsin interfaceadams.core.option.OptionHandler- Overrides:
defineOptionsin 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:
getQuickInfoin interfaceadams.core.QuickInfoSupporter- Overrides:
getQuickInfoin classAbstractRatInput- Returns:
- null if no info available, otherwise short string
-
generates
public Class generates()
Returns the type of data this scheme generates.- Specified by:
generatesin interfaceRatInput- Specified by:
generatesin classAbstractRatInput- Returns:
- the type of data
-
initReception
public String initReception()
Initializes the reception.- Specified by:
initReceptionin interfaceRatInput- Overrides:
initReceptionin classAbstractRatInput- Returns:
- null if successfully initialized, otherwise error message
-
doReceive
protected String doReceive()
Performs the actual reception of data.- Specified by:
doReceivein classAbstractRatInput- Returns:
- null if successful, otherwise error message
-
stopExecution
public void stopExecution()
Stops the execution.- Specified by:
stopExecutionin interfaceRatInput- Specified by:
stopExecutionin interfaceadams.core.Stoppable- Overrides:
stopExecutionin classAbstractBufferedRatInput
-
cleanUp
public void cleanUp()
Cleans up data structures, frees up memory.- Specified by:
cleanUpin interfaceadams.core.CleanUpHandler- Overrides:
cleanUpin classAbstractBufferedRatInput
-
-