java.lang.Object
swim.system.AbstractWarpRef
swim.system.AbstractTierBinding
swim.remote.RemoteHost
- All Implemented Interfaces:
DownlinkFactory
,WarpRef
,StayContext
,WarpSocket
,CellBinding
,CellContext
,HostBinding
,TierBinding
,Log
- Direct Known Subclasses:
RemoteHostClient
-
Field Summary
FieldsFields 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
ConstructorsConstructorDescriptionRemoteHost
(Uri baseUri) RemoteHost
(Uri requestUri, Uri baseUri) RemoteHost
(Uri requestUri, Uri baseUri, HashTrieMap<String, Cookie> cookies) -
Method Summary
Modifier and TypeMethodDescriptionbindDownlink
(Downlink downlink) <T> T
bottomHost
(Class<T> hostClass) void
closeDownlink
(LinkBinding link) protected void
protected void
protected HostProfile
collectProfile
(long dt) protected void
void
Logs a debug-level message.void
void
void
void
didClose()
protected void
didCloseDownlink
(WarpBinding downlink) protected void
didCloseUplink
(WarpContext uplink) void
void
void
protected void
didOpenDownlink
(WarpBinding downlink) protected void
didOpenUplink
(WarpContext uplink) protected void
didPushMessage
(Envelope envelope) void
void
didRead
(WsControlFrame<?, ?> frame) protected void
didReadClose
(WsCloseFrame<?, ?> frame) void
void
protected void
void
didUpgrade
(HttpRequest<?> request, HttpResponse<?> response) void
void
didWrite
(WsControlFrame<?, ?> frame) protected void
void
doRead()
void
doWrite()
edgeName()
void
Logs an error-level message.void
Logs an fail-level message.protected void
protected void
forbid()
final HostContext
hostUri()
final HostBinding
long
void
Logs an info-level message.boolean
boolean
isMaster()
boolean
boolean
isRemote()
boolean
boolean
isSecure()
boolean
isSlave()
meshUri()
nodes()
protected void
onAuthedResponse
(AuthedResponse response) protected void
onAuthRequest
(AuthRequest request) protected void
onCommandMessage
(CommandMessage message) protected void
onDeauthedResponse
(DeauthedResponse response) protected void
onDeauthRequest
(DeauthRequest request) protected void
onEventMessage
(EventMessage message) protected void
onLinkedResponse
(LinkedResponse response) protected void
onLinkRequest
(LinkRequest request) protected void
onSyncedResponse
(SyncedResponse response) protected void
onSyncRequest
(SyncRequest request) protected void
onUnknownEnvelope
(Envelope envelope) protected void
onUnlinkedResponse
(UnlinkedResponse response) protected void
onUnlinkRequest
(UnlinkRequest request) void
openDownlink
(LinkBinding link) void
openMetaDownlink
(LinkBinding downlink, NodeBinding metaDownlink) void
openMetaHost
(HostBinding host, NodeBinding metaHost) void
openMetaLane
(LaneBinding lane, NodeBinding metaLane) protected void
openMetaLanes
(HostBinding host, AgentNode metaHost) void
openMetaNode
(NodeBinding node, NodeBinding metaNode) void
openMetaUplink
(LinkBinding uplink, NodeBinding metaUplink) openNode
(Uri nodeUri, NodeBinding node) protected void
openReflectLanes
(HostBinding host, AgentNode metaHost) void
openUplink
(LinkBinding link) protected void
openWarpUplink
(WarpBinding link) final PartBinding
part()
partKey()
policy()
void
void
protected void
protected void
void
reportDown
(Metric metric) protected void
reportMetrics
(long dt) protected Uri
protected void
routeDownlink
(LinkAddressed envelope) protected void
routeUplink
(LaneAddressed envelope) schedule()
void
setHostContext
(HostContext hostContext) void
setPrimary
(boolean isPrimary) void
setReplica
(boolean isReplica) void
setWarpSocketContext
(WarpSocketContext warpSocketContext) stage()
store()
final TierContext
void
Logs a trace-level message.<T> T
unwrapHost
(Class<T> hostClass) void
Logs a warn-level message.void
willBecome
(IpSocket socket) protected void
void
protected void
willPushMessage
(Envelope envelope) void
Methods inherited from class swim.system.AbstractTierBinding
activate, awaitStart, close, didLoad, didOpen, didStart, didStop, didUnload, isClosed, isLoaded, isOpened, isStarted, load, open, start, stop, unload, willLoad, willOpen, willStart, willStop, willUnload
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
-
Field Details
-
hostContext
-
warpSocketContext
-
-
Constructor Details
-
RemoteHost
-
RemoteHost
-
RemoteHost
-
-
Method Details
-
tierContext
- Specified by:
tierContext
in interfaceTierBinding
- Specified by:
tierContext
in classAbstractTierBinding
-
part
- Specified by:
part
in interfaceHostBinding
-
hostWrapper
- Specified by:
hostWrapper
in interfaceHostBinding
-
unwrapHost
- Specified by:
unwrapHost
in interfaceHostBinding
-
bottomHost
- Specified by:
bottomHost
in interfaceHostBinding
-
hostContext
- Specified by:
hostContext
in interfaceHostBinding
-
setHostContext
- Specified by:
setHostContext
in interfaceHostBinding
-
warpSocketContext
- Specified by:
warpSocketContext
in interfaceWarpSocket
-
setWarpSocketContext
- Specified by:
setWarpSocketContext
in interfaceWarpSocket
-
idleTimeout
public long idleTimeout()- Specified by:
idleTimeout
in interfaceWarpSocket
-
cellAddress
- Specified by:
cellAddress
in interfaceCellContext
- Specified by:
cellAddress
in interfaceHostBinding
-
edgeName
- Specified by:
edgeName
in interfaceCellContext
-
meshUri
- Specified by:
meshUri
in interfaceCellContext
- Specified by:
meshUri
in interfaceHostBinding
-
partKey
- Specified by:
partKey
in interfaceHostBinding
-
hostUri
- Specified by:
hostUri
in interfaceHostBinding
-
policy
- Specified by:
policy
in interfaceCellContext
-
schedule
- Specified by:
schedule
in interfaceCellContext
-
stage
- Specified by:
stage
in interfaceCellContext
-
store
- Specified by:
store
in interfaceCellContext
-
isConnected
public boolean isConnected()- Specified by:
isConnected
in interfaceHostBinding
-
isRemote
public boolean isRemote()- Specified by:
isRemote
in interfaceHostBinding
-
isSecure
public boolean isSecure()- Specified by:
isSecure
in interfaceHostBinding
-
securityProtocol
-
cipherSuite
-
localAddress
-
localIdentity
-
localPrincipal
-
localCertificates
-
remoteAddress
-
remoteIdentity
-
remotePrincipal
-
remoteCertificates
-
isPrimary
public boolean isPrimary()- Specified by:
isPrimary
in interfaceHostBinding
-
setPrimary
public void setPrimary(boolean isPrimary) - Specified by:
setPrimary
in interfaceHostBinding
-
isReplica
public boolean isReplica()- Specified by:
isReplica
in interfaceHostBinding
-
setReplica
public void setReplica(boolean isReplica) - Specified by:
setReplica
in interfaceHostBinding
-
isMaster
public boolean isMaster()- Specified by:
isMaster
in interfaceHostBinding
-
isSlave
public boolean isSlave()- Specified by:
isSlave
in interfaceHostBinding
-
didBecomeMaster
public void didBecomeMaster()- Specified by:
didBecomeMaster
in interfaceHostBinding
-
didBecomeSlave
public void didBecomeSlave()- Specified by:
didBecomeSlave
in interfaceHostBinding
-
resolve
-
nodes
- Specified by:
nodes
in interfaceHostBinding
-
getNode
- Specified by:
getNode
in interfaceHostBinding
-
openNode
- Specified by:
openNode
in interfaceHostBinding
-
openNode
- Specified by:
openNode
in interfaceHostBinding
-
openUplink
- Specified by:
openUplink
in interfaceCellBinding
-
openWarpUplink
-
pushUp
- Specified by:
pushUp
in interfaceCellBinding
-
willConnect
public void willConnect()- Specified by:
willConnect
in interfaceWarpSocket
-
didConnect
public void didConnect()- Specified by:
didConnect
in interfaceWarpSocket
-
willSecure
public void willSecure()- Specified by:
willSecure
in interfaceWarpSocket
-
didSecure
public void didSecure()- Specified by:
didSecure
in interfaceWarpSocket
-
willBecome
- Specified by:
willBecome
in interfaceWarpSocket
-
didBecome
- Specified by:
didBecome
in interfaceWarpSocket
-
didUpgrade
- Specified by:
didUpgrade
in interfaceWarpSocket
-
doRead
public void doRead()- Specified by:
doRead
in interfaceWarpSocket
-
didRead
- Specified by:
didRead
in interfaceWarpSocket
-
didRead
- Specified by:
didRead
in interfaceWarpSocket
-
didReadClose
-
onEventMessage
-
onCommandMessage
-
willPushMessage
-
didPushMessage
-
reconcileReceiveBacklog
protected void reconcileReceiveBacklog() -
routeDownlink
-
didOpenDownlink
-
didCloseDownlink
-
routeUplink
-
didOpenUplink
-
didCloseUplink
-
onLinkRequest
-
onLinkedResponse
-
onSyncRequest
-
onSyncedResponse
-
onUnlinkRequest
-
onUnlinkedResponse
-
onAuthRequest
-
onAuthedResponse
-
onDeauthRequest
-
onDeauthedResponse
-
onUnknownEnvelope
-
forbid
protected void forbid() -
doWrite
public void doWrite()- Specified by:
doWrite
in interfaceWarpSocket
-
didWrite
- Specified by:
didWrite
in interfaceWarpSocket
-
didWrite
- Specified by:
didWrite
in interfaceWarpSocket
-
didTimeout
public void didTimeout()- Specified by:
didTimeout
in interfaceWarpSocket
-
didDisconnect
public void didDisconnect()- Specified by:
didDisconnect
in interfaceWarpSocket
-
willClose
protected void willClose()- Overrides:
willClose
in classAbstractTierBinding
-
didClose
public void didClose()- Specified by:
didClose
in interfaceTierBinding
- Overrides:
didClose
in classAbstractTierBinding
-
didFail
- Specified by:
didFail
in interfaceTierBinding
- Specified by:
didFail
in interfaceWarpSocket
- Overrides:
didFail
in classAbstractTierBinding
-
openMetaHost
- Specified by:
openMetaHost
in interfaceHostBinding
-
openMetaLanes
-
openReflectLanes
-
openMetaNode
- Specified by:
openMetaNode
in interfaceHostBinding
-
openMetaLane
- Specified by:
openMetaLane
in interfaceHostBinding
-
openMetaUplink
- Specified by:
openMetaUplink
in interfaceHostBinding
-
openMetaDownlink
- Specified by:
openMetaDownlink
in interfaceCellContext
-
bindDownlink
- Specified by:
bindDownlink
in interfaceCellContext
-
openDownlink
- Specified by:
openDownlink
in interfaceCellContext
-
closeDownlink
- Specified by:
closeDownlink
in interfaceCellContext
-
pushDown
- Specified by:
pushDown
in interfaceCellContext
-
reportDown
- Specified by:
reportDown
in interfaceCellContext
-
reconnect
protected void reconnect() -
closeDownlinks
protected void closeDownlinks() -
closeUplinks
protected void closeUplinks() -
connectUplinks
protected void connectUplinks() -
disconnectUplinks
protected void disconnectUplinks() -
trace
Description copied from interface:Log
Logs a trace-level message. -
debug
Description copied from interface:Log
Logs a debug-level message. -
info
Description copied from interface:Log
Logs an info-level message. -
warn
Description copied from interface:Log
Logs a warn-level message. -
error
Description copied from interface:Log
Logs an error-level message. -
fail
Description copied from interface:Log
Logs an fail-level message. -
didUpdateMetrics
protected void didUpdateMetrics() -
flushMetrics
protected void flushMetrics() -
reportMetrics
protected void reportMetrics(long dt) -
collectProfile
-