org.tapchain.core

Class ChainPiece<PARTNER extends Piece>

java.lang.Object

org.tapchain.core.Piece<PARTNER>

org.tapchain.core.ChainPiece<PARTNER>

All Implemented Interfaces:

java.io.Serializable, java.lang.Runnable, Chain.Tickable, IPiece<PARTNER>

Direct Known Subclasses:

Actor

public class ChainPiece<PARTNER extends Piece>
extends Piece<PARTNER>
implements java.io.Serializable, Chain.Tickable, java.lang.Runnable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ChainPiece.LogCase
static class	ChainPiece.PieceState

Nested classes/interfaces inherited from class org.tapchain.core.Piece

Piece.PartnerList<PARTNER extends IPiece>, Piece.PartnersReturn<PARTNER extends IPiece>

Field Summary

Fields

Modifier and Type	Field and Description
protected ActorManager.IStatusHandler<IPiece>	_statusHandler
protected IPieceHead	fImpl
static java.util.concurrent.ExecutorService	threadExecutor

Fields inherited from class org.tapchain.core.Piece

inPack, outPack, partnerList

Method Summary

Methods

Modifier and Type	Method and Description
<T> T	__exec(T obj, java.lang.String flg)
<T> T	__log(T obj, java.lang.String tag)
<T> T	__logout(T obj, java.lang.String tag)
protected boolean	_waitNext()
Chain.ConnectionResultOutConnector	appended(PathType stack_target, IPiece from, PathPack.OutPathPack.Output type) Check and accept connection from other piece.
Chain.ConnectionResultPath	appendTo(PathType stack, IPiece target, PathType stack_target) Check and append this piece to target piece.
ChainPiece	boost()
protected boolean	changeState(ChainPiece.PieceState state)
IPiece	end()
int	getId()
boolean	getLockStatus()
java.lang.String	getLockTag()
boolean	getLogLevel()
Chain	getParentChain()
java.lang.String	getState()
ActorManager.IStatusHandler<IPiece>	getStatusHandler()
java.lang.String	getTag()
int	getTickInterval()
void	init(java.lang.Object... obj)
void	initNum()
void	invalidate()
boolean	isAlive()
ChainPiece.LogCase	L(java.lang.String tag)
protected boolean	onError(Chain.ChainException e)
protected void	onTerminate()
protected boolean	onUnerror(Chain.ChainException e)
boolean	postAppend()
java.lang.String	printLastExecLog()
IPiece	restart()
protected ChainPiece.PieceState	restoreState()
void	run()
boolean	sendUnerrorEvent()
IPiece	setControlled(boolean c)
ChainPiece	setError(IErrorHandler er)
protected ChainPiece	setFunc(IPieceHead f)
ChainPiece	setLogLevel(boolean _log)
void	setLogTag(java.lang.String tag)
ChainPiece	setParentChain(Chain c)
ChainPiece	setStatusHandler(ActorManager.IStatusHandler<IPiece> st)
void	setTag(java.lang.String tag)
IPiece	start()
int	tick(Packet packet)
protected void	waitEnd()

Methods inherited from class org.tapchain.core.Piece

addInPath, addNewInPack, addNewOutPack, addOutPath, clearPull, clearPush, detach, detachAll, detached, getCache, getInPack, getInPathClasses, getLinks, getName, getOutPack, getOutPathClasses, getPackType, getPartners, getPartners, hasInPath, hasOutPath, input, inputHeapAsync, inputPeek, isConnectedTo, isConnectedTo, isConnectedTo, outputAll, outputAllReset, outputAllSimple, resetInPathPack, setInPackType, setInPathClass, setName, setOutPackType, setOutPathClass, setPartner, setPathClass, waitOutput, waitOutputAll

Methods inherited from class java.lang.Object

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

Field Detail

threadExecutor

public static java.util.concurrent.ExecutorService threadExecutor

fImpl

protected IPieceHead fImpl

_statusHandler

protected ActorManager.IStatusHandler<IPiece> _statusHandler

Method Detail

init

public void init(java.lang.Object... obj)

initNum

public void initNum()

getId

public int getId()

Specified by:

getId in interface IPiece<PARTNER extends Piece>

setFunc

protected ChainPiece setFunc(IPieceHead f)

setParentChain

public ChainPiece setParentChain(Chain c)

getParentChain

public Chain getParentChain()

setControlled

public IPiece setControlled(boolean c)

boost

public ChainPiece boost()

setLogLevel

public ChainPiece setLogLevel(boolean _log)

getLogLevel

public boolean getLogLevel()

setLogTag

public void setLogTag(java.lang.String tag)

__exec

public <T> T __exec(T obj,
           java.lang.String flg)

Specified by:

__exec in interface IPiece<PARTNER extends Piece>

printLastExecLog

public java.lang.String printLastExecLog()

__log

public <T> T __log(T obj,
          java.lang.String tag)

__logout

public <T> T __logout(T obj,
             java.lang.String tag)

L

public ChainPiece.LogCase L(java.lang.String tag)

Specified by:

L in interface IPiece<PARTNER extends Piece>

setError

public ChainPiece setError(IErrorHandler er)

setStatusHandler

public ChainPiece setStatusHandler(ActorManager.IStatusHandler<IPiece> st)

getStatusHandler

public ActorManager.IStatusHandler<IPiece> getStatusHandler()

isAlive

public boolean isAlive()

postAppend

public boolean postAppend()

restart

public IPiece restart()

_waitNext

protected boolean _waitNext()
                     throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

invalidate

public void invalidate()

start

public IPiece start()

run

public void run()

Specified by:

run in interface java.lang.Runnable

end

public IPiece end()

Specified by:

end in interface IPiece<PARTNER extends Piece>

Overrides:

end in class Piece<PARTNER extends Piece>

waitEnd

protected void waitEnd()
                throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

onError

protected boolean onError(Chain.ChainException e)

onUnerror

protected boolean onUnerror(Chain.ChainException e)

changeState

protected boolean changeState(ChainPiece.PieceState state)

getState

public java.lang.String getState()

tick

public int tick(Packet packet)

Specified by:

tick in interface Chain.Tickable

getTickInterval

public int getTickInterval()

Specified by:

getTickInterval in interface Chain.Tickable

restoreState

protected ChainPiece.PieceState restoreState()

sendUnerrorEvent

public boolean sendUnerrorEvent()

getLockStatus

public boolean getLockStatus()

getLockTag

public java.lang.String getLockTag()

onTerminate

protected void onTerminate()
                    throws Chain.ChainException

Throws:

Chain.ChainException

appendTo

public Chain.ConnectionResultPath appendTo(PathType stack,
                                  IPiece target,
                                  PathType stack_target)
                                    throws Chain.ChainException

Description copied from interface: IPiece

Check and append this piece to target piece.

Specified by:

appendTo in interface IPiece<PARTNER extends Piece>

Overrides:

appendTo in class Piece<PARTNER extends Piece>

Parameters:

stack - Packtype of this piece

target - IPiece of target piece

stack_target - PackType of target piece

Returns:

ConnectionResultIO object

Throws:

Chain.ChainException

appended

public Chain.ConnectionResultOutConnector appended(PathType stack_target,
                                          IPiece from,
                                          PathPack.OutPathPack.Output type)
                                            throws Chain.ChainException

Description copied from interface: IPiece

Check and accept connection from other piece.

Specified by:

appended in interface IPiece<PARTNER extends Piece>

Overrides:

appended in class Piece<PARTNER extends Piece>

Parameters:

stack_target - PackType of this piece

from - Piece from whom connection offered

type - Output type

Returns:

ConnectionResultO object

Throws:

Chain.ChainException

getTag

public java.lang.String getTag()

Specified by:

getTag in interface IPiece<PARTNER extends Piece>

setTag

public void setTag(java.lang.String tag)

Specified by:

setTag in interface IPiece<PARTNER extends Piece>