Module swim.system

Package swim.system.warp

Class WarpLaneModel<View extends WarpLaneView,U extends WarpUplinkModem>

java.lang.Object

swim.system.AbstractWarpRef

swim.system.AbstractTierBinding

swim.system.LaneModel<View,U>

swim.system.warp.WarpLaneModel<View,U>

All Implemented Interfaces:

DownlinkFactory, WarpRef, CellBinding, CellContext, LaneBinding, TierBinding, Log

Direct Known Subclasses:

CommandLaneModel, DemandLaneModel, DemandMapLaneModel, JoinMapLaneModel, JoinValueLaneModel, ListLaneModel, MapLaneModel, SpatialLaneModel, SupplyLaneModel, ValueLaneModel

public abstract class WarpLaneModel<View extends WarpLaneView,U extends WarpUplinkModem>
extends LaneModel<View,U>

Field Summary

Fields

Modifier and Type	Field	Description
protected static final AtomicLongFieldUpdater<WarpLaneModel<?,?>>	EXEC_DELTA
protected static final AtomicLongFieldUpdater<WarpLaneModel<?,?>>	EXEC_TIME

Fields inherited from class swim.system.LaneModel

laneContext, uplinks, UPLINKS, views, VIEWS

Fields inherited from class swim.system.AbstractTierBinding

CLOSED_PHASE, CLOSED_STATE, CLOSING_STATE, FAILED_STATE, FAILING_STATE, LOADED_PHASE, LOADED_STATE, LOADING_STATE, OPENED_PHASE, OPENED_STATE, OPENING_STATE, PHASE_MASK, PHASE_SHIFT, RECOVERING_STATE, STARTED_PHASE, STARTED_STATE, STARTING_STATE, STATE_MASK, status, STATUS, STOPPING_STATE, UNLOADING_STATE

Constructor Summary

Constructors

Constructor	Description
WarpLaneModel()

Method Summary

Modifier and Type	Method	Description
void	accumulateExecTime(long execDelta)
protected void	accumulateWarpDownlinkProfile(WarpDownlinkProfile profile)
protected void	accumulateWarpUplinkProfile(WarpUplinkProfile profile)
protected WarpLaneProfile	collectProfile(long dt)
protected U	createUplink(LinkBinding link)
protected abstract U	createWarpUplink(WarpBinding link)
void	cueDown()
void	didClose()
protected void	didCloseUplink(U uplink)
protected void	didEnter(Identity identity)
protected void	didLeave(Identity identity)
protected void	didOpenUplink(U uplink)
protected void	didUpdateMetrics()
protected void	flushMetrics()
protected void	onCommand(Push<CommandMessage> push)
void	pushUp(Push<?> push)
void	pushUpCommand(Push<CommandMessage> push)
void	reportDown(Metric metric)
protected void	reportMetrics(long dt)
void	sendDown(Value body)

Methods inherited from class swim.system.LaneModel

bindDownlink, bottomLane, cellAddress, closeDownlink, closeLaneView, closeUplink, createUplinkAddress, debug, didCloseLaneView, didFail, didOpenLaneView, edgeName, error, fail, getLaneView, getUplink, hostUri, info, isLinked, laneContext, laneUri, laneWrapper, meshUri, node, nodeUri, openDownlink, openLaneView, openMetaDownlink, openMetaLane, openMetaLanes, openMetaUplink, openReflectLanes, openUplink, partKey, policy, pushDown, schedule, setLaneContext, stage, store, tierContext, trace, unwrapLane, uplinks, warn, willClose, willLoad, willOpen, willStart, willStop, willUnload

Methods inherited from class swim.system.AbstractTierBinding

activate, awaitStart, close, didLoad, didOpen, didStart, didStop, didUnload, isClosed, isLoaded, isOpened, isStarted, load, open, start, stop, unload

Methods inherited from class swim.system.AbstractWarpRef

command, command, command, command, command, command, command, command, command, command, command, command, command, command, command, command, downlink, downlinkHttp, downlinkList, downlinkMap, downlinkValue, downlinkWs, hostRef, hostRef, laneRef, laneRef, laneRef, laneRef, nodeRef, nodeRef, nodeRef, nodeRef

Methods inherited from class java.lang.Object

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

Methods inherited from interface swim.system.LaneBinding

laneType

Methods inherited from interface swim.system.TierBinding

close, isClosed, isLoaded, isOpened, isStarted, load, open, start, stop, unload

Field Details

EXEC_DELTA

protected static final AtomicLongFieldUpdater<WarpLaneModel<?,?>> EXEC_DELTA

EXEC_TIME

protected static final AtomicLongFieldUpdater<WarpLaneModel<?,?>> EXEC_TIME

Constructor Details

WarpLaneModel

public WarpLaneModel()

Method Details

createUplink

protected U createUplink(LinkBinding link)

Specified by:

createUplink in class LaneModel<View extends WarpLaneView,U extends WarpUplinkModem>

createWarpUplink

protected abstract U createWarpUplink(WarpBinding link)

cueDown

public void cueDown()

sendDown

public void sendDown(Value body)

pushUp

public void pushUp(Push<?> push)

Specified by:

pushUp in interface CellBinding

Specified by:

pushUp in class LaneModel<View extends WarpLaneView,U extends WarpUplinkModem>

pushUpCommand

public void pushUpCommand(Push<CommandMessage> push)

Specified by:

pushUpCommand in interface LaneBinding

Specified by:

pushUpCommand in class LaneModel<View extends WarpLaneView,U extends WarpUplinkModem>

onCommand

protected void onCommand(Push<CommandMessage> push)

didOpenUplink

protected void didOpenUplink(U uplink)

Overrides:

didOpenUplink in class LaneModel<View extends WarpLaneView,U extends WarpUplinkModem>

didCloseUplink

protected void didCloseUplink(U uplink)

Overrides:

didCloseUplink in class LaneModel<View extends WarpLaneView,U extends WarpUplinkModem>

didEnter

protected void didEnter(Identity identity)

didLeave

protected void didLeave(Identity identity)

didClose

public void didClose()

Specified by:

didClose in interface TierBinding

Overrides:

didClose in class LaneModel<View extends WarpLaneView,U extends WarpUplinkModem>

reportDown

public void reportDown(Metric metric)

Specified by:

reportDown in interface CellContext

Specified by:

reportDown in interface LaneBinding

Overrides:

reportDown in class LaneModel<View extends WarpLaneView,U extends WarpUplinkModem>

accumulateExecTime

public void accumulateExecTime(long execDelta)

Overrides:

accumulateExecTime in class LaneModel<View extends WarpLaneView,U extends WarpUplinkModem>

accumulateWarpUplinkProfile

protected void accumulateWarpUplinkProfile(WarpUplinkProfile profile)

accumulateWarpDownlinkProfile

protected void accumulateWarpDownlinkProfile(WarpDownlinkProfile profile)

didUpdateMetrics

protected void didUpdateMetrics()

flushMetrics

protected void flushMetrics()

reportMetrics

protected void reportMetrics(long dt)

collectProfile

protected WarpLaneProfile collectProfile(long dt)