Unary模式下客戶端創建 default-executor 和 resolver-executor 線程和從啟動到執行grpc_connector_connect的主要流程

来源:https://www.cnblogs.com/yuyuguang/archive/2019/10/29/11756500.html
-Advertisement-
Play Games

(原創)C/C++語言， 平臺是debian10, grpc版本：grpc c++/1.25.0 dev, 使用的例子是自帶的例子GreeterClient 創建 default executor 和 resolver executor 線程的主要流程，創建channel時會創建這2個線程 grpc ...


(原創)C/C語言， 平臺是debian10, grpc版本：grpc-c/1.25.0-dev grpc-c/8.0.0, 使用的例子是自帶的例子GreeterClient

創建 default-executor 和 resolver-executor 線程的主要流程，創建channel時會創建這2個線程

graph TD; 000(grpc::InsecureChannelCredentials #credentials.h:91 調用InsecureChannelCredentials)-->001(grpc_impl::InsecureChannelCredentials #insecure_credentials.cc:59 創建一個共用的InsecureChannelCredentialsImpl對象) 001-->002(grpc_impl::InsecureChannelCredentialsImpl::InsecureChannelCredentialsImpl #insecure_credentials.cc:30 調用父類ChannelCredentials構造函數) 002-->003(grpc_impl::ChannelCredentials::ChannelCredentials #credentials_cc.cc:25 調用父類GrpcLibraryCodegen構造函數) 003-->004(grpc::GrpcLibraryCodegen::GrpcLibraryCodegen #grpc_library.h:45 調用GrpcLibraryInterface的init) 004-->005(grpc::internal::GrpcLibrary::init #grpc_library.h:34 調用grpc_init) 005-->006(grpc_init #init.cc:146 調用grpc_iomgr_init) 006-->007(grpc_iomgr_init #iomgr.cc:60 調用grpc_core::Executor::InitAll) 007-->008(創建 default-executor 和 resolver-executor 線程) 008-->009(grpc_iomgr_start #iomgr.cc:69 調用grpc_timer_manager_init) 009-->010(grpc_timer_manager_init #timer_manager.cc:311 調用start_threads) 010-->011(start_threads #timer_manager.cc:293 調用start_timer_thread_and_unlock) 011-->012(start_timer_thread_and_unlock #timer_manager.cc:91 啟動grpc_global_timer線程)

grpc Unary模式下客戶端啟動到執行grpc_connector_connect的主要流程

graph TD; 000(grpc::internal::BlockingUnaryCall #client_unary_call.h:43)-->001(grpc::internal::BlockingUnaryCallImpl::BlockingUnaryCallImpl #client_unary_call.h:71 創建CompletionQueue, Call, CallOpSet對象, 設置CallOpSet對象參數, 調用PerformOps) 001-->002(grpc::internal::Call::PerformOps #call.h:69 調用PerformOpsOnCall) 002-->003(grpc_impl::Channel::PerformOpsOnCall #channel_cc.cc:164 調用FillOps) 003-->004(grpc::internal::CallOpSet::FillOps #call_op_set.h:874 調用ContinueFillOpsAfterInterception) 004-->005(grpc::internal::CallOpSet::ContinueFillOpsAfterInterception #call_op_set.h:943 調用6個op的AddOp並調用grpc_call_start_batch) 005-->006(grpc::CoreCodegen::grpc_call_start_batch #core_codegen.cc:113 調用grpc_call_start_batch) 006-->007(grpc_call_start_batch #call.cc:1974 調用call_start_batch) 007-->008(call_start_batch #call.cc:1929 根據6個ops的op->op, 設置stream_op, ops, call的參數, 最後調用execute_batch) 008-->009(execute_batch #call.cc:639 調用start_batch_closure的callback函數 execute_batch_in_call_combiner) 009-->010(execute_batch_in_call_combiner #call.cc:628 調用 elem->filter->start_transport_stream_op_batch) 010-->011(grpc_call_next_op #channel_stack.cc:227 調用 next_elem->filter->start_transport_stream_op_batch) 011-->012(grpc_core::CallData::StartTransportStreamOpBatch #client_channel.cc:2140 把batch加入pending:PendingBatchesAdd並調用PickSubchannel) 012-->013(grpc_core::CallData::PickSubchannel #client_channel.cc:3853 調用PickSubchannelLocked返回false) 013-->014(grpc_core::CallData::PickSubchannelLocked #client_channel.cc:3870 picker_是nullptr, 調用CheckConnectivityState, 參數設定為嘗試連接) 014-->015(grpc_core::ChannelData::CheckConnectivityState #client_channel.cc:1956 創建closure並調用它的callback函數 TryToConnectLocked) 015-->016(closure_impl::closure_wrapper #closure.h:156 創建closure是callback函數是closure_impl::closure_wrapper, 真正的callback是 TryToConnectLocked) 016-->017(grpc_core::ChannelData::TryToConnectLocked #client_channel.cc:1946 調用CreateResolvingLoadBalancingPolicyLocked) 017-->018(grpc_core::ChannelData::CreateResolvingLoadBalancingPolicyLocked #client_channel.cc:1596 調用ResolvingLoadBalancingPolicy構造函數) 018-->019(grpc_core::ResolvingLoadBalancingPolicy #resolving_lb_policy.cc:199 創建CreateResolver, UpdateState並調用StartLocked開始解析) 019-->020(grpc_core::AresDnsResolver::StartLocked #dns_resolver_ares.cc:177 調用MaybeStartResolvingLocked) 020-->021(grpc_core::AresDnsResolver::MaybeStartResolvingLocked #dns_resolver_ares.cc:409 調用StartResolvingLocked) 021-->022(grpc_core::AresDnsResolver::StartResolvingLocked #dns_resolver_ares.cc:420 調用grpc_dns_lookup_ares_locked) 022-->023(grpc_dns_lookup_ares_locked_impl #grpc_ares_wrapper.cc:625 調用grpc_dns_lookup_ares_continue_after_check_localhost_and_ip_literals_locked) 023-->024(grpc_dns_lookup_ares_continue_after_check_localhost_and_ip_literals_locked #grpc_ares_wrapper.cc:446 使用c-ares通過dns查找ip地址, 最後調用grpc_ares_request_unref_locked) 024-->025(grpc_ares_request_unref_locked #grpc_ares_wrapper.cc:135 如果延遲的查詢為0, 調用grpc_ares_ev_driver_on_queries_complete_locked) 025-->026(grpc_ares_ev_driver_on_queries_complete_locked #grpc_ares_ev_driver.cc:191 停止查詢,調用grpc_timer_cancel, 參數是query_timeout) 026-->027(grpc_timer_cancel #timer.cc:35 調用grpc_timer_impl->cancel) 027-->028(timer_cancel #timer_generic.cc:474 調用 timer->closure對應的callback函數) 028-->029(on_ares_backup_poll_alarm_locked #grpc_ares_ev_driver.cc:288 調用grpc_ares_ev_driver_unref) 029-->030(grpc_ares_ev_driver_unref #grpc_ares_ev_driver.cc:112 釋放資源並調用grpc_ares_complete_request_locked) 030-->031(grpc_ares_complete_request_locked #grpc_ares_wrapper.cc:151 調用on_done對應的callback函數) 031-->032(grpc_core::AresDnsResolver::OnResolvedLocked #dns_resolver_ares.cc:347 解析完成, 調用ReturnResult) 032-->033(grpc_core::ResolvingLoadBalancingPolicy::ResolverResultHandler::ReturnResult #resolving_lb_policy.cc:87 調用OnResolverResultChangedLocked) 033-->034(OnResolverResultChangedLocked #resolving_lb_policy.cc:479 獲得lb_policy_name,預設pick_first, 如果lb_policy_name不為空, 則創建或者更新LB policy, 調用的是CreateOrUpdateLbPolicyLocked) 034-->035(CreateOrUpdateLbPolicyLocked #resolving_lb_policy.cc:364 創建或者更新lb_policy, 調用UpdateLocked) 035-->036(PickFirst::UpdateLocked #pick_first.cc:280 調用AttemptToConnectUsingLatestUpdateArgsLocked) 036-->037(PickFirst::AttemptToConnectUsingLatestUpdateArgsLocked #pick_first.cc:236 用latest_update_args_創建 subchannel列表, 如果列表中的subchannel有狀態是GRPC_CHANNEL_READY, 則選中此subchannel, 否則選中第0個subchannel) 037-->038(AttemptToConnect #client_channel.cc:921 調用subchannel_->AttemptToConnect) 038-->039(Subchannel::AttemptToConnect #subchannel.cc:823 調用MaybeStartConnectingLocked) 039-->040(Subchannel::MaybeStartConnectingLocked #subchannel.cc:930 調用ContinueConnectingLocked) 040-->041(Subchannel::ContinueConnectingLocked #subchannel.cc:983 設置grpc_connect_in_args參數並調用grpc_connector_connect, 通過connector->vtable->connect最後調用chttp2_connector_connect)
您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Nginx入門簡介和反向代理、負載均衡、動靜分離理解
    場景 Nginx簡介 Nginx ("engine x")是一個高性能的 HTTP 和反向代理伺服器 特點是占有記憶體少，併發能力強，事實上 nginx 的併發能力確實在同類型的網頁伺服器中表現較好，中國大陸使用 nginx網站用戶有：百度、京東、新浪、網易、騰訊、淘寶等。 Nginx可以作為靜態頁面 ...
  • hadoop偽分佈模式的配置和一些常用命令
    大數據的發展歷史 3V：volume、velocity、variety（結構化和非結構化數據）、value（價值密度低） 大數據帶來的技術挑戰 存儲容量不斷增加 獲取有價值的信息的難度：搜索、廣告、推薦 大容量、多類型、高時效的數據處理場景，使得從數據中獲取有價值的信息變得非常困難 hadoop理論 ...
  • 集合框架關於<list介面><map介面>的運用
    集合： 集合就是一個容器，他可以存儲對象，我們說集合就是一個可變的數組 集合框架特點 1、list和set集合同時實現了collection介面 2、set集合存儲唯一，無序的對象。 3、list 存儲的不唯一，有序的對象（順序，按存儲的先後順序） 4、map介面存儲的方式：鍵值對進行存儲，鍵是唯一 ...
  • CDN原理加速解析
    CDN概念 CDN全稱叫做“Content Delivery Network”，中文叫內容分髮網絡。 原理分析 我們知道，當我們使用功能變數名稱訪問某一個網站時，實際上就是將請求包（以Http請求為例）通過網路傳輸給某台伺服器，比如訪問“www.baidu.com”時： 首先解析出該功能變數名稱所對應的IP地址(D ...
  • 設計模式 - 委派模式
    理解 首先委派模式不屬於23種設計模式。 所謂委派，個人理解是：將為達到最終結果的事情交給其他人或中間人來乾，我只要最終結果，其他的事情，由我委派的人來安排。 更直白的表達就是，比如，我們想要蓋一棟樓房，蓋完之後我要刷漆，這些事情我自己肯定不能做，所以我這時候就會去找一個“包工頭”來幫我完成這件事情 ...
  • 周末學了個“吸英大法”
    "曦曦粉絲會視頻鏈接" : https://v.qq.com/x/page/o3010zxz73y.html 周末閑看微信時，看到了上面這個視頻，一個 4 歲的小孩，面對一群大人提出的人問題，回答得頭頭是道，燃起了我的好奇心：一個還沒上學的小孩竟然知道這麼多東西，是怎麼學會的？而且看起來小孩看起來很 ...
  • Django框架篇-13用戶認證組件
    用戶認證 auth模塊 django.contrib.auth中提供了許多方法，這裡主要介紹其中的三個： 1.1 、authenticate() 提供了用戶認證，即驗證用戶名以及密碼是否正確,一般需要username password兩個關鍵字參數 如果認證信息有效，會返回一個 User 對象。au ...
  • Servlet處理原生Ajax請求
    萌新小白人生中的第一篇博客，難免會有差錯，還望各位大佬多多包涵。 1. Ajax技術簡介 Ajax(Asynchronous JavaScript and XML，非同步JavaScript和XML)時一種創建互動式網頁應用的網頁開發技術，它並不是一項新的技術，其產生的目的是用於實現頁面的局部刷新。通 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類