chromium通信系统-ipcz系统(十一)-mojo binding

关于mojo binding的官方文档为mojo docs。 由于比较复杂，这里只做简单源码分析。

我们知道要实现rpc，必须实现客户端和服务端。 mojo 实现了一套领域语言，通过领域语言描述接口和数据， 再通过特有编译器编译成c++代码。 这个过程会生成Mojo对象， 我们以content/common/child_process.mojom 为例子来分析。


interface ChildProcess {......// Requests that the process bind a receiving pipe targeting the service// interface named by |receiver|.//// TODO(crbug.com/977637): Rename this to |RunService()| once the above method// is removed.BindServiceInterface(mojo_base.mojom.GenericPendingReceiver receiver);// Requests that the process bind a receiving pipe targeting the interface// named by |receiver|. Unlike |BindServiceInterface()| this may be used to// bind arbitrary interfaces on many different types of child processes.// Calls to this method generally end up in// |ChildThreadImpl::OnBindReceiver()|.//// Whether or not the interface type encapsulated by |receiver| is supported// depends on the process type and potentially on the Content embedder.BindReceiver(mojo_base.mojom.GenericPendingReceiver receiver);......
};

我们删除一些接口，总体定义如下。生成带c++代码如下。
out/Default/gen/content/common/child_process.mojom.h

class CONTENT_EXPORT ChildProcess: public ChildProcessInterfaceBase {public:......// 接口的名字static const char Name_[];// 方法表，用于将消息序号转化为处理函数static IPCStableHashFunction MessageToMethodInfo_(mojo::Message& message);// 方法名称表static const char* MessageToMethodName_(mojo::Message& message);// 协议版本static constexpr uint32_t Version_ = 0;static constexpr bool PassesAssociatedKinds_ = false;// 是否包含不可中断的方法static constexpr bool HasUninterruptableMethods_ = false;using Base_ = ChildProcessInterfaceBase;// 代理对象，用于客户端调用using Proxy_ = ChildProcessProxy;template <typename ImplRefTraits>// 用于指向服务端实现using Stub_ = ChildProcessStub<ImplRefTraits>;// 请求校验器using RequestValidator_ = ChildProcessRequestValidator;// 回复校验器using ResponseValidator_ = mojo::PassThroughFilter;// 方法版本列表enum MethodMinVersions : uint32_t {kProcessShutdownMinVersion = 0,kSetIPCLoggingEnabledMinVersion = 0,kGetBackgroundTracingAgentProviderMinVersion = 0,kEnableSystemTracingServiceMinVersion = 0,kCrashHungProcessMinVersion = 0,kRunServiceDeprecatedMinVersion = 0,kBindServiceInterfaceMinVersion = 0,kBindReceiverMinVersion = 0,kSetPseudonymizationSaltMinVersion = 0,};......// 下面是方法声明virtual ~ChildProcess() = default;......virtual void BindServiceInterface(::mojo::GenericPendingReceiver receiver) = 0;virtual void BindReceiver(::mojo::GenericPendingReceiver receiver) = 0;......
};

生成的c++ 类除了方法声明之外，还包括如下信息：

  • Name_接口名称
  • MessageToMethodInfo_： 方法表，通过收到的消息找到对应的rpc方法。
  • Proxy_ 代理对象，通过代理对象调用具体方法组装消息，发送给服务端。（包括方法名称，参数等，用于调用服务端对应方法）
  • Stub_ 用于描述服务端，指向服务端具体实现。
  • RequestValidator_ 请求校验。
  • ResponseValidator_ 响应校验。

通过官方文档我们知道通过Remote 调用服务端方法。 来看一下Remote 是如何实现的。
mojo/public/cpp/bindings/remote.h

 887 void ChildProcessProxy::BindServiceInterface(888     ::mojo::GenericPendingReceiver in_receiver) {889 #if BUILDFLAG(MOJO_TRACE_ENABLED)890   TRACE_EVENT1(891     "mojom", "Send content::mojom::ChildProcess::BindServiceInterface", "input_parameters",892     [&](perfetto::TracedValue context){893       auto dict = std::move(context).WriteDictionary();894       perfetto::WriteIntoTracedValueWithFallback(895            dict.AddItem("receiver"), in_receiver,896                         "<value of type ::mojo::GenericPendingReceiver>");897    });898 #endif899   const bool kExpectsResponse = false;900   const bool kIsSync = false;901   const bool kAllowInterrupt = true;902 903   const uint32_t kFlags =904       ((kExpectsResponse) ? mojo::Message::kFlagExpectsResponse : 0) |905       ((kIsSync) ? mojo::Message::kFlagIsSync : 0) |906       ((kAllowInterrupt) ? 0 : mojo::Message::kFlagNoInterrupt);907 908   mojo::Message message(909       internal::kChildProcess_BindServiceInterface_Name, kFlags, 0, 0, nullptr);910   mojo::internal::MessageFragment<911       ::content::mojom::internal::ChildProcess_BindServiceInterface_Params_Data> params(912           message);913   params.Allocate();914   mojo::internal::MessageFragment<915       typename decltype(params->receiver)::BaseType> receiver_fragment(916           params.message());917   mojo::internal::Serialize<::mojo_base::mojom::GenericPendingReceiverDataView>(918       in_receiver, receiver_fragment);919   params->receiver.Set(920       receiver_fragment.is_null() ? nullptr : receiver_fragment.data());921   MOJO_INTERNAL_DLOG_SERIALIZATION_WARNING(922       params->receiver.is_null(),923       mojo::internal::VALIDATION_ERROR_UNEXPECTED_NULL_POINTER,924       "null receiver in ChildProcess.BindServiceInterface request");925 926 #if defined(ENABLE_IPC_FUZZER)927   message.set_interface_name(ChildProcess::Name_);928   message.set_method_name("BindServiceInterface");929 #endif930   // This return value may be ignored as false implies the Connector has931   // encountered an error, which will be visible through other means.932   ::mojo::internal::SendMojoMessage(*receiver_, message);933 }

BindServiceInterface 的主要作用就是组装消息，然后发送。 这里908-909行创建Message的时候指定的消息名称为internal::kChildProcess_BindServiceInterface_Name， 用于指示服务端调用哪个方法。 这里932行receiver_ 持有一个portal，可以将数据写出去。

我们再看服务端怎么处理消息：

259 // Implements the mojom ChildProcess interface and lives on the IO thread.
260 class ChildThreadImpl::IOThreadState
261     : public base::RefCountedThreadSafe<IOThreadState>,
262       public mojom::ChildProcess {......
358 
359   void BindServiceInterface(mojo::GenericPendingReceiver receiver) override {
360     if (service_binder_)
361       service_binder_.Run(&receiver);
362 
363     if (receiver) {
364       main_thread_task_runner_->PostTask(
365           FROM_HERE, base::BindOnce(&ChildThreadImpl::BindServiceInterface,
366                                     weak_main_thread_, std::move(receiver)));
367     }
368   }
369 
370   void BindReceiver(mojo::GenericPendingReceiver receiver) override {
371     if (wait_for_interface_binders_) {
372       pending_binding_requests_.push_back(std::move(receiver));
373       return;
374     }
375 
376     if (interface_binders_.TryBind(&receiver))
377       return;
378 
379     main_thread_task_runner_->PostTask(
380         FROM_HERE, base::BindOnce(&ChildThreadImpl::OnBindReceiver,
381                                   weak_main_thread_, std::move(receiver)));
382   }
383 ......457   mojo::Receiver<mojom::ChildProcess> receiver_{this};
458 
459   // Binding requests which should be handled by |interface_binders|, but which
460   // have been queued because |allow_interface_binders_| is still |false|.
461   std::vector<mojo::GenericPendingReceiver> pending_binding_requests_;
462 };

ChildThreadImpl::IOThreadState 实现了mojom::ChildProcess接口。 它持有了一个receiver_对象， 该对象持有portal一端， 用于处理对端发送的消息。

我们具体来看 mojo::Receivermojom::ChildProcess 的实现。

template <typename Interface,typename ImplRefTraits = RawPtrImplRefTraits<Interface>>
class Receiver {
......explicit Receiver(ImplPointerType impl) : internal_state_(std::move(impl)) {}
......private:internal::BindingState<Interface, ImplRefTraits> internal_state_;
}

Receiver 的参数为ChildThreadImpl::IOThreadState实例。 然后初始化internal_state_变量。internal_state_类型展开宏之后为nternal::BindingState<mojom::ChildProcess, RawPtrImplRefTraitsmojom::ChildProcess> internal_state_。

template <typename Interface, typename ImplRefTraits>
class BindingState : public BindingStateBase {public:using ImplPointerType = typename ImplRefTraits::PointerType;explicit BindingState(ImplPointerType impl) {stub_.set_sink(std::move(impl));}......
}

这里stub_成员变量为 typename Interface::template Stub_ stub_;展开宏为
mojom::ChildProcess::Stub_ stub_, 也就是ChildProcessStub。 我们看一下它的实现以及set_sink 方法。
out/Default/gen/content/common/child_process.mojom.h


template <typename ImplRefTraits =mojo::RawPtrImplRefTraits<ChildProcess>>
class ChildProcessStub: public mojo::MessageReceiverWithResponderStatus {public:
........void set_sink(ImplPointerType sink) { sink_ = std::move(sink); }ImplPointerType& sink() { return sink_; }bool Accept(mojo::Message* message) override {if (ImplRefTraits::IsNull(sink_))return false;return ChildProcessStubDispatch::Accept(ImplRefTraits::GetRawPointer(&sink_), message);}bool AcceptWithResponder(mojo::Message* message,std::unique_ptr<mojo::MessageReceiverWithStatus> responder) override {if (ImplRefTraits::IsNull(sink_))return false;return ChildProcessStubDispatch::AcceptWithResponder(ImplRefTraits::GetRawPointer(&sink_), message, std::move(responder));}private:ImplPointerType sink_;
};

set_sink方法实际设置成员变量sink_， 实际指向ChildThreadImpl::IOThreadState实例。 当receiver收到消息后会调用Accept(异步)方法或者AcceptWithResponder（同步返回结果）方法。

Accept方法调用ChildProcessStubDispatch::Accept方法，第一个参数为sink_, 第二个参数为消息体。我们来看ChildProcessStubDispatch::Accept 方法
out/Default/gen/content/common/child_process.mojom.cc

1021 // static
1022 bool ChildProcessStubDispatch::Accept(
1023     ChildProcess* impl,
1024     mojo::Message* message) {
1025   switch (message->header()->name) {.......
1182     case internal::kChildProcess_BindServiceInterface_Name: {
1183 
1184       DCHECK(message->is_serialized());
1185       internal::ChildProcess_BindServiceInterface_Params_Data* params =
1186           reinterpret_cast<internal::ChildProcess_BindServiceInterface_Params_Data*>(
1187               message->mutable_payload());
1188 
1189       bool success = true;
1190       ::mojo::GenericPendingReceiver p_receiver{};
1191       ChildProcess_BindServiceInterface_ParamsDataView input_data_view(params, message);
1192 
1193       if (success && !input_data_view.ReadReceiver(&p_receiver))
1194         success = false;
1195       if (!success) {
1196         ReportValidationErrorForMessage(
1197             message,
1198             mojo::internal::VALIDATION_ERROR_DESERIALIZATION_FAILED,
1199             ChildProcess::Name_, 6, false);
1200         return false;
1201       }
1202       // A null |impl| means no implementation was bound.
1203       DCHECK(impl);
1204       impl->BindServiceInterface(
1205 std::move(p_receiver));
1206       return true;
1207     }
1208     case internal::kChildProcess_BindReceiver_Name: {
1209 
1210       DCHECK(message->is_serialized());
1211       internal::ChildProcess_BindReceiver_Params_Data* params =
1212           reinterpret_cast<internal::ChildProcess_BindReceiver_Params_Data*>(
1213               message->mutable_payload());
1214 
1215       bool success = true;
1216       ::mojo::GenericPendingReceiver p_receiver{};
1217       ChildProcess_BindReceiver_ParamsDataView input_data_view(params, message);
1218 
1219       if (success && !input_data_view.ReadReceiver(&p_receiver))
1220         success = false;
1221       if (!success) {
1222         ReportValidationErrorForMessage(
1223             message,
1224             mojo::internal::VALIDATION_ERROR_DESERIALIZATION_FAILED,
1225             ChildProcess::Name_, 7, false);
1226         return false;
1227       }
1228       // A null |impl| means no implementation was bound.
1229       DCHECK(impl);
1230       impl->BindReceiver(
1231 std::move(p_receiver));
1232       return true;
1233     }.......
1259     }
1260   }
1261   return false;
1262 }

函数很简单，根据message的名称反序列化参数，然后调用ChildThreadImpl::IOThreadState的对应方法。

以上就是典型的ipcz binding 使用。 整体通信借助ipcz 通道。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/622764.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

C语言之字符串和指针

C语言之字符串和指针

目录 用数组实现的字符串和用指针实现的字符串 █用数组实现的字符串str █用指针实现的字符串ptr 注意 用数组和指针实现字符串的不同点 字符串数组 用数组实现的字符串的数组——二维数组 用指针实现的字符串数组——指针数组 注意 字符串和指针有着紧密的联系&#…
阅读更多...
程序设计语言的分类

程序设计语言的分类

编译与解释 编译型 将源代码转换成目标代码&#xff0c;通常源代码是高级语言代码&#xff0c;目标代码是机器语言代码&#xff0c;执行编译的计算机程序称为编译器。 eg:java 好处&#xff1a;对于相同的源代码编译产生的目标代码执行速度更快&#xff0c;目标代码不需要编译…
阅读更多...
TikTok系列算法定位还原x-ss-stub

TikTok系列算法定位还原x-ss-stub

TikTok的x系列的算法比较有名，很多粉丝也问过，之前没有深入研究，本人工作量也比较大。 我们上次说到TikTok的x-ss-stub的算法就是ccmd5标准库算的，今天要讲细致点，表面这个结论本不是直接将数据md5那么来的，是经过一系列分析来的 上图是上次截图的，这次我们分析整个定位…
阅读更多...
node(express.js创建项目)+连接mysql数据库

node(express.js创建项目)+连接mysql数据库

1.node npm的安装 2.express的安装 全局安装:npm install express -gnpm install -g express-generator// ps: 4.0版本把generator分离出来了&#xff0c;需要单独安装3.创建express项目 express 项目名称 cd 项目名称 npm install npm start4.项目中安装数据库 npm install…
阅读更多...
flink中的row类型详解

flink中的row类型详解

在Apache Flink中&#xff0c;Row 是一个通用的数据结构&#xff0c;用于表示一行数据。它是 Flink Table API 和 Flink DataSet API 中的基本数据类型之一。Row 可以看作是一个类似于元组的结构&#xff0c;其中包含按顺序排列的字段。 Row 的字段可以是各种基本数据类型&…
阅读更多...
C语言督学营（高级阶段）

C语言督学营（高级阶段）

文章目录 高级阶段19.C语言语法进阶1.条件运算符、逗号运算符(1)条件运算符 / 三目运算符   ? :(2)逗号运算符   , 2.自增自减运算符3.位运算符&#xff1a;按位或、按位异或、按位取反(1)逻辑与、按位与、左移、右移(2)有符号数右移 vs 无符号数右移(3)按位与、按位或、按位…
阅读更多...
Docker学习与应用（五）-DockerFile

Docker学习与应用（五）-DockerFile

1、DockerFile 1&#xff09;DockerFile介绍 dockerfile是用来构建docker镜像的文件&#xff01;命令参数脚本&#xff01; 构建步骤&#xff1a; 1. 编写一个dockerfile文件 2. docker build 构建称为一个镜像 3. docker run运行镜像 4. docker push发布镜像&#xff08;D…
阅读更多...
LC 83. 删除排序链表中的重复元素

LC 83. 删除排序链表中的重复元素

83. 删除排序链表中的重复元素 难度 &#xff1a; 简单 题目&#xff1a; 给定一个已排序的链表的头 head &#xff0c; 删除所有重复的元素&#xff0c;使每个元素只出现一次 。返回 已排序的链表 。 提示&#xff1a; 链表中节点数目在范围 [0, 300] 内-100 < Node.va…
阅读更多...
蓝桥杯准备

蓝桥杯准备

书籍获取&#xff1a;Z-Library – 世界上最大的电子图书馆。自由访问知识和文化。 (zlibrary-east.se) 书评&#xff1a;(豆瓣) (douban.com) 一、观千曲而后晓声 别人常说蓝桥杯拿奖很简单&#xff0c;但是拿奖是一回事&#xff0c;拿什么奖又是一回事。况且&#xff0c;如果…
阅读更多...
Docker教程

Docker教程

docker 安装 官方文档 wget -qO- https://get.docker.com/ | sh sudo usermod -aG docker your-user sudo usermod -aG docker ${USER} newgrp docker # 更新docker用户组 cat /etc/group | grep docker docker --version 使用非root用户管理 帮助启动类 命令 system…
阅读更多...
vue3+ts 中实现压缩图片、blob 转 base64

vue3+ts 中实现压缩图片、blob 转 base64

压缩图片 1.npm 安装 image-compressor.js 2.引入 import ImageCompressor from image-compressor.js 3.使用 const compressImage async (file: any) > {var imageCompressor new ImageCompressor()return new Promise((resolve, reject) > {imageCompressor.comp…
阅读更多...
寄快递有没有什么省钱的小妙招？ 怎样寄快递才能省钱呢？

寄快递有没有什么省钱的小妙招？ 怎样寄快递才能省钱呢？

快递物流行业的快速崛起刺激了人们的消费欲望&#xff0c;其中典型的是每每到重大节日尤其是双十一或者双十二&#xff0c;消费市场异常火爆&#xff0c;这也使得快递行业加班加点的干也不追不上人们下单的速度。如今&#xff0c;互联网时代崛起&#xff0c;网购成为了大家最寻…
阅读更多...
机器学习_捕捉函数的变化趋势（凸函数）

机器学习_捕捉函数的变化趋势（凸函数）

文章目录 连续性是求导的前提条件通过求导发现 y 如何随 x 而变凸函数有一个全局最低点 机器学习所关心的问题之一捕捉函数的变化趋势&#xff0c;也就是标签&#xff08;y&#xff09;是如何随着特征字段&#xff08;x&#xff09;而变化的&#xff0c;这个变化趋势是通过求导…
阅读更多...
代码随想录day30 回溯算法最终章

代码随想录day30 回溯算法最终章

51. N皇后 题目 n 皇后问题 研究的是如何将 n 个皇后放置在 nn 的棋盘上&#xff0c;并且使皇后彼此之间不能相互攻击。 给你一个整数 n &#xff0c;返回所有不同的 n 皇后问题 的解决方案。 每一种解法包含一个不同的 n 皇后问题 的棋子放置方案&#xff0c;该方案中 Q 和…
阅读更多...
想做好项目，网工必看！

想做好项目，网工必看！

上午好&#xff0c;我是老杨。 做项目&#xff0c;贯穿一个网络工程师职业生涯的始终。不管是大项目还是小项目&#xff0c;做久了项目&#xff0c;都会形成一种自己的方法论。 项目要划分&#xff0c;无非就是新网组建&#xff0c;旧网优化&#xff0c;以及网络排障三大类。…
阅读更多...
【已解决】Spring常见错误：类文件具有错误的版本 61.0, 应为 52.0

【已解决】Spring常见错误：类文件具有错误的版本 61.0, 应为 52.0

目录 问题复现原因分析错误依赖正确依赖 问题复现 报错内容如下&#xff1a; java: 无法访问org.springframework.web.bind.annotation.RequestMapping 错误的类文件: /D:/Java/Apache Software Foundation/apache-maven-3.6.3/maven/repository/org/springframework/spring…
阅读更多...
ISO11898-闭环高速CAN网络 (125K~1Mbps)

ISO11898-闭环高速CAN网络 (125K~1Mbps)

ISO11898 标准的物理框图如下图 可理解为一个高速闭环 CAN 总线网络&#xff1b;CAN 闭环总线网络允许总线最大长度为 40m;最高速度为 1Mbps;可以看到总线的两端各有一个 120Ω 的电阻&#xff0c;此电阻作为阻抗匹配功能&#xff0c;以减少回波反射;节点就是不同的设备&#…
阅读更多...
Pytorch基础知识点复习

Pytorch基础知识点复习

文章目录 并行计算单卡训练多卡训练单机多卡DP多机多卡DDPDP 与 DDP 的优缺点 PyTorch的主要组成模块Pytorch的主要组成模块包括那些呢&#xff1f;Dataset和DataLoader的作用是什么&#xff0c;我们如何构建自己的Dataset和DataLoader&#xff1f;神经网络的一般构造方法&…
阅读更多...
k8s的策略

k8s的策略

集群调度&#xff1a; Scheduler的调度算法&#xff1a; 预算策略 过滤出合适的节点 优先策略 选择部署的节点 NodeName&#xff1a;硬策略&#xff0c;不走调度策略&#xff0c;node1 nodeSelector&#xff1a;根据节点的标签选择&#xff0c;会走一个调度算法 只要是…
阅读更多...
Git基础操作

Git基础操作

Git 是一种分布式版本控制系统&#xff0c;用于管理软件项目的源代码。它是由 Linux 之父 Linus Torvalds 开发的&#xff0c;并已经成为了现代软件开发领域中最流行的版本控制系统之一。 使用 Git 可以追踪代码的历史修改记录&#xff0c;方便团队协作、代码共享和代码重构。…
阅读更多...
最新文章

Copyright @ 2022~2023