sofa-pbrpc-server
2018-01-17 21:25:53   0  举报             
     
         
 sofa-pbrpc数据收发流程
    作者其他创作
 大纲/内容
 io+work线程组
    RpcServerMessageStream::async_send_message
  TimerWorker::start
  try_start_receive
  RpcServerImpl::OnReceived
  split_and_process_message
  RpcListener::async_accept
  on_read_some
  RpcServer::Start
  RpcRequest::OnCallMethodDone
  BinaryRpcRequest
  RpcByteStream
  RpcServerImpl::Start
  BinaryRpcRequest::ProcessRequest
  put_into_pending_queue
  RpcListener::start_listen
  set_received_request_callback
  RpcListener
  set_socket_connected
  以binary为例
  set_accept_callback
  on_write_some
  on_connected
  on_received
  创建Clusure
  RpcRequest::SendSucceedResponse
  async_write_some
  _io_service_pool-Run
  RpcListener::on_accept
  RpcServerImpl::OnCreated
  RpcServerImpl
  RpcRequest
  FindMethodBoard
  ParseMethodFullName
  RpcServerMessageStream
  RpcServerStream::send_response
  maintain_thread
  RpcServerStream
  async_accept
  async_read_some
  RpcServerImpl::OnAccepted
  trigger_receive
  trigger_send
  调用服务的CallMethod
  RpcRequest::CallMethod
  _maintain_thread_group
  try_start_send
  set_create_callback
  设置done-run方法
   
 
 
 
 
  0 条评论
 下一页
  
   
   
   
   
  
  
  
  
  
  
  
  
 