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 AtomicLongFieldUpdater<WarpLaneModel<?,?>>
EXEC_DELTA
protected static AtomicLongFieldUpdater<WarpLaneModel<?,?>>
EXEC_TIME
-
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
All Methods Instance Methods Abstract Methods Concrete Methods 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
-
-
-
-
Field Detail
-
EXEC_DELTA
protected static final AtomicLongFieldUpdater<WarpLaneModel<?,?>> EXEC_DELTA
-
EXEC_TIME
protected static final AtomicLongFieldUpdater<WarpLaneModel<?,?>> EXEC_TIME
-
-
Method Detail
-
createUplink
protected U createUplink(LinkBinding link)
- Specified by:
createUplink
in classLaneModel<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 interfaceCellBinding
- Specified by:
pushUp
in classLaneModel<View extends WarpLaneView,U extends WarpUplinkModem>
-
pushUpCommand
public void pushUpCommand(Push<CommandMessage> push)
- Specified by:
pushUpCommand
in interfaceLaneBinding
- Specified by:
pushUpCommand
in classLaneModel<View extends WarpLaneView,U extends WarpUplinkModem>
-
onCommand
protected void onCommand(Push<CommandMessage> push)
-
didOpenUplink
protected void didOpenUplink(U uplink)
- Overrides:
didOpenUplink
in classLaneModel<View extends WarpLaneView,U extends WarpUplinkModem>
-
didCloseUplink
protected void didCloseUplink(U uplink)
- Overrides:
didCloseUplink
in classLaneModel<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 interfaceTierBinding
- Overrides:
didClose
in classLaneModel<View extends WarpLaneView,U extends WarpUplinkModem>
-
reportDown
public void reportDown(Metric metric)
- 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
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)
-
-