1 server
對應《GRPC-C++源碼分析(二)--main函數主要流程》中的
<code> 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_)));/<server>/<code>sync_server_cqs作為參數傳到了Server構造函數中,賦給了sync_server_cqs_
在Server的構造函數中填充了sync_req_mgrs_
<code> 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));
}/<code>注意sync_server_cqs_作為參數傳到了SyncRequestThreadManager構造函數中,賦給了server_cq_,這個server_cq_會在後面用到
在Server的構造函數中生成了grpc_server* server_;
<code>server_ = grpc_server_create(&channel_args, nullptr);/<code>這裡的server_會在稍後的grpc_server_register_completion_queue方法中用到
2 Register
對應於《GRPC-C++源碼分析(三)--main函數主要流程》中1.3節和1.4節
2.1 grpc_server_register_completion_queue
<code> for (auto it = sync_server_cqs->begin(); it != sync_server_cqs->end(); ++it) {
grpc_server_register_completion_queue(server->server_, (*it)->cq(),
nullptr);
has_frequently_polled_cqs = true;
}/<code>
2.2 RegisterService
<code> for (auto service = services_.begin(); service != services_.end();
service++) {
if (!server->RegisterService((*service)->host.get(), (*service)->service)) {
return nullptr;
}
}/<code>註冊service得從/grpc/examples/cpp/helloworld/greeter_server.cc說起