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_DELTAprotected 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 voidaccumulateExecTime(long execDelta)protected voidaccumulateWarpDownlinkProfile(WarpDownlinkProfile profile)protected voidaccumulateWarpUplinkProfile(WarpUplinkProfile profile)protected WarpLaneProfilecollectProfile(long dt)protected UcreateUplink(LinkBinding link)protected abstract UcreateWarpUplink(WarpBinding link)voidcueDown()voiddidClose()protected voiddidCloseUplink(U uplink)protected voiddidEnter(Identity identity)protected voiddidLeave(Identity identity)protected voiddidOpenUplink(U uplink)protected voiddidUpdateMetrics()protected voidflushMetrics()protected voidonCommand(Push<CommandMessage> push)voidpushUp(Push<?> push)voidpushUpCommand(Push<CommandMessage> push)voidreportDown(Metric metric)protected voidreportMetrics(long dt)voidsendDown(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:
createUplinkin 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:
pushUpin interfaceCellBinding- Specified by:
pushUpin classLaneModel<View extends WarpLaneView,U extends WarpUplinkModem>
-
pushUpCommand
public void pushUpCommand(Push<CommandMessage> push)
- Specified by:
pushUpCommandin interfaceLaneBinding- Specified by:
pushUpCommandin classLaneModel<View extends WarpLaneView,U extends WarpUplinkModem>
-
onCommand
protected void onCommand(Push<CommandMessage> push)
-
didOpenUplink
protected void didOpenUplink(U uplink)
- Overrides:
didOpenUplinkin classLaneModel<View extends WarpLaneView,U extends WarpUplinkModem>
-
didCloseUplink
protected void didCloseUplink(U uplink)
- Overrides:
didCloseUplinkin 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:
didClosein interfaceTierBinding- Overrides:
didClosein classLaneModel<View extends WarpLaneView,U extends WarpUplinkModem>
-
reportDown
public void reportDown(Metric metric)
- Specified by:
reportDownin interfaceCellContext- Specified by:
reportDownin interfaceLaneBinding- Overrides:
reportDownin classLaneModel<View extends WarpLaneView,U extends WarpUplinkModem>
-
accumulateExecTime
public void accumulateExecTime(long execDelta)
- Overrides:
accumulateExecTimein 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)
-
-