GRPC-C++源码分析（四）--ServerCompletionQueue

原创

路小饭

修改于 2019-04-23 11:17:15

3.8K10

代码可运行

文章被收录于专栏：C++开源框架源码分析C++开源框架源码分析

运行总次数：0

代码可运行

对应《GRPC-C++源码分析（三）--main线程》中的1.1节初始化ServerCompletionQueue

1 overview

先来看下ServerCompletionQueue的整体结构

ServerCompletionQueue的核心在于创建了grpc_completion_queue* cq_，见其父类CompletionQueue的构造函数

  CompletionQueue(const grpc_completion_queue_attributes& attributes) {
    cq_ = g_core_codegen_interface->grpc_completion_queue_create(
        g_core_codegen_interface->grpc_completion_queue_factory_lookup(
            &attributes),
        &attributes, NULL);
    InitialAvalanching();  // reserve this for the future shutdown
  }

而CompletionQueue则继承了GrpcLibraryCodegen。了解ServerCompletionQueue类需要我们从顶级父类一层层分析

2 GrpcLibraryCodegen

class GrpcLibraryCodegen {
 public:
  GrpcLibraryCodegen(bool call_grpc_init = true) : grpc_init_called_(false) {
    if (call_grpc_init) {
      GPR_CODEGEN_ASSERT(g_glip &&
                         "gRPC library not initialized. See "
                         "grpc::internal::GrpcLibraryInitializer.");
      g_glip->init();
      grpc_init_called_ = true;
    }
  }

GrpcLibraryCodegen极为简单，仅仅调用了g_glip->init();所以重点在g_glip上，让我们看看它的来源

g_glip在GrpcLibraryInitializer类的构造函数中被初始化。
grpc声明了一个全局的静态变量static internal::GrpcLibraryInitializer g_gli_initializer;以确保在main函数之前就完成了g_glip的初始化

class GrpcLibraryInitializer final {
 public:
  GrpcLibraryInitializer() {
    if (grpc::g_glip == nullptr) {
      static auto* const g_gli = new GrpcLibrary();
      grpc::g_glip = g_gli;
    }
    if (grpc::g_core_codegen_interface == nullptr) {
      static auto* const g_core_codegen = new CoreCodegen();
      grpc::g_core_codegen_interface = g_core_codegen;
    }
  }

在代码中可以看到，除了g_glip 外，还有grpc::g_core_codegen_interface也初始化了。这个变量会被用在CompletionQueue的构造函数中，后面会说到
从图中可以看到g_glip->init方法实际调用的是GrpcLibrary中的init方法

class GrpcLibrary final : public GrpcLibraryInterface {
 public:
  void init() override { grpc_init(); }
  void shutdown() override { grpc_shutdown(); }
};

重点转移到了grpc_init()方法中

2.1 grpc_init（init.cc）

顾名思义，grpc_init代表的是初始化grpc核心参数，所以在此方法中，可以看到n多*_init()方法，目前先把注意力放在grpc_iomgr_init();

在grpc_iomgr_init中，开始涉及到grpc/src/core部分的代码，这是c风格的库。
这里决定了后续使用的是哪个系统平台的reactor模型，epoll还是poll，或者其他
还记得线程模型中的default-executor和resolver-executor么，它们是由grpc_core::Executor::InitAll方法启动的
grpc_iomgr_platform_init的最终作用是赋值给全局变量：static const grpc_event_engine_vtable* g_event_engine = nullptr;后面的分析会看到

2.1.1 grpc_core::Executor::InitAll

//executor.cc
void Executor::InitAll() {
  EXECUTOR_TRACE0("Executor::InitAll() enter");

  // Return if Executor::InitAll() is already called earlier
  if (executors[static_cast<size_t>(ExecutorType::DEFAULT)] != nullptr) {
    GPR_ASSERT(executors[static_cast<size_t>(ExecutorType::RESOLVER)] !=
               nullptr);
    return;
  }

  executors[static_cast<size_t>(ExecutorType::DEFAULT)] =
      grpc_core::New<Executor>("default-executor");
  executors[static_cast<size_t>(ExecutorType::RESOLVER)] =
      grpc_core::New<Executor>("resolver-executor");

  executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init();
  executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Init();

  EXECUTOR_TRACE0("Executor::InitAll() done");
}