equip.data
Class DataDelegatePeerTCP

java.lang.Object
  equip.data.DataDelegatePeerTCP

All Implemented Interfaces:

DataDelegatePeerCancel, java.lang.Runnable

public class DataDelegatePeerTCP

extends java.lang.Object

implements java.lang.Runnable, DataDelegatePeerCancel

Internal implementation class; works with DataDelegatePeer and DataDelegate to handle the direct networking aspects of a single dataspace peer. 'TCP' is actually now a misnomer, since it now uses the ConnectionSap abstraction to support both TCP and JCP.

Field Summary

(package private) boolean	connectedFlag
(package private) ConnectionSap	connection
(package private) java.lang.Object	connectLock
(package private) DeactivateCallback	deactivateCallback
(package private) ValueBase	deactivateClosure
(package private) boolean	deactivatedFlag
(package private) boolean	failedFlag
(package private) java.lang.Thread	inputThread
(package private) java.lang.Object	lock
(package private) static int	maxSentEvents
(package private) java.lang.Thread	outputThread
(package private) DataDelegatePeer	peer
(package private) boolean	persistFlag
(package private) boolean	replicateAll
(package private) java.util.Vector	sentEvents

Constructor Summary

DataDelegatePeerTCP(DataDelegatePeer peer)

Method Summary

(package private) void	addSentEvent(DataDelegatePeer.OutboundEvent oe)
void	checkCancelObject(UpdateEvent update1) this should be called from DataDelegatePeer.outputEvent when an UpdateEvent is added, to allow us to check whether this causes a cancel on a written object.
void	cleanup()
void	deactivate()
protected void	finalize()
DataDelegatePeer	getPeer()
void	run()
void	run(ConnectionSap connection, java.lang.Thread inputThread, boolean persistFlag, DeactivateCallback callback, ValueBase closure)
void	setPersist(boolean persistFlag)
boolean	waitForConnect()

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

lock

java.lang.Object lock

peer

DataDelegatePeer peer

connection

ConnectionSap connection

inputThread

java.lang.Thread inputThread

outputThread

java.lang.Thread outputThread

persistFlag

boolean persistFlag

deactivateCallback

DeactivateCallback deactivateCallback

deactivateClosure

ValueBase deactivateClosure

deactivatedFlag

boolean deactivatedFlag

connectLock

java.lang.Object connectLock

connectedFlag

boolean connectedFlag

failedFlag

boolean failedFlag

replicateAll

boolean replicateAll

sentEvents

java.util.Vector sentEvents

maxSentEvents

static final int maxSentEvents

See Also:

Constant Field Values

Constructor Detail

DataDelegatePeerTCP

public DataDelegatePeerTCP(DataDelegatePeer peer)

Method Detail

getPeer

public DataDelegatePeer getPeer()

waitForConnect

public boolean waitForConnect()

run

public void run(ConnectionSap connection,
                java.lang.Thread inputThread,
                boolean persistFlag,
                DeactivateCallback callback,
                ValueBase closure)

setPersist

public void setPersist(boolean persistFlag)

deactivate

public void deactivate()

run

public void run()

Specified by:

run in interface java.lang.Runnable

finalize

protected void finalize()

cleanup

public void cleanup()

addSentEvent

void addSentEvent(DataDelegatePeer.OutboundEvent oe)

checkCancelObject

public void checkCancelObject(UpdateEvent update1)

this should be called from DataDelegatePeer.outputEvent when an UpdateEvent is added, to allow us to check whether this causes a cancel on a written object.

Specified by:

checkCancelObject in interface DataDelegatePeerCancel