开发者社区

文档建议反馈控制台

文章/答案/技术大牛

发布

GRPC-C++源码分析9-16

共 8 篇文章

1

GRPC-C++源码分析（九）--Server

2

GRPC-C++源码分析（十）--Register

3

GRPC-C++源码分析（十一）--bind&listen

4

GRPC-C++源码分析（十二）--Start

5

GRPC-C++源码分析（十三）--Start续

6

GRPC-C++源码分析（十四）--Start续

7

GRPC-C++源码分析（十五）--Start续

8

GRPC-C++源码分析（十六）--Start续

清单首页GRPC-C++源码分析9-16文章详情

清单「GRPC-C++源码分析9-16」 01/08

GRPC-C++源码分析（九）--Server

对应《GRPC-C++源码分析（三）--main线程》中的1.2节创建Server

  std::unique_ptr<Server> server(new Server(
      max_receive_message_size_, &args, sync_server_cqs,
      sync_server_settings_.min_pollers, sync_server_settings_.max_pollers,
      sync_server_settings_.cq_timeout_msec, resource_quota_,
      std::move(interceptor_creators_)));

sync_server_cqs作为参数传到了Server构造函数中，赋给了sync_server_cqs_

在Server的构造函数中填充了sync_req_mgrs_

    for (const auto& it : *sync_server_cqs_) {
      sync_req_mgrs_.emplace_back(new SyncRequestThreadManager(
          this, it.get(), global_callbacks_, server_rq, min_pollers,
          max_pollers, sync_cq_timeout_msec));
    }

注意sync_server_cqs_作为参数传到了SyncRequestThreadManager构造函数中，赋给了server_cq_，这个server_cq_会在后面用到

在Server的构造函数中生成了grpc_server* server_;

server_ = grpc_server_create(&channel_args, nullptr);

这里的server_会在稍后的grpc_server_register_completion_queue方法中用到

举报