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

对应《GRPC-C++源码分析（三）--main线程》中1.6节

这一节可能才是最核心的部分，包括大家理解的怎样注册listen和accept描述符，怎样处理读写事件，怎样处理业务逻辑等等。

由于这部分涉及的方面太多了，笔者也只是梳理出了核心的部分供参考，欢迎有精力的小伙伴继续补充。

server->Start(cqs_data, cqs_.size());

在Server::Start的实现中，主要分两部分

//第一部分
grpc_server_start(server_);

• 建立epoll，listen描述符注册

  //第二部分
  for (auto it = sync_req_mgrs_.begin(); it != sync_req_mgrs_.end(); it++) {
    (*it)->Start();
  }

• accept描述符注册，读写事件响应，处理注册的service业务逻辑

下面对这两部分分别进行解释

1 grpc_server_start

在grpc_server_start函数中也分两部分说明：

//第一部分
  for (i = 0; i < server->cq_count; i++) {
    if (grpc_cq_can_listen(server->cqs[i])) {
      server->pollsets[server->pollset_count++] =
          grpc_cq_pollset(server->cqs[i]);
    }
  }

• 重点理解server->pollsets[server->pollset_count++]=grpc_cq_pollset(server->cqs[i]);看下图

• 一句话，把cqs中的grpc_pollset指针放到grpc_server的指针数组pollsets中

//第二部分
  GRPC_CLOSURE_SCHED(
      GRPC_CLOSURE_CREATE(
          start_listeners, server,
          grpc_core::Executor::Scheduler(grpc_core::ExecutorJobType::SHORT)),
      GRPC_ERROR_NONE);

• 这块代码对应了《GRPC-C++源码分析（二）--线程模型》中将start_listeners放入default-excutor线程中执行
• 跟踪下grpc_core::Executor::Scheduler可以清晰看到最终调用的是grpc_closure_list_append方法

• 《GRPC-C++源码分析（十一）--bind&listen》中的server_start_listener在这里被调用了
• 下面继续看server_start_listener方法