Package | Description |
---|---|
org.opendaylight.usc.manager | |
org.opendaylight.usc.manager.cluster | |
org.opendaylight.usc.manager.cluster.message | |
org.opendaylight.usc.plugin |
Modifier and Type | Method and Description |
---|---|
void |
UscRouteBrokerService.addLocalSession(UscRouteIdentifier localRouteId,
io.netty.channel.local.LocalChannel serverChannel)
add local session for processing the response which getting from remote
controller
|
int |
UscRouteBrokerService.createNewLocalSessionId(UscRouteIdentifier remoteRouteId)
create a new lcoal session id for remote caller
|
akka.actor.ActorRef |
UscRouteBrokerService.getRemoteActorForRequest(UscRouteIdentifier localRouteId)
get actor which has the remote channel of local route identifier
|
akka.actor.ActorRef |
UscRouteBrokerService.getRemoteActorForResponse(UscRouteIdentifier localRouteId)
get actor which sending request to local channel, and will call back to
it
|
io.netty.channel.local.LocalChannel |
UscRouteBrokerService.getRequestSource(UscRouteIdentifier localRouteId)
get the server channel for sending request to remote using the particular
route identifier
|
boolean |
UscRouteBrokerService.isLocalRemoteSession(UscRouteIdentifier routeId)
check if the route identifier is local session using remote channel for
intercepting the request from local channel
|
boolean |
UscRouteBrokerService.isRemoteSession(UscRouteIdentifier routeId)
check if the route identifier is the remote session using local channel
for intercepting the response from agent channel
|
void |
UscRouteBrokerService.removeLocalSession(UscRouteIdentifier localRouteId)
remove local session for processing the response which getting from
remote controller
|
void |
UscRouteBrokerService.sendException(UscRouteIdentifier localRouteId,
UscException exception)
send local USC channel exception response to remote session
|
void |
UscRouteBrokerService.sendResponse(UscRouteIdentifier localRouteId,
byte[] payload)
send local USC channel response to remote session
|
Modifier and Type | Method and Description |
---|---|
UscRouteIdentifier |
UscRouteIdentifierData.getLocalRouteIdentifier()
get local route identifier
|
UscRouteIdentifier |
UscRoutedRemoteSessionManager.getLocalRouteIdentifier(UscRouteIdentifier remoteRouteId)
get local route identifier from remote route identifier
|
UscRouteIdentifier |
UscRouteIdentifierData.getRemoteRouteIdentifier()
get remote route identifier
|
UscRouteIdentifier |
UscRoutedRemoteSessionManager.getRemoteRouteIdentifier(UscRouteIdentifier localRouteId)
get remote route identifier by the local route identifier
|
Modifier and Type | Method and Description |
---|---|
void |
UscRoutedLocalSessionManager.addEntry(UscRouteIdentifier localRouteId,
io.netty.channel.local.LocalChannel serverChannel)
add a entry of local route identifier and server local channel for
sending response to request caller like Netconf plug-in
|
akka.actor.ActorRef |
UscRoutedRemoteSessionManager.getActorRef(UscRouteIdentifier localRouteId)
get call back actor by local route identifier
|
io.netty.channel.Channel |
UscRoutedRemoteSessionManager.getAgentChannel(UscRouteIdentifier localRouteId)
get agent channel by the local route identifier for sending request to
agent channel
|
UscRouteIdentifier |
UscRoutedRemoteSessionManager.getLocalRouteIdentifier(UscRouteIdentifier remoteRouteId)
get local route identifier from remote route identifier
|
UscRouteIdentifier |
UscRoutedRemoteSessionManager.getRemoteRouteIdentifier(UscRouteIdentifier localRouteId)
get remote route identifier by the local route identifier
|
io.netty.channel.local.LocalChannel |
UscRoutedLocalSessionManager.getServerChannel(UscRouteIdentifier localRouteId)
get the server channel of particular local route identifier
|
boolean |
UscRouteIdentifier.hasSameDevice(UscRouteIdentifier other)
check if the route identifier using same device
|
boolean |
UscRoutedLocalSessionManager.isRemoteMessage(UscRouteIdentifier localRouteId)
check if it is a route identifier of remote communication
|
boolean |
UscRoutedRemoteSessionManager.isRemoteSession(UscRouteIdentifier localRouteId)
check if this message is the response message for any remote request
|
void |
UscRoutedLocalSessionManager.removeEntry(UscRouteIdentifier localRouteId)
remove a entry of local route identifier for the session closed
|
Constructor and Description |
---|
UscRouteIdentifierData(akka.actor.ActorRef actorRef,
UscRouteIdentifier remoteRouteIdentifier,
int localSessionId,
io.netty.channel.Channel agentChannel)
contructor by actor of remote caller, remote route identifier, local
session identifier and local agent channel
|
Modifier and Type | Field and Description |
---|---|
protected UscRouteIdentifier |
UscRemoteMessage.routeIdentifier |
Modifier and Type | Method and Description |
---|---|
UscRouteIdentifier |
UscRemoteMessage.getRouteIdentifier() |
Constructor and Description |
---|
UscRemoteDataMessage(UscRouteIdentifier routeId,
byte[] payload,
boolean request) |
UscRemoteExceptionMessage(UscRouteIdentifier routeIdentifier,
UscException exception) |
UscRemoteMessage(UscRouteIdentifier routeIdentifier) |
Modifier and Type | Field and Description |
---|---|
static io.netty.util.AttributeKey<UscRouteIdentifier> |
UscPlugin.ROUTE_IDENTIFIER
Constant used for setting the UscDevice attribute on a server channel
|
Copyright © 2019 OpenDaylight. All rights reserved.