Class Diagram
2016-12-20 14:29:08 0 举报
登录查看完整内容
GRPC Agent
作者其他创作
大纲/内容
GRPCPort
grpc_agent_messaging_port = 12222grpc_agent_messaging_notification = 12223grpc_agent_messaging_port = 12224grpc_agent_config_notification_port= 1222
grpc-agent-messaging
GRPCAgentConfigTask
GRPCMessageHandler
process() 将受到的message解析,调用grpc发送给XRv
message
IPCMessagingClientImpl
send()sendNIO()sendProtocol() -send(Header & sendBody)
common
MessageOperationType
IPCMessagingServerImpl
start()registerMessageHandler()startNIO()startProtocol()stop()
grpc-agent
以delegate interface为例子,会调用put方法,然后再调用IPCMessageClient的sendProtocl方法,在这个方法里面,会发送header和数据包
use mvn to compile .proto files
agent.internal
itgrpc
GrpcServer
start()GRPCAgentServerTaskGRPCAgentConfigTaskGRPCInterfaceSubscribeCallbackImpl()
GRPCAgentImpl
addGrpcServer()getGrpcServerRuntimeByDeciceId()getGRPCClientByDeviceId()invokeGRPCRuntimeServiceRegistry
Delgation
delegatePresentingInterfaceCallisto
InterfaceSubscribeRspMessage
MessageClient
send()sendNIO()sendProtocol()
SunstonGRPCAPIs
SunstoneGRPCFunctions()everyrpcfunctionGrpcClientInterceptor()MfFibSubscribeInput() ???EmsServiceOps()
grpc(define .proto files)
MessagingConfiguration
DALDeviceOperationsGRPCProvider
put()
RegisterMpls
InitNode
InterfaceNotificationInputMessage
start() -- 启动server监听socket
当一个gRPC连接开始的时候,客户端先上传自己的metadata(相当于request包头),然后服务器可以选择马上返回自己的metadata(相当于reponse包头),或者等待客户端上传完包体再返回
CreateMPLSLabelMessage
GRPCClient
server
MessageServer
microfib
MessageAddDevice
model(yang)
GRPCAgentServerTask
InterfaceSubscribeOpMessage
MessageHandler
process()
MessageHeader
setClassName()getClassName()
enumerator
API
init
dirvers
provider(RPC)
EMScommandMessage
impl
收藏
0 条评论
回复 删除
下一页