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
FieldsModifier and TypeFieldDescriptionprotected static final AtomicLongFieldUpdater<WarpLaneModel<?,
?>> protected static final AtomicLongFieldUpdater<WarpLaneModel<?,
?>> 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 -
Method Summary
Modifier and TypeMethodDescriptionvoid
accumulateExecTime
(long execDelta) protected void
protected void
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
protected void
protected void
didOpenUplink
(U uplink) protected void
protected void
protected void
onCommand
(Push<CommandMessage> push) void
void
pushUpCommand
(Push<CommandMessage> push) void
reportDown
(Metric metric) protected void
reportMetrics
(long dt) void
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
-
Field Details
-
EXEC_DELTA
-
EXEC_TIME
-
-
Constructor Details
-
WarpLaneModel
public WarpLaneModel()
-
-
Method Details
-
createUplink
- Specified by:
createUplink
in classLaneModel<View extends WarpLaneView,
U extends WarpUplinkModem>
-
createWarpUplink
-
cueDown
public void cueDown() -
sendDown
-
pushUp
- Specified by:
pushUp
in interfaceCellBinding
- Specified by:
pushUp
in classLaneModel<View extends WarpLaneView,
U extends WarpUplinkModem>
-
pushUpCommand
- Specified by:
pushUpCommand
in interfaceLaneBinding
- Specified by:
pushUpCommand
in classLaneModel<View extends WarpLaneView,
U extends WarpUplinkModem>
-
onCommand
-
didOpenUplink
- Overrides:
didOpenUplink
in classLaneModel<View extends WarpLaneView,
U extends WarpUplinkModem>
-
didCloseUplink
- Overrides:
didCloseUplink
in classLaneModel<View extends WarpLaneView,
U extends WarpUplinkModem>
-
didEnter
-
didLeave
-
didClose
public void didClose()- Specified by:
didClose
in interfaceTierBinding
- Overrides:
didClose
in classLaneModel<View extends WarpLaneView,
U extends WarpUplinkModem>
-
reportDown
- Specified by:
reportDown
in interfaceCellContext
- Specified by:
reportDown
in interfaceLaneBinding
- Overrides:
reportDown
in classLaneModel<View extends WarpLaneView,
U extends WarpUplinkModem>
-
accumulateExecTime
public void accumulateExecTime(long execDelta) - Overrides:
accumulateExecTime
in classLaneModel<View extends WarpLaneView,
U extends WarpUplinkModem>
-
accumulateWarpUplinkProfile
-
accumulateWarpDownlinkProfile
-
didUpdateMetrics
protected void didUpdateMetrics() -
flushMetrics
protected void flushMetrics() -
reportMetrics
protected void reportMetrics(long dt) -
collectProfile
-