org.tapchain.core

Class Piece<PARTNER extends IPiece>

java.lang.Object

org.tapchain.core.Piece<PARTNER>

All Implemented Interfaces:

IPiece<PARTNER>

Direct Known Subclasses:

ChainPiece

public abstract class Piece<PARTNER extends IPiece>
extends java.lang.Object
implements IPiece<PARTNER>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Piece.PartnerList<PARTNER extends IPiece>
class	Piece.PartnersReturn<PARTNER extends IPiece>

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Map<PathType,PathPack.InPathPack>	inPack
protected java.util.Map<PathType,PathPack.OutPathPack>	outPack
protected Piece.PartnerList	partnerList

Constructor Summary

Constructors

Constructor and Description
Piece()

Method Summary

Methods

Modifier and Type	Method and Description
protected Connector.InConnector	addInPath(PathType stack)
protected PathPack.InPathPack	addNewInPack(PathType type)
protected PathPack.OutPathPack	addNewOutPack(PathType type)
protected Connector.OutConnector	addOutPath(PathPack.OutPathPack.Output io, PathType stack)
Chain.ConnectionResultOutConnector	appended(PathType stack, 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.
boolean	clearPull()
boolean	clearPush()
IPath	detach(IPiece p)
void	detachAll()
void	detached(IPiece cp) Check and detach this piece from target piece.
IPiece	end()
<T> T	getCache(Connector.InConnector i)
PathPack.InPathPack	getInPack(PathType packtype)
java.util.Collection<ClassEnvelope>	getInPathClasses(PathType stack)
java.util.Collection<IPath>	getLinks()
java.lang.String	getName()
PathPack.OutPathPack	getOutPack(PathType stack)
java.util.Collection<ClassEnvelope>	getOutPathClasses(PathType stack)
PathType	getPackType(IPiece cp)
java.util.Collection<PARTNER>	getPartners()
java.util.Collection<PARTNER>	getPartners(PathType pathType, boolean outOrIn)
boolean	hasInPath(PathType pathType)
boolean	hasOutPath(PathType pathType)
java.util.ArrayList<Packet>	input(PathType type)
protected boolean	inputHeapAsync()
java.util.ArrayList<Packet>	inputPeek(PathType type)
boolean	isConnectedTo(IPiece cp) Check connection between this object and secondpiece.
boolean	isConnectedTo(IPiece cp, PathType pt)
boolean	isConnectedTo(PathType pathType, boolean out)
boolean	outputAll(PathType type, java.util.ArrayList<Packet> ar)
boolean	outputAllReset()
boolean	outputAllSimple(PathType type, Packet obj)
protected Piece	resetInPathPack(PathType pack)
Piece	setInPackType(PathType pack, PathPack.InPathPack.Input type)
boolean	setInPathClass(PathType stack, ClassEnvelope clz)
IPiece	setName(java.lang.String name)
Piece	setOutPackType(PathType pack, PathPack.OutPathPack.Output type)
boolean	setOutPathClass(PathType stack, ClassEnvelope clz)
void	setPartner(IPath o, IPiece cp, PathType type)
boolean	setPathClass(PathType pathType, boolean OutOrIn, ClassEnvelope clz)
void	waitOutput(java.util.ArrayList<Packet> rtn)
void	waitOutputAll(Packet rtn)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.tapchain.core.IPiece

__exec, getId, getTag, L, setTag

Field Detail

partnerList

protected Piece.PartnerList partnerList

inPack

protected java.util.Map<PathType,PathPack.InPathPack> inPack

outPack

protected java.util.Map<PathType,PathPack.OutPathPack> outPack

Constructor Detail

Piece

public Piece()

Method Detail

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 IPiece>

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

Parameters:

stack - PackType of this piece

from - Piece from whom connection offered

type - Output type

Returns:

ConnectionResultO object

Throws:

Chain.ChainException

setName

public IPiece setName(java.lang.String name)

getName

public java.lang.String getName()

Specified by:

getName in interface IPiece<PARTNER extends IPiece>

getOutPack

public PathPack.OutPathPack getOutPack(PathType stack)

Specified by:

getOutPack in interface IPiece<PARTNER extends IPiece>

getInPack

public PathPack.InPathPack getInPack(PathType packtype)

Specified by:

getInPack in interface IPiece<PARTNER extends IPiece>

setOutPackType

public Piece setOutPackType(PathType pack,
                   PathPack.OutPathPack.Output type)

setInPackType

public Piece setInPackType(PathType pack,
                  PathPack.InPathPack.Input type)

hasInPath

public boolean hasInPath(PathType pathType)

hasOutPath

public boolean hasOutPath(PathType pathType)

getLinks

public java.util.Collection<IPath> getLinks()

getPartners

public java.util.Collection<PARTNER> getPartners()

Specified by:

getPartners in interface IPiece<PARTNER extends IPiece>

getPartners

public java.util.Collection<PARTNER> getPartners(PathType pathType,
                                        boolean outOrIn)

Specified by:

getPartners in interface IPiece<PARTNER extends IPiece>

setPartner

public void setPartner(IPath o,
              IPiece cp,
              PathType type)

Specified by:

setPartner in interface IPiece<PARTNER extends IPiece>

isConnectedTo

public boolean isConnectedTo(IPiece cp)

Description copied from interface: IPiece

Check connection between this object and secondpiece.

Specified by:

isConnectedTo in interface IPiece<PARTNER extends IPiece>

Returns:

True when this object and secondpiece are connected.

isConnectedTo

public boolean isConnectedTo(IPiece cp,
                    PathType pt)

Specified by:

isConnectedTo in interface IPiece<PARTNER extends IPiece>

isConnectedTo

public boolean isConnectedTo(PathType pathType,
                    boolean out)

Specified by:

isConnectedTo in interface IPiece<PARTNER extends IPiece>

getPackType

public PathType getPackType(IPiece cp)

Specified by:

getPackType in interface IPiece<PARTNER extends IPiece>

addNewInPack

protected PathPack.InPathPack addNewInPack(PathType type)

addNewOutPack

protected PathPack.OutPathPack addNewOutPack(PathType type)

detachAll

public void detachAll()

addInPath

protected Connector.InConnector addInPath(PathType stack)

addOutPath

protected Connector.OutConnector addOutPath(PathPack.OutPathPack.Output io,
                                PathType stack)

getInPathClasses

public java.util.Collection<ClassEnvelope> getInPathClasses(PathType stack)

getOutPathClasses

public java.util.Collection<ClassEnvelope> getOutPathClasses(PathType stack)

setPathClass

public boolean setPathClass(PathType pathType,
                   boolean OutOrIn,
                   ClassEnvelope clz)

setInPathClass

public boolean setInPathClass(PathType stack,
                     ClassEnvelope clz)

setOutPathClass

public boolean setOutPathClass(PathType stack,
                      ClassEnvelope clz)

getCache

public <T> T getCache(Connector.InConnector i)
           throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

outputAll

public boolean outputAll(PathType type,
                java.util.ArrayList<Packet> ar)
                  throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

outputAllSimple

public boolean outputAllSimple(PathType type,
                      Packet obj)
                        throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

outputAllReset

public boolean outputAllReset()

resetInPathPack

protected Piece resetInPathPack(PathType pack)

detached

public void detached(IPiece cp)

Description copied from interface: IPiece

Check and detach this piece from target piece.

Specified by:

detached in interface IPiece<PARTNER extends IPiece>

Parameters:

cp - IPiece of target piece

waitOutput

public void waitOutput(java.util.ArrayList<Packet> rtn)
                throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

waitOutputAll

public void waitOutputAll(Packet rtn)
                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

clearPull

public boolean clearPull()

clearPush

public boolean clearPush()

inputHeapAsync

protected boolean inputHeapAsync()

inputPeek

public java.util.ArrayList<Packet> inputPeek(PathType type)
                                      throws java.lang.InterruptedException,
                                             IAxon.AxonException

Throws:

java.lang.InterruptedException

IAxon.AxonException

input

public java.util.ArrayList<Packet> input(PathType type)
                                  throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

detach

public IPath detach(IPiece p)

Specified by:

detach in interface IPiece<PARTNER extends IPiece>

end

public IPiece end()

Specified by:

end in interface IPiece<PARTNER extends IPiece>