chromium通信系统-ipcz系统(八)-ipcz系统代码实现-跨Node通信-Broker和Broker通信

2024-01-01 20:28

本文主要是介绍chromium通信系统-ipcz系统(八)-ipcz系统代码实现-跨Node通信-Broker和Broker通信,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

前面我们分析了Broker和NonBroker通信,也分析了NonBroker和NonBroker通信,这里我们分析一下Broker和Broker通信过程。
我们直接一步到位,看NodeConnector的创建。

std::pair<Ref<NodeConnector>, IpczResult> CreateConnector(Ref<Node> node,Ref<DriverTransport> transport,IpczConnectNodeFlags flags,const std::vector<Ref<Portal>>& initial_portals,Ref<NodeLink> broker_link,NodeConnector::ConnectCallback callback) {const bool from_broker = node->type() == Node::Type::kBroker;const bool to_broker = (flags & IPCZ_CONNECT_NODE_TO_BROKER) != 0;const bool share_broker = (flags & IPCZ_CONNECT_NODE_SHARE_BROKER) != 0;const bool inherit_broker = (flags & IPCZ_CONNECT_NODE_INHERIT_BROKER) != 0;if (from_broker) {DriverMemoryWithMapping memory =NodeLinkMemory::AllocateMemory(node->driver());if (!memory.mapping.is_valid()) {return {nullptr, IPCZ_RESULT_RESOURCE_EXHAUSTED};}if (to_broker) {return {MakeRefCounted<NodeConnectorForBrokerToBroker>(std::move(node), std::move(transport), std::move(memory),flags, initial_portals, std::move(callback)),IPCZ_RESULT_OK};}......return {nullptr, IPCZ_RESULT_INVALID_ARGUMENT};
}

当前节点是broker的情况下,对端节点也是broker,就是broker to broker请求,创建NodeConnectorForBrokerToBroker。
NodeConnectorForBrokerToBroker

  // NodeConnector:bool Connect() override {DVLOG(4) << "Sending direct ConnectFromBrokerToBroker from broker "<< local_name_.ToString() << " with " << num_portals()<< " initial portals";ABSL_ASSERT(node_->type() == Node::Type::kBroker);msg::ConnectFromBrokerToBroker connect;connect.params().name = local_name_;connect.params().protocol_version = msg::kProtocolVersion;connect.params().num_initial_portals =checked_cast<uint32_t>(num_portals());connect.params().buffer = connect.AppendDriverObject(link_memory_allocation_.memory.TakeDriverObject());connect.params().padding = 0;return IPCZ_RESULT_OK == transport_->Transmit(connect);}

从broker链接另一个broker的消息对象为ConnectFromBrokerToBroker, ConnectFromBrokerToBroker的参数如下
name: 当前进程的NodeName,后面我们称这个进程为A进程,接收链接的进程为B进程。
protocol_version: 协议版本
num_initial_portals: 要初始化的RouterLink
buffer: 共享内存对象
padding: 用于对齐。

我们看对端收到消息如何处理

 // NodeMessageListener overrides:bool OnConnectFromBrokerToBroker(msg::ConnectFromBrokerToBroker& connect) override {const NodeName& remote_name = connect.params().name;DVLOG(4) << "Accepting ConnectFromBrokerToBroker on broker "<< local_name_.ToString() << " from other broker "<< remote_name.ToString();const LinkSide this_side =remote_name < local_name_ ? LinkSide::kA : LinkSide::kB;DriverMemory their_memory(connect.TakeDriverObject(connect.params().buffer));DriverMemoryMapping primary_buffer_mapping =this_side.is_side_a() ? std::move(link_memory_allocation_.mapping): their_memory.Map();if (!primary_buffer_mapping.is_valid()) {return false;}Ref<NodeLink> link = NodeLink::CreateActive(node_, this_side, local_name_, remote_name, Node::Type::kBroker,connect.params().protocol_version, transport_,NodeLinkMemory::Create(node_, std::move(primary_buffer_mapping)));AcceptConnection({.link = link, .broker = link},connect.params().num_initial_portals);return true;}

创建NodeLink, 注意这里面LinkSide 根据NodeName做比较确定。 共享内存使用LinkSide::kA端提供的共享内存。 对应的Connection 的broker 指向核对段的链接。

到这里我们所有的链接类型就分析完了,下面对NodeConnector 和 Connection的几种情况做一下总结。

NodeConnector类型:

Broker 和 NonBroker建立链接(假设A是Broker, B是NonBroker):

  • NodeConnectorForBrokerToNonBroker: 用于A链接B进程,创建的Connection.link 指向A->B链接,Connection.broker 为空。
  • NodeConnectorForNonBrokerToBroker: 用于B链接A进程。创建的Connection.link 指向B->A链接,Connection.broker 也指向B->A链接。

NonBroker 和NonBroker建立链接: (假设主动发起请求的NonBroker 为B, 另一个NonBroker为C, Broker 为A)

  • NodeConnectorForReferrer: 用于B 向C主动发起链接的过程中, 用于帮助A 和 另一个C 建立链接的NodeConnector。
  • NodeConnectorForBrokerReferral: 用于B 向C主动发起链接的过程中, A 一端建立的NodeConnector对象,用于等待C端链发起链接。收到C端发请求后帮助B和C建立链接。
  • NodeConnectorForReferredNonBroker: 用于C端请求NodeConnectorForBrokerReferral,并且接收NodeConnectorForBrokerReferral请求,建立C->A 和 C->B链接。

以上过程建立了三个链接:
C->A:Connection.link 为C到A的NodeLink, Connection.broker 为C到A的NodeLink。
A->C: Connection.link 为A到C的NodeLink, Connection.broker 为空。
B->C: Connection.link 为B到C的NodeLink, Connection.broker 为 B到A的NodeLink。
C->B: Connection.link 为C到B的NodeLink, Connection.broker 为 C到A的NodeLink。

也就是NonBroker<->NonBroker 的链接Connection->broker 都是和Broker的NodeLink。

Broker 和Broker建立链接
NodeConnectorForBrokerToBroker: 用于Broker 和Broker 建立链接, Connection.link 为指向对端的NodeLink, Connection.broker 也是指向对端的NodeLink。

到此几种链接我们都分析过了。下面就可以分析代理消除了。

这篇关于chromium通信系统-ipcz系统(八)-ipcz系统代码实现-跨Node通信-Broker和Broker通信的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/560420

相关文章

java中BigDecimal里面的subtract函数介绍及实现方法

《java中BigDecimal里面的subtract函数介绍及实现方法》在Java中实现减法操作需要根据数据类型选择不同方法,主要分为数值型减法和字符串减法两种场景,本文给大家介绍java中BigD... 目录Java中BigDecimal里面的subtract函数的意思?一、数值型减法(高精度计算)1.

C#代码实现解析WTGPS和BD数据

《C#代码实现解析WTGPS和BD数据》在现代的导航与定位应用中,准确解析GPS和北斗(BD)等卫星定位数据至关重要,本文将使用C#语言实现解析WTGPS和BD数据,需要的可以了解下... 目录一、代码结构概览1. 核心解析方法2. 位置信息解析3. 经纬度转换方法4. 日期和时间戳解析5. 辅助方法二、L

Python使用Code2flow将代码转化为流程图的操作教程

《Python使用Code2flow将代码转化为流程图的操作教程》Code2flow是一款开源工具,能够将代码自动转换为流程图,该工具对于代码审查、调试和理解大型代码库非常有用,在这篇博客中,我们将深... 目录引言1nVflRA、为什么选择 Code2flow?2、安装 Code2flow3、基本功能演示

使用Python和Matplotlib实现可视化字体轮廓(从路径数据到矢量图形)

《使用Python和Matplotlib实现可视化字体轮廓(从路径数据到矢量图形)》字体设计和矢量图形处理是编程中一个有趣且实用的领域,通过Python的matplotlib库,我们可以轻松将字体轮廓... 目录背景知识字体轮廓的表示实现步骤1. 安装依赖库2. 准备数据3. 解析路径指令4. 绘制图形关键

Windows 系统下 Nginx 的配置步骤详解

《Windows系统下Nginx的配置步骤详解》Nginx是一款功能强大的软件,在互联网领域有广泛应用,简单来说,它就像一个聪明的交通指挥员,能让网站运行得更高效、更稳定,:本文主要介绍W... 目录一、为什么要用 Nginx二、Windows 系统下 Nginx 的配置步骤1. 下载 Nginx2. 解压

RabbitMQ工作模式中的RPC通信模式详解

《RabbitMQ工作模式中的RPC通信模式详解》在RabbitMQ中,RPC模式通过消息队列实现远程调用功能,这篇文章给大家介绍RabbitMQ工作模式之RPC通信模式,感兴趣的朋友一起看看吧... 目录RPC通信模式概述工作流程代码案例引入依赖常量类编写客户端代码编写服务端代码RPC通信模式概述在R

如何确定哪些软件是Mac系统自带的? Mac系统内置应用查看技巧

《如何确定哪些软件是Mac系统自带的?Mac系统内置应用查看技巧》如何确定哪些软件是Mac系统自带的?mac系统中有很多自带的应用,想要看看哪些是系统自带,该怎么查看呢?下面我们就来看看Mac系统内... 在MAC电脑上,可以使用以下方法来确定哪些软件是系统自带的:1.应用程序文件夹打开应用程序文件夹

windows系统上如何进行maven安装和配置方式

《windows系统上如何进行maven安装和配置方式》:本文主要介绍windows系统上如何进行maven安装和配置方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不... 目录1. Maven 简介2. maven的下载与安装2.1 下载 Maven2.2 Maven安装2.

C/C++中OpenCV 矩阵运算的实现

《C/C++中OpenCV矩阵运算的实现》本文主要介绍了C/C++中OpenCV矩阵运算的实现,包括基本算术运算(标量与矩阵)、矩阵乘法、转置、逆矩阵、行列式、迹、范数等操作,感兴趣的可以了解一下... 目录矩阵的创建与初始化创建矩阵访问矩阵元素基本的算术运算 ➕➖✖️➗矩阵与标量运算矩阵与矩阵运算 (逐元

IIS 7.0 及更高版本中的 FTP 状态代码

《IIS7.0及更高版本中的FTP状态代码》本文介绍IIS7.0中的FTP状态代码,方便大家在使用iis中发现ftp的问题... 简介尝试使用 FTP 访问运行 Internet Information Services (IIS) 7.0 或更高版本的服务器上的内容时,IIS 将返回指示响应状态的数字代