GRPC-C++源码分析(七)--bind&listen

对应于《GRPC-C++源码分析(三)--main函数主要流程》中1.5节

<code>  for (auto port = ports_.begin(); port != ports_.end(); port++) {
int r = server->AddListeningPort(port->addr, port->creds.get());
if (!r) {
if (added_port) server->Shutdown();
return nullptr;
}
added_port = true;
if (port->selected_port != nullptr) {
*port->selected_port = r;
}
}/<code>


GRPC-C++源码分析(七)--bind&listen


可以右键鼠标--在新标签页中打开图片,会更清晰一些

  • 大家最关心的bind和listen操作在蓝色框中
  • 本节的重点在server_start_listener方法上

下面大概说下上图的流程:

  • 通过跟踪,Server的AddListeningPort方法最终调用的是grpc_chttp2_server_add_port方法
  • 在grpc_chttp2_server_add_port方法中,grpc_tcp_server_create创建了grpc_tcp_server变量。
<code>//tcp_server.cc
grpc_error* grpc_tcp_server_create(grpc_closure* shutdown_complete,
const grpc_channel_args* args,
grpc_tcp_server** server) {
return grpc_tcp_server_impl->create(shutdown_complete, args, server);
}
//又遇到了熟悉grpc_tcp_server_impl类型,如果还不熟悉的同学,可以参考图中上方区域,说明了grpc_tcp_server_impl的来源/<code>
  • grpc_tcp_server_add_port方法中创建了socket,并执行了bind和listen操作,将listen描述符封装在了grpc_tcp_listener结构中,并最终赋给了grpc_tcp_server
  • grpc_server_add_listener方法将server_start_listener方法放在了grpc_server中,这块会在后面用到

这块的代码没有理解上的难点,基本上按照上图所示就能跟下来


分享到:


相關文章: