java.lang.Object
swim.system.AbstractDownlinkBinding
swim.system.DownlinkModel<View>
swim.system.warp.WarpDownlinkModem<View>
- All Implemented Interfaces:
LinkBinding
,WarpBinding
,Log
- Direct Known Subclasses:
WarpDownlinkModel
public abstract class WarpDownlinkModem<View extends DownlinkView>
extends DownlinkModel<View>
implements WarpBinding
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final Value
protected CellContext
protected static final AtomicLongFieldUpdater<WarpDownlinkModem<?>>
protected static final AtomicLongFieldUpdater<WarpDownlinkModem<?>>
protected WarpContext
protected final float
protected final float
protected int
Fields inherited from class swim.system.DownlinkModel
views, VIEWS
Fields inherited from class swim.system.AbstractDownlinkBinding
hostUri, laneUri, meshUri, nodeUri
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
accumulateExecTime
(long execDelta) final Value
body()
final CellContext
void
protected WarpDownlinkProfile
collectProfile
(long dt) void
void
command
(float prio, Value body, Cont<CommandMessage> cont) void
void
command
(Value body, Cont<CommandMessage> cont) void
cueDown()
void
cueUp()
protected void
didAddDownlink
(View view) protected void
didClose()
void
void
void
void
void
protected void
didLink
(LinkedResponse response) protected void
didOpen()
protected void
didRemoveDownlink
(View view) protected void
didSync
(SyncedResponse response) protected void
didUnlink
(UnlinkedResponse response) protected void
void
feedDown()
protected void
feedUp()
protected void
abstract boolean
abstract boolean
void
link()
final WarpContext
protected LinkRequest
final WarpBinding
protected Push<CommandMessage>
protected Push<CommandMessage>
protected void
onCommand
(CommandMessage message) protected void
onEvent
(EventMessage message) void
openDown()
void
openMetaDownlink
(LinkBinding downlink, NodeBinding metaDownlink) final float
prio()
void
pullUp()
protected void
pullUpCommand
(CommandMessage message) protected void
pullUpLink
(LinkRequest request) protected void
pullUpSync
(SyncRequest request) protected void
pullUpUnlink
(UnlinkRequest request) void
protected void
pushDownEvent
(Push<EventMessage> push) protected void
pushDownLinked
(Push<LinkedResponse> push) protected void
pushDownSynced
(Push<SyncedResponse> push) protected void
pushDownUnknown
(Push<?> push) protected void
pushDownUnlinked
(Push<UnlinkedResponse> push) void
protected void
protected void
queueUp
(Value body, Cont<CommandMessage> cont) final float
rate()
protected void
reportMetrics
(long dt) void
setCellContext
(CellContext cellContext) void
setLinkContext
(LinkContext linkContext) void
skipDown()
void
sync()
protected SyncRequest
void
unlink()
protected UnlinkRequest
protected boolean
protected void
willLink
(LinkRequest request) protected void
willSync
(SyncRequest request) protected void
willUnlink
(UnlinkRequest request) Methods inherited from class swim.system.DownlinkModel
addDownlink, removeDownlink, removeDownlinks, reopen
Methods inherited from class swim.system.AbstractDownlinkBinding
bottomLink, cellAddressDown, cipherSuite, cipherSuiteDown, debug, debugDown, error, errorDown, fail, failDown, hostUri, info, infoDown, isConnected, isConnectedDown, isRemote, isRemoteDown, isSecure, isSecureDown, laneUri, linkKey, localAddress, localAddressDown, localCertificates, localCertificatesDown, localIdentity, localIdentityDown, localPrincipal, localPrincipalDown, meshUri, nodeUri, remoteAddress, remoteAddressDown, remoteCertificates, remoteCertificatesDown, remoteIdentity, remoteIdentityDown, remotePrincipal, remotePrincipalDown, securityProtocol, securityProtocolDown, setHostUri, setNodeUri, trace, traceDown, unwrapLink, warn, warnDown
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface swim.system.LinkBinding
bottomLink, cellAddressDown, cipherSuiteDown, debugDown, errorDown, failDown, hostUri, infoDown, isConnectedDown, isRemoteDown, isSecureDown, laneUri, linkKey, localAddressDown, localCertificatesDown, localIdentityDown, localPrincipalDown, meshUri, nodeUri, remoteAddressDown, remoteCertificatesDown, remoteIdentityDown, remotePrincipalDown, reopen, securityProtocolDown, setHostUri, setNodeUri, traceDown, unwrapLink, warnDown
-
Field Details
-
prio
protected final float prio -
rate
protected final float rate -
body
-
linkContext
-
cellContext
-
status
protected volatile int status -
EXEC_DELTA
-
EXEC_TIME
-
-
Constructor Details
-
WarpDownlinkModem
-
-
Method Details
-
linkWrapper
- Specified by:
linkWrapper
in interfaceLinkBinding
- Specified by:
linkWrapper
in interfaceWarpBinding
- Specified by:
linkWrapper
in classAbstractDownlinkBinding
-
linkContext
- Specified by:
linkContext
in interfaceLinkBinding
- Specified by:
linkContext
in interfaceWarpBinding
- Specified by:
linkContext
in classAbstractDownlinkBinding
-
setLinkContext
- Specified by:
setLinkContext
in interfaceLinkBinding
-
cellContext
- Specified by:
cellContext
in interfaceLinkBinding
- Specified by:
cellContext
in classAbstractDownlinkBinding
-
setCellContext
- Specified by:
setCellContext
in interfaceLinkBinding
-
prio
public final float prio()- Specified by:
prio
in interfaceWarpBinding
-
rate
public final float rate()- Specified by:
rate
in interfaceWarpBinding
-
body
- Specified by:
body
in interfaceWarpBinding
-
keepLinked
public abstract boolean keepLinked()- Specified by:
keepLinked
in interfaceWarpBinding
-
keepSynced
public abstract boolean keepSynced()- Specified by:
keepSynced
in interfaceWarpBinding
-
cueDown
public void cueDown() -
feedDown
public void feedDown()- Specified by:
feedDown
in interfaceWarpBinding
-
pushDown
- Specified by:
pushDown
in interfaceWarpBinding
-
pushDownEvent
-
pushDownLinked
-
pushDownSynced
-
pushDownUnlinked
-
pushDownUnknown
-
skipDown
public void skipDown()- Specified by:
skipDown
in interfaceWarpBinding
-
upQueueIsEmpty
protected boolean upQueueIsEmpty() -
queueUp
-
nextUpQueue
-
nextUpCue
-
pushUp
-
cueUp
public void cueUp() -
feedUp
protected void feedUp() -
pullUp
public void pullUp()- Specified by:
pullUp
in interfaceWarpBinding
-
pullUpCommand
-
pullUpLink
-
pullUpSync
-
pullUpUnlink
-
pushUp
-
link
public void link() -
sync
public void sync() -
unlink
public void unlink() -
command
-
command
-
command
-
command
-
linkRequest
-
syncRequest
-
unlinkRequest
-
didAddDownlink
- Overrides:
didAddDownlink
in classDownlinkModel<View extends DownlinkView>
-
didRemoveDownlink
- Overrides:
didRemoveDownlink
in classDownlinkModel<View extends DownlinkView>
-
openDown
public void openDown()- Specified by:
openDown
in interfaceLinkBinding
- Specified by:
openDown
in classAbstractDownlinkBinding
-
didOpen
protected void didOpen() -
closeDown
public void closeDown()- Specified by:
closeDown
in interfaceLinkBinding
- Specified by:
closeDown
in classAbstractDownlinkBinding
-
didClose
protected void didClose() -
onEvent
-
onCommand
-
willLink
-
didLink
-
willSync
-
didSync
-
willUnlink
-
didUnlink
-
didConnect
public void didConnect()- Specified by:
didConnect
in interfaceLinkBinding
- Overrides:
didConnect
in classDownlinkModel<View extends DownlinkView>
-
didDisconnect
public void didDisconnect()- Specified by:
didDisconnect
in interfaceLinkBinding
- Overrides:
didDisconnect
in classDownlinkModel<View extends DownlinkView>
-
didCloseUp
public void didCloseUp()- Specified by:
didCloseUp
in interfaceLinkBinding
- Overrides:
didCloseUp
in classDownlinkModel<View extends DownlinkView>
-
didFailUp
- Specified by:
didFailUp
in interfaceLinkBinding
- Specified by:
didFailUp
in classAbstractDownlinkBinding
-
didFail
- Specified by:
didFail
in interfaceLinkBinding
- Overrides:
didFail
in classDownlinkModel<View extends DownlinkView>
-
openMetaDownlink
- Specified by:
openMetaDownlink
in interfaceLinkBinding
-
accumulateExecTime
public void accumulateExecTime(long execDelta) - Overrides:
accumulateExecTime
in classDownlinkModel<View extends DownlinkView>
-
didUpdateMetrics
protected void didUpdateMetrics() -
flushMetrics
protected void flushMetrics() -
reportMetrics
protected void reportMetrics(long dt) -
collectProfile
-