grpc c++源码阅读(11)----server数据流的处理

我们使用官方route_guide的例子进行讲解，为了使server端能够持续的收到数据，我们简单地对客户端代码进行了改造，让其不停的发送数据。

const int kPoints = 1000000000;

std::thread t1(&RouteGuideClient::RecordRoute, &guide);
t1.join();

调用RecordRoute方法，然后发送kPoints个数据。这时server端的线程有6个。

作用分别如下:

2个”grpcpp_sync_ser线程”,一个用于epoll循环，一个处理rpc方法调用。回想一下这篇文章中讲的线程模型吧<<GRPC C++源码阅读同步SERVER线程模型>>
2个”grpcpp_sync_ser线程”,一个用于epoll循环，一个处理rpc方法调用。回想一下这篇文章中讲的线程模型吧<<GRPC C++源码阅读同步SERVER线程模型>>
2个”grpc_global_tim”线程，用于处理定时任务。如握手超时的处理。
一个主线程，等待server结束
一个”global-executor”调度器线程，用于调度一些阻塞或异步任务。回想一下这篇文章中讲的executor.<<6.GRPC C++源码阅读–常见的类>>
一个”global-executor”调度器线程，用于调度一些阻塞或异步任务。回想一下这篇文章中讲的executor.<<6.GRPC C++源码阅读–常见的类>>

数据解包的核心流程是grpc_chttp2_perform_read函数，里面会逐字节的拆分chttp2数据包，按照http2的帧格式一帧一帧的解析。解析具体一帧的函数为parse_frame_slice.parse_frame_slice里面会根据状态机调用当前合适的parser.比如收到“window_udpate”帧会调用“grpc_chttp2_window_update_parser_parse”;收到”ping”帧会调用”grpc_chttp2_ping_parser_parse”;数据帧对应的解析函数为”grpc_chttp2_data_parser_parse”.

这个函数会将当前的数据帧存放到对应的流上，并检查是否已经有一个完整的消息了。

grpc_slice_buffer_add(&s->frame_storage, slice);
grpc_chttp2_maybe_complete_recv_message(t, s);

grpc_deframe_unprocessed_incoming_frames

在解析到一个完整的消息后，会依次调用以下处理函数：

recv_message_ready—->receiving_stream_ready—>process_data_after_md—->continue_receiving_slices—->finish_batch_step—->post_batch_completion—>cq_end_op_for_pluck

最后调用cq_end_op_for_pluck向无锁队列中加入完成事件，即要调用的rpc方法。

这里留几个个疑问，无锁队列是什么鬼？怎么实现无锁的？加入完成事件后如何通知工作线程去调用？下节继续讲解。