Module swim.remote

Package swim.remote

Class RemoteHost

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

public class RemoteHost
extends AbstractTierBinding
implements HostBinding, WarpSocket, StayContext

Field Summary

Fields

Modifier and Type	Field	Description
protected HostContext	hostContext
protected WarpSocketContext	warpSocketContext

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
RemoteHost(Uri baseUri)
RemoteHost(Uri requestUri, Uri baseUri)

Method Summary

Modifier and Type	Method	Description
LinkBinding	bindDownlink(Downlink downlink)
<T> T	bottomHost(Class<T> hostClass)
HostAddress	cellAddress()
String	cipherSuite()
void	closeDownlink(LinkBinding link)
protected void	closeDownlinks()
protected void	closeUplinks()
protected HostProfile	collectProfile(long dt)
protected void	connectUplinks()
void	debug(Object message)	Logs a debug-level message.
void	didBecome(IpSocket socket)
void	didBecomeMaster()
void	didBecomeSlave()
void	didClose()
protected void	didCloseDownlink(WarpBinding downlink)
protected void	didCloseUplink(WarpContext uplink)
void	didConnect()
void	didDisconnect()
void	didFail(Throwable error)
protected void	didOpenDownlink(WarpBinding downlink)
protected void	didOpenUplink(WarpContext uplink)
protected void	didPushMessage(Envelope envelope)
void	didRead(Envelope envelope)
void	didRead(WsControlFrame<?,?> frame)
protected void	didReadClose(WsCloseFrame<?,?> frame)
void	didSecure()
void	didTimeout()
protected void	didUpdateMetrics()
void	didUpgrade(HttpRequest<?> request, HttpResponse<?> response)
void	didWrite(Envelope envelope)
void	didWrite(WsControlFrame<?,?> frame)
protected void	disconnectUplinks()
void	doRead()
void	doWrite()
String	edgeName()
void	error(Object message)	Logs an error-level message.
void	fail(Object message)	Logs an fail-level message.
protected void	flushMetrics()
protected void	forbid()
NodeBinding	getNode(Uri nodeUri)
HostContext	hostContext()
Uri	hostUri()
HostBinding	hostWrapper()
long	idleTimeout()
void	info(Object message)	Logs an info-level message.
boolean	isConnected()
boolean	isMaster()
boolean	isPrimary()
boolean	isRemote()
boolean	isReplica()
boolean	isSecure()
boolean	isSlave()
InetSocketAddress	localAddress()
Collection<Certificate>	localCertificates()
Identity	localIdentity()
Principal	localPrincipal()
Uri	meshUri()
UriMapper<NodeBinding>	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)
NodeBinding	openNode(Uri nodeUri)
NodeBinding	openNode(Uri nodeUri, NodeBinding node)
protected void	openReflectLanes(HostBinding host, AgentNode metaHost)
void	openUplink(LinkBinding link)
protected void	openWarpUplink(WarpBinding link)
PartBinding	part()
Value	partKey()
Policy	policy()
void	pushDown(Push<?> push)
void	pushUp(Push<?> push)
protected void	reconcileReceiveBacklog()
protected void	reconnect()
InetSocketAddress	remoteAddress()
Collection<Certificate>	remoteCertificates()
Identity	remoteIdentity()
Principal	remotePrincipal()
void	reportDown(Metric metric)
protected void	reportMetrics(long dt)
protected Uri	resolve(Uri relativeUri)
protected void	routeDownlink(LinkAddressed envelope)
protected void	routeUplink(LaneAddressed envelope)
Schedule	schedule()
String	securityProtocol()
void	setHostContext(HostContext hostContext)
void	setPrimary(boolean isPrimary)
void	setReplica(boolean isReplica)
void	setWarpSocketContext(WarpSocketContext warpSocketContext)
Stage	stage()
StoreBinding	store()
TierContext	tierContext()
void	trace(Object message)	Logs a trace-level message.
<T> T	unwrapHost(Class<T> hostClass)
void	warn(Object message)	Logs a warn-level message.
WarpSocketContext	warpSocketContext()
void	willBecome(IpSocket socket)
protected void	willClose()
void	willConnect()
protected void	willPushMessage(Envelope envelope)
void	willSecure()

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface swim.system.TierBinding

close, isClosed, isLoaded, isOpened, isStarted, load, open, start, stop, unload

Field Detail

hostContext

protected HostContext hostContext

warpSocketContext

protected WarpSocketContext warpSocketContext

Constructor Detail

RemoteHost

public RemoteHost(Uri requestUri,
                  Uri baseUri)

RemoteHost

public RemoteHost(Uri baseUri)

Method Detail

tierContext

public final TierContext tierContext()

Specified by:

tierContext in interface TierBinding

Specified by:

tierContext in class AbstractTierBinding

part

public final PartBinding part()

Specified by:

part in interface HostBinding

hostWrapper

public final HostBinding hostWrapper()

Specified by:

hostWrapper in interface HostBinding

unwrapHost

public <T> T unwrapHost(Class<T> hostClass)

Specified by:

unwrapHost in interface HostBinding

bottomHost

public <T> T bottomHost(Class<T> hostClass)

Specified by:

bottomHost in interface HostBinding

hostContext

public final HostContext hostContext()

Specified by:

hostContext in interface HostBinding

setHostContext

public void setHostContext(HostContext hostContext)

Specified by:

setHostContext in interface HostBinding

warpSocketContext

public WarpSocketContext warpSocketContext()

Specified by:

warpSocketContext in interface WarpSocket

setWarpSocketContext

public void setWarpSocketContext(WarpSocketContext warpSocketContext)

Specified by:

setWarpSocketContext in interface WarpSocket

idleTimeout

public long idleTimeout()

Specified by:

idleTimeout in interface WarpSocket

cellAddress

public HostAddress cellAddress()

Specified by:

cellAddress in interface CellContext

Specified by:

cellAddress in interface HostBinding

edgeName

public String edgeName()

Specified by:

edgeName in interface CellContext

meshUri

public Uri meshUri()

Specified by:

meshUri in interface CellContext

Specified by:

meshUri in interface HostBinding

partKey

public Value partKey()

Specified by:

partKey in interface HostBinding

hostUri

public Uri hostUri()

Specified by:

hostUri in interface HostBinding

policy

public Policy policy()

Specified by:

policy in interface CellContext

schedule

public Schedule schedule()

Specified by:

schedule in interface CellContext

stage

public Stage stage()

Specified by:

stage in interface CellContext

store

public StoreBinding store()

Specified by:

store in interface CellContext

isConnected

public boolean isConnected()

Specified by:

isConnected in interface HostBinding

isRemote

public boolean isRemote()

Specified by:

isRemote in interface HostBinding

isSecure

public boolean isSecure()

Specified by:

isSecure in interface HostBinding

securityProtocol

public String securityProtocol()

cipherSuite

public String cipherSuite()

localAddress

public InetSocketAddress localAddress()

localIdentity

public Identity localIdentity()

localPrincipal

public Principal localPrincipal()

localCertificates

public Collection<Certificate> localCertificates()

remoteAddress

public InetSocketAddress remoteAddress()

remoteIdentity

public Identity remoteIdentity()

remotePrincipal

public Principal remotePrincipal()

remoteCertificates

public Collection<Certificate> remoteCertificates()

isPrimary

public boolean isPrimary()

Specified by:

isPrimary in interface HostBinding

setPrimary

public void setPrimary(boolean isPrimary)

Specified by:

setPrimary in interface HostBinding

isReplica

public boolean isReplica()

Specified by:

isReplica in interface HostBinding

setReplica

public void setReplica(boolean isReplica)

Specified by:

setReplica in interface HostBinding

isMaster

public boolean isMaster()

Specified by:

isMaster in interface HostBinding

isSlave

public boolean isSlave()

Specified by:

isSlave in interface HostBinding

didBecomeMaster

public void didBecomeMaster()

Specified by:

didBecomeMaster in interface HostBinding

didBecomeSlave

public void didBecomeSlave()

Specified by:

didBecomeSlave in interface HostBinding

resolve

protected Uri resolve(Uri relativeUri)

nodes

public UriMapper<NodeBinding> nodes()

Specified by:

nodes in interface HostBinding

getNode

public NodeBinding getNode(Uri nodeUri)

Specified by:

getNode in interface HostBinding

openNode

public NodeBinding openNode(Uri nodeUri)

Specified by:

openNode in interface HostBinding

openNode

public NodeBinding openNode(Uri nodeUri,
                            NodeBinding node)

Specified by:

openNode in interface HostBinding

openUplink

public void openUplink(LinkBinding link)

Specified by:

openUplink in interface CellBinding

openWarpUplink

protected void openWarpUplink(WarpBinding link)

pushUp

public void pushUp(Push<?> push)

Specified by:

pushUp in interface CellBinding

willConnect

public void willConnect()

Specified by:

willConnect in interface WarpSocket

didConnect

public void didConnect()

Specified by:

didConnect in interface WarpSocket

willSecure

public void willSecure()

Specified by:

willSecure in interface WarpSocket

didSecure

public void didSecure()

Specified by:

didSecure in interface WarpSocket

willBecome

public void willBecome(IpSocket socket)

Specified by:

willBecome in interface WarpSocket

didBecome

public void didBecome(IpSocket socket)

Specified by:

didBecome in interface WarpSocket

didUpgrade

public void didUpgrade(HttpRequest<?> request,
                       HttpResponse<?> response)

Specified by:

didUpgrade in interface WarpSocket

doRead

public void doRead()

Specified by:

doRead in interface WarpSocket

didRead

public void didRead(Envelope envelope)

Specified by:

didRead in interface WarpSocket

didRead

public void didRead(WsControlFrame<?,?> frame)

Specified by:

didRead in interface WarpSocket

didReadClose

protected void didReadClose(WsCloseFrame<?,?> frame)

onEventMessage

protected void onEventMessage(EventMessage message)

onCommandMessage

protected void onCommandMessage(CommandMessage message)

willPushMessage

protected void willPushMessage(Envelope envelope)

didPushMessage

protected void didPushMessage(Envelope envelope)

reconcileReceiveBacklog

protected void reconcileReceiveBacklog()

routeDownlink

protected void routeDownlink(LinkAddressed envelope)

didOpenDownlink

protected void didOpenDownlink(WarpBinding downlink)

didCloseDownlink

protected void didCloseDownlink(WarpBinding downlink)

routeUplink

protected void routeUplink(LaneAddressed envelope)

didOpenUplink

protected void didOpenUplink(WarpContext uplink)

didCloseUplink

protected void didCloseUplink(WarpContext uplink)

onLinkRequest

protected void onLinkRequest(LinkRequest request)

onLinkedResponse

protected void onLinkedResponse(LinkedResponse response)

onSyncRequest

protected void onSyncRequest(SyncRequest request)

onSyncedResponse

protected void onSyncedResponse(SyncedResponse response)

onUnlinkRequest

protected void onUnlinkRequest(UnlinkRequest request)

onUnlinkedResponse

protected void onUnlinkedResponse(UnlinkedResponse response)

onAuthRequest

protected void onAuthRequest(AuthRequest request)

onAuthedResponse

protected void onAuthedResponse(AuthedResponse response)

onDeauthRequest

protected void onDeauthRequest(DeauthRequest request)

onDeauthedResponse

protected void onDeauthedResponse(DeauthedResponse response)

onUnknownEnvelope

protected void onUnknownEnvelope(Envelope envelope)

forbid

protected void forbid()

doWrite

public void doWrite()

Specified by:

doWrite in interface WarpSocket

didWrite

public void didWrite(Envelope envelope)

Specified by:

didWrite in interface WarpSocket

didWrite

public void didWrite(WsControlFrame<?,?> frame)

Specified by:

didWrite in interface WarpSocket

didTimeout

public void didTimeout()

Specified by:

didTimeout in interface WarpSocket

didDisconnect

public void didDisconnect()

Specified by:

didDisconnect in interface WarpSocket

willClose

protected void willClose()

Overrides:

willClose in class AbstractTierBinding

didClose

public void didClose()

Specified by:

didClose in interface TierBinding

Overrides:

didClose in class AbstractTierBinding

didFail

public void didFail(Throwable error)

Specified by:

didFail in interface TierBinding

Specified by:

didFail in interface WarpSocket

Overrides:

didFail in class AbstractTierBinding

openMetaHost

public void openMetaHost(HostBinding host,
                         NodeBinding metaHost)

Specified by:

openMetaHost in interface HostBinding

openMetaLanes

protected void openMetaLanes(HostBinding host,
                             AgentNode metaHost)

openReflectLanes

protected void openReflectLanes(HostBinding host,
                                AgentNode metaHost)

openMetaNode

public void openMetaNode(NodeBinding node,
                         NodeBinding metaNode)

Specified by:

openMetaNode in interface HostBinding

openMetaLane

public void openMetaLane(LaneBinding lane,
                         NodeBinding metaLane)

Specified by:

openMetaLane in interface HostBinding

openMetaUplink

public void openMetaUplink(LinkBinding uplink,
                           NodeBinding metaUplink)

Specified by:

openMetaUplink in interface HostBinding

openMetaDownlink

public void openMetaDownlink(LinkBinding downlink,
                             NodeBinding metaDownlink)

Specified by:

openMetaDownlink in interface CellContext

bindDownlink

public LinkBinding bindDownlink(Downlink downlink)

Specified by:

bindDownlink in interface CellContext

openDownlink

public void openDownlink(LinkBinding link)

Specified by:

openDownlink in interface CellContext

closeDownlink

public void closeDownlink(LinkBinding link)

Specified by:

closeDownlink in interface CellContext

pushDown

public void pushDown(Push<?> push)

Specified by:

pushDown in interface CellContext

reportDown

public void reportDown(Metric metric)

Specified by:

reportDown in interface CellContext

reconnect

protected void reconnect()

closeDownlinks

protected void closeDownlinks()

closeUplinks

protected void closeUplinks()

connectUplinks

protected void connectUplinks()

disconnectUplinks

protected void disconnectUplinks()

trace

public void trace(Object message)

Description copied from interface: Log

Logs a trace-level message.

Specified by:

trace in interface Log

debug

public void debug(Object message)

Description copied from interface: Log

Logs a debug-level message.

Specified by:

debug in interface Log

info

public void info(Object message)

Description copied from interface: Log

Logs an info-level message.

Specified by:

info in interface Log

warn

public void warn(Object message)

Description copied from interface: Log

Logs a warn-level message.

Specified by:

warn in interface Log

error

public void error(Object message)

Description copied from interface: Log

Logs an error-level message.

Specified by:

error in interface Log

fail

public void fail(Object message)

Description copied from interface: Log

Logs an fail-level message.

Specified by:

fail in interface Log

didUpdateMetrics

protected void didUpdateMetrics()

flushMetrics

protected void flushMetrics()

reportMetrics

protected void reportMetrics(long dt)

collectProfile

protected HostProfile collectProfile(long dt)