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, ObjectCloneable, 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

Nested Class Summary

Nested classes inherited from class drcl.comp.Component

Component.Locks

Field Summary

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, locks, 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

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.
void	reset() Resets the component for being used anew.
void	setDataUnit(int dataUnit_)

Methods inherited from class drcl.comp.Component

addComponent, addComponent, addEventPort, addEventPort, addForkPort, addPort, addPort, addPort, addPort, addPort, addPort, addPort, addPort, addServerPort, addServerPort, cancelFork, connect, containsComponent, containsComponent, containsPort, debug, disconnectAll, disconnectAllPeers, disconnectAllPorts, drop, drop, error, error, expose, exposeEventPorts, exposePort, exposePort, exposePort, exposePort, exposePort, findAvailable, findAvailable, findAvailable, fork, forkAt, getAllComponents, getAllPorts, getAllPorts, getAllWiresInside, getAllWiresInsideOut, getAllWiresOut, getComponent, getComponentFlag, getComponentFlag, getContract, getContractHT, getContractHT, getDebugFlagsInBinary, getDebugLevelNames, getID, getName, getParent, getPort, getPort, getRoot, getTime, iduplicate, isAncestorOf, isContainer, isDebugEnabled, isDebugEnabledAt, isDirectlyRelatedTo, isDirectOutputEnabled, isEnabled, isErrorNoticeEnabled, isEventExportEnabled, isGarbageDisplayEnabled, isGarbageEnabled, isPortRemovable, isStarted, isStopped, isTraceEnabled, lock, notify, notifyAll, operate, reboot, removeAll, removeAllComponents, removeAllPorts, removeAllPorts, removeComponent, removeComponent, removePort, removePort, removePort, resume, run, sduplicate, send, sendAt, setComponentFlag, setComponentFlag, setDebugEnabled, setDebugEnabled, setDebugEnabledAt, setDebugEnabledAt, setDebugEnabledAt, setDirectOutputEnabled, setDirectOutputEnabled, setEnabled, setErrorNoticeEnabled, setErrorNoticeEnabled, setEventExportEnabled, setEventExportEnabled, setExecutionBoundary, setGarbageDisplayEnabled, setGarbageDisplayEnabled, setGarbageEnabled, setGarbageEnabled, setID, setID, setName, setPort, setPort, 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, 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.

Specified by:

duplicate in interface ObjectDuplicable

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