drcl.comp.lib.bytestream
Class ByteStreamNetPeer

java.lang.Object
  |
  +--drcl.DrclObj
        |
        +--drcl.comp.Component
              |
              +--drcl.comp.lib.bytestream.ByteStreamNetPeer

All Implemented Interfaces:

ActiveComponent, ByteStreamConstants, java.lang.Cloneable, ObjectDuplicable, java.io.Serializable

public class ByteStreamNetPeer

extends Component

implements ByteStreamConstants, ActiveComponent

An intermediate component that acts as between a ByteStreamContract component and a real network socket.

As a reactor, it absorts any size of incoming data from the initiator and sends the data to the real socket. It always reports available buffer size of 1 to keep the initiator sending data.

As an initiator, it relays data from the real socket to the reactor in bulks of size dataUnit.

See Also:

Serialized Form

Inner classes inherited from class drcl.comp.Component

Component.LockPack

Fields inherited from class drcl.comp.Component

FLAG_COMPONENT_NOTIFICATION, FLAG_DEBUG_ENABLED, FLAG_DIRECT_OUTPUT_ENABLED, FLAG_ENABLED, FLAG_ERROR_ENABLED, FLAG_EVENT_ENABLED, FLAG_GARBAGE_DISPLAY_ENABLED, FLAG_GARBAGE_ENABLED, FLAG_PORT_NOTIFICATION, FLAG_STARTED, FLAG_STOPPED, FLAG_TRACE_ENABLED, FLAG_UNDEFINED_START, id, infoPort, lockHead, name, parent, PortGroup_DEFAULT_GROUP, PortGroup_EVENT, PortGroup_SERVICE, Root, Trace_DATA, Trace_SEND

Fields inherited from interface drcl.comp.lib.bytestream.ByteStreamConstants

ERROR, QUERY, REPORT, SEND

Constructor Summary

ByteStreamNetPeer()

ByteStreamNetPeer(java.lang.String id_)

Method Summary

protected void	_start() This method is invoked in a new thread context when Component.run() is called.
void	accept(int serverPort_) Sets up a real socket and makes the component listens to the socket.
void	connect(java.lang.String serverAddress_, int serverPort_) Sets up a real socket and makes the component connects to the real remote socket.
void	duplicate(java.lang.Object source_) Duplicates the content of source_, including ID, name, child components and connections among them, to this component.
int	getDataUnit()
java.lang.String	info() Returns information regarding this component.
protected void	process(java.lang.Object data_, Port inPort_) The main callback method of a component.
void	reset() Resets the component for being used anew.
void	setDataUnit(int dataUnit_)

Methods inherited from class drcl.comp.Component

_resume, _stop, addComponent, addComponent, addEventPort, addEventPort, addForkPort, addPort, addPort, addPort, addPort, addPort, addPort, addPort, addPort, addServerPort, addServerPort, cancelFork, componentAdded, componentRemoved, connect, containsComponent, containsComponent, containsPort, debug, disconnectAll, disconnectAllPeers, disconnectAllPorts, drop, drop, error, error, expose, exposeEventPorts, exposePort, exposePort, exposePort, exposePort, exposePort, findAvailable, findAvailable, findAvailable, finishing, fork, forkAt, getAllComponents, getAllPorts, getAllPorts, getAllWiresInside, getAllWiresInsideOut, getAllWiresOut, getComponent, getComponentFlag, getComponentFlag, getContract, getContractHT, getContractHT, getDebugFlagsInBinary, getDebugLevelNames, getForkManager, getID, getName, getParent, getPort, getPort, getRoot, getRuntime, getTime, iduplicate, isAncestorOf, isComponentNotificationEnabled, isContainer, isDebugEnabled, isDebugEnabledAt, isDirectOutputEnabled, isEnabled, isErrorNoticeEnabled, isEventExportEnabled, isGarbageDisplayEnabled, isGarbageEnabled, isPortNotificationEnabled, isPortRemovable, isStarted, isStopped, isTraceEnabled, lock, notify, notifyAll, operate, portAdded, portRemoved, reboot, removeAll, removeAllComponents, removeAllPorts, removeAllPorts, removeComponent, removeComponent, removePort, removePort, removePort, resume, run, sduplicate, send, sendAt, setComponentFlag, setComponentFlag, setComponentNotificationEnabled, setContract, setDebugEnabled, setDebugEnabled, setDebugEnabledAt, setDebugEnabledAt, setDebugEnabledAt, setDirectOutputEnabled, setDirectOutputEnabled, setEnabled, setErrorNoticeEnabled, setErrorNoticeEnabled, setEventExportEnabled, setEventExportEnabled, setExecutionBoundary, setGarbageDisplayEnabled, setGarbageDisplayEnabled, setGarbageEnabled, setGarbageEnabled, setID, setID, setName, setPort, setPort, setPortNotificationEnabled, setPortRemovable, setRuntime, setTraceEnabled, setTraceEnabled, sleepFor, sleepUntil, stop, toString, unexpose, unlock, useLocalForkManager, useLocalForkManager, wait

Methods inherited from class drcl.DrclObj

clone

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteStreamNetPeer

public ByteStreamNetPeer()

ByteStreamNetPeer

public ByteStreamNetPeer(java.lang.String id_)

Method Detail

duplicate

public void duplicate(java.lang.Object source_)

Description copied from class: Component

Duplicates the content of source_, including ID, name, child components and connections among them, to this component. Subclasses need to override this method to copy its own variables.

Overrides:

duplicate in class Component

info

public java.lang.String info()

Description copied from class: Component

Returns information regarding this component. Subclasses should override this method to provide useful information at run-time.

Overrides:

info in class Component

reset

public void reset()

Description copied from class: Component

Resets the component for being used anew. All the internal variables must be set to the initial state. All the ports and child components are reset as well.

Overrides:

reset in class Component

accept

public void accept(int serverPort_)

Sets up a real socket and makes the component listens to the socket.

connect

public void connect(java.lang.String serverAddress_,
                    int serverPort_)

Sets up a real socket and makes the component connects to the real remote socket.

setDataUnit

public void setDataUnit(int dataUnit_)

getDataUnit

public int getDataUnit()

_start

protected void _start()

Description copied from class: Component

This method is invoked in a new thread context when Component.run() is called. An ActiveComponent subclass must override this method to start this component.

Overrides:

_start in class Component

process

protected void process(java.lang.Object data_,
                       Port inPort_)

Description copied from class: Component

The main callback method of a component. Being invoked when data arrives at a port of its.

Overrides:

process in class Component

Following copied from class: drcl.comp.Component

Parameters:

data_ - the arrival data.

inPort_ - the port where the data arrives.