java.lang.Object
swim.system.AbstractUplinkContext
swim.system.warp.WarpUplinkModem
- All Implemented Interfaces:
Link
,Uplink
,WarpLink
,WarpUplink
,Observable<Object>
,LinkContext
,WarpContext
,Log
- Direct Known Subclasses:
DemandUplinkModem
,ListUplinkModem
,MapUplinkModem
,SupplyUplinkModem
public abstract class WarpUplinkModem
extends AbstractUplinkContext
implements WarpContext, WarpUplink
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final WarpBinding
protected int
protected final UplinkAddress
Fields inherited from class swim.system.AbstractUplinkContext
observers
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
WarpUplinkModem
(WarpBinding linkBinding, UplinkAddress uplinkAddress) -
Method Summary
Modifier and TypeMethodDescriptionfinal Value
body()
final UplinkAddress
protected WarpUplinkProfile
collectProfile
(long dt) void
cueDown()
void
cueUp()
protected void
didClose()
protected void
didLink
(LinkedResponse response) protected void
didSync
(SyncedResponse response) protected void
didUnlink
(UnlinkedResponse response) protected void
protected void
protected boolean
dispatchOnCommand
(CommandMessage message, boolean preemptive) protected void
dispatchOnEvent
(EventMessage message) protected boolean
dispatchOnLink
(LinkRequest request, boolean preemptive) protected void
dispatchOnLinked
(LinkedResponse response) protected boolean
dispatchOnSync
(SyncRequest request, boolean preemptive) protected void
dispatchOnSynced
(SyncedResponse response) protected boolean
dispatchOnUnlink
(UnlinkRequest request, boolean preemptive) protected void
dispatchOnUnlinked
(UnlinkedResponse response) protected boolean
void
feedUp()
protected void
final Uri
hostUri()
final Uri
laneUri()
final WarpBinding
protected LinkedResponse
final Value
linkKey()
final WarpBinding
protected Value
protected EventMessage
protected Value
protected EventMessage
final Uri
nodeUri()
onCommand
(OnCommandMessage onCommand) protected void
onCommand
(CommandMessage message) onEvent
(OnEventMessage onEvent) protected void
onEvent
(EventMessage message) onLink
(OnLinkRequest onLink) onLinked
(OnLinkedResponse onLinked) onSync
(OnSyncRequest onSync) onSynced
(OnSyncedResponse onSynced) onUnlink
(OnUnlinkRequest onUnlink) onUnlinked
(OnUnlinkedResponse onUnlinked) void
openMetaUplink
(LinkBinding uplink, NodeBinding metaUplink) final float
prio()
void
pullDown()
protected void
protected void
pullDownEvent
(EventMessage message) protected void
pullDownLinked
(LinkedResponse response) protected void
pullDownSynced
(SyncedResponse response) protected void
pullDownUnlinked
(UnlinkedResponse response) protected void
void
protected void
pushUpCommand
(Push<CommandMessage> push) protected void
pushUpLink
(Push<LinkRequest> push) protected void
pushUpSync
(Push<SyncRequest> push) protected void
pushUpUnknown
(Push<?> push) protected void
pushUpUnlink
(Push<UnlinkRequest> push) protected void
final float
rate()
protected void
reportMetrics
(long dt) protected void
runOnCommand
(Push<CommandMessage> push) protected void
runOnLink
(Push<LinkRequest> push) protected void
runOnSync
(Push<SyncRequest> push) protected void
runOnUnlink
(Push<UnlinkRequest> push) protected void
void
void
skipUp()
protected SyncedResponse
void
unlink()
protected UnlinkedResponse
protected void
willLink
(LinkRequest request) protected void
willSync
(SyncRequest request) protected void
willUnlink
(UnlinkRequest request) Methods inherited from class swim.system.AbstractUplinkContext
bottomLink, cipherSuite, cipherSuiteUp, close, closeUp, debug, debugUp, didCloseDown, didFail, didFailDown, didOpenDown, error, errorUp, fail, failUp, info, infoUp, isConnected, isConnectedUp, isRemote, isRemoteUp, isSecure, isSecureUp, laneBinding, localAddress, localAddressUp, localCertificates, localCertificatesUp, localIdentity, localIdentityUp, localPrincipal, localPrincipalUp, remoteAddress, remoteAddressUp, remoteCertificates, remoteCertificatesUp, remoteIdentity, remoteIdentityUp, remotePrincipal, remotePrincipalUp, securityProtocol, securityProtocolUp, stage, trace, traceUp, unwrapLink, warn, warnUp
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface swim.api.Link
cipherSuite, close, isConnected, isRemote, isSecure, localAddress, localCertificates, localIdentity, localPrincipal, remoteAddress, remoteCertificates, remoteIdentity, remotePrincipal, securityProtocol
Methods inherited from interface swim.system.LinkContext
bottomLink, cipherSuiteUp, closeUp, debugUp, didCloseDown, didFailDown, didOpenDown, errorUp, failUp, infoUp, isConnectedUp, isRemoteUp, isSecureUp, localAddressUp, localCertificatesUp, localIdentityUp, localPrincipalUp, remoteAddressUp, remoteCertificatesUp, remoteIdentityUp, remotePrincipalUp, securityProtocolUp, traceUp, unwrapLink, warnUp
-
Field Details
-
linkBinding
-
uplinkAddress
-
status
protected volatile int status
-
-
Constructor Details
-
WarpUplinkModem
-
-
Method Details
-
linkWrapper
- Specified by:
linkWrapper
in interfaceLinkContext
- Specified by:
linkWrapper
in interfaceWarpContext
- Specified by:
linkWrapper
in classAbstractUplinkContext
-
linkBinding
- Specified by:
linkBinding
in classAbstractUplinkContext
-
hostUri
- Specified by:
hostUri
in interfaceLink
- Specified by:
hostUri
in classAbstractUplinkContext
-
nodeUri
- Specified by:
nodeUri
in interfaceLink
- Specified by:
nodeUri
in classAbstractUplinkContext
-
laneUri
- Specified by:
laneUri
in interfaceLink
- Specified by:
laneUri
in classAbstractUplinkContext
-
linkKey
- Specified by:
linkKey
in interfaceLinkContext
- Specified by:
linkKey
in classAbstractUplinkContext
-
cellAddressUp
- Specified by:
cellAddressUp
in interfaceLinkContext
- Overrides:
cellAddressUp
in classAbstractUplinkContext
-
prio
public final float prio()- Specified by:
prio
in interfaceWarpUplink
-
rate
public final float rate()- Specified by:
rate
in interfaceWarpUplink
-
body
- Specified by:
body
in interfaceWarpUplink
-
observe
- Specified by:
observe
in interfaceLink
- Specified by:
observe
in interfaceObservable<Object>
- Specified by:
observe
in interfaceUplink
- Specified by:
observe
in interfaceWarpUplink
- Overrides:
observe
in classAbstractUplinkContext
-
unobserve
- Specified by:
unobserve
in interfaceLink
- Specified by:
unobserve
in interfaceObservable<Object>
- Specified by:
unobserve
in interfaceUplink
- Specified by:
unobserve
in interfaceWarpUplink
- Overrides:
unobserve
in classAbstractUplinkContext
-
onEvent
- Specified by:
onEvent
in interfaceWarpUplink
-
onCommand
- Specified by:
onCommand
in interfaceWarpUplink
-
onLink
- Specified by:
onLink
in interfaceWarpUplink
-
onLinked
- Specified by:
onLinked
in interfaceWarpUplink
-
onSync
- Specified by:
onSync
in interfaceWarpUplink
-
onSynced
- Specified by:
onSynced
in interfaceWarpUplink
-
onUnlink
- Specified by:
onUnlink
in interfaceWarpUplink
-
onUnlinked
- Specified by:
onUnlinked
in interfaceWarpUplink
-
didClose
- Specified by:
didClose
in interfaceWarpUplink
-
dispatchOnEvent
-
dispatchOnCommand
-
dispatchOnLink
-
dispatchOnLinked
-
dispatchOnSync
-
dispatchOnSynced
-
dispatchOnUnlink
-
dispatchOnUnlinked
-
dispatchDidClose
protected void dispatchDidClose() -
downQueueIsEmpty
protected boolean downQueueIsEmpty() -
queueDown
-
nextDownQueue
-
nextDownQueueEvent
-
nextDownCue
-
nextDownCueEvent
-
sendDown
-
cueDown
public void cueDown() -
pullDown
public void pullDown()- Specified by:
pullDown
in interfaceWarpContext
-
runPullDown
protected void runPullDown() -
pullDownEnvelope
protected void pullDownEnvelope() -
pullDownEvent
-
pullDownLinked
-
pullDownSynced
-
pullDownUnlinked
-
pushDown
-
cueUp
public void cueUp() -
feedUp
public void feedUp()- Specified by:
feedUp
in interfaceWarpContext
-
pushUp
- Specified by:
pushUp
in interfaceWarpContext
-
pushUpCommand
-
runOnCommand
-
pushUpLink
-
runOnLink
-
pushUpSync
-
runOnSync
-
pushUpUnlink
-
runOnUnlink
-
pushUpUnknown
-
skipUp
public void skipUp()- Specified by:
skipUp
in interfaceWarpContext
-
unlink
public void unlink() -
onEvent
-
onCommand
-
willLink
-
didLink
-
willSync
-
didSync
-
willUnlink
-
didUnlink
-
linkedResponse
-
syncedResponse
-
unlinkedResponse
-
didClose
protected void didClose()- Overrides:
didClose
in classAbstractUplinkContext
-
openMetaUplink
- Specified by:
openMetaUplink
in interfaceLinkContext
-
didUpdateMetrics
protected void didUpdateMetrics() -
flushMetrics
protected void flushMetrics() -
reportMetrics
protected void reportMetrics(long dt) -
collectProfile
-