流量控制方法、存储介质、电子装置及程序产品与流程

本申请实施例涉及通信领域，具体而言，涉及一种流量控制方法、存储介质、电子装置及程序产品。

背景技术：

1、智算网络(intelligent computing network)作为支撑大规模分布式ai训练、高性能计算和云数据中心的核心基础设施，需处理海量节点间的高并发、低时延通信需求。uec(ultra ethernet consortium)针对智算网络场景提出了基于信用的流量控制(credit-based flow control，cbfc)机制，以实现高效、公平、动态化的队列资源管理需求，避免传统流量控制方法在复杂智能场景中的局限性(如静态的带宽资源预留造成的浪费)。

2、然而，目前使用循环计数器的cbfc机制在一些情况下存在死锁问题，这主要是因为它采用了具有有限比特位的无限递增的计数器，下游节点在向上游节点反馈最新的信用值时，计数器可能已经发生翻转，而翻转后的值可能与上游节点保存的旧值接近，导致上游节点无法正常计算新增的信用，从而造成死锁。除此之外，消息丢失也会导致死锁发生。

技术实现思路

1、本申请实施例提供了一种流量控制方法、存储介质、电子装置及程序产品，以至少解决传统基于信用的流量控制机制中因信用计数器翻转或消息丢失而导致第一节点与第二节点间通信死锁的问题。

2、根据本申请的一个实施例，提供了一种流量控制方法，包括：第一节点根据其发送队列的可用令牌数向第二节点的接收队列发送报文，其中，可用令牌数根据发送队列的初始令牌数和补充令牌数确定，补充令牌数根据第二节点的接收队列发送的字节数对应的令牌数达到预设阈值的通知确定。

3、根据本申请的另一个实施例，提供了一种流量控制方法，包括：第二节点的接收队列接收第一节点根据其发送队列的可用令牌数发送的报文，其中，可用令牌数是第一节点根据发送队列的初始令牌数和补充令牌数确定的，补充令牌数是第一节点根据第二节点的接收队列发送的字节数对应的令牌数达到预设阈值的通知确定的。

4、根据本申请的又一个实施例，还提供了一种计算机可读存储介质，所述计算机可读存储介质中存储有计算机程序，其中，所述计算机程序被设置为运行时执行上述任一项方法实施例中的步骤。

5、根据本申请的又一个实施例，还提供了一种电子装置，包括存储器和处理器，所述存储器中存储有计算机程序，所述处理器被设置为运行所述计算机程序以执行上述任一项方法实施例中的步骤。

6、根据本申请的又一个实施例，还提供了一种计算机程序产品，包括计算机程序，所述计算机程序被处理器执行时实现上述任一项方法实施例中的步骤。

7、通过本申请上述实施例，利用令牌的动态调整保证了第一节点能够根据第二节点的实际接收能力发送报文，避免了不必要的等待和数据包积压，提高了通信效率和数据传输的实时性。通过动态补充令牌，即使在网络拥塞或消息丢失的情况下，也能够避免第一节点因为无法增补信用而陷入无法发送数据的状态，从而有效防止了死锁问题。令牌的消耗和补充机制确保了网络资源的公平分配，每个发送队列都能根据其数据传输的需求动态获得令牌资源，避免了静态资源预留可能导致的资源浪费和不公平。解决了传统基于信用的流量控制机制中因信用计数器翻转或消息丢失而导致第一节点与第二节点间通信死锁的问题。

1.一种流量控制方法，其特征在于，包括：

2.根据权利要求1所述的方法，其特征在于，所述第一节点根据其发送队列的可用令牌数向第二节点的接收队列发送报文之前，还包括：所述第一节点与所述第二节点进行会话协商。

3.根据权利要求2所述的方法，其特征在于，所述第一节点与所述第二节点进行会话协商，包括：

4.根据权利要求3所述的方法，其特征在于，所述第一节点根据其发送队列的可用令牌数向第二节点的接收队列发送报文，包括：

5.根据权利要求4所述的方法，其特征在于，所述第四消息还包括第二节点的令牌数计数器值。

6.根据权利要求5所述的方法，其特征在于，所述第一节点为所述可用令牌数增加补充令牌数，包括：所述第一节点为所述可用令牌数增加所述令牌数计数器值。

7.根据权利要求5所述的方法，其特征在于，所述根据所述第四消息中的丢包码判断是否发生过第四消息的丢失，包括：

8.根据权利要求4所述的方法，其特征在于，在判断结果为发生第四消息的丢失的情况下，所述第一节点向所述第二节点发起会话重新协商。

9.根据权利要求8所述的方法，其特征在于，所述第一节点向所述第二节点发起会话重新协商，包括：

10.根据权利要求3所述的方法，其特征在于，所述第二消息包括所述接收队列编号和所述第一序列号。

11.根据权利要求10所述的方法，其特征在于，所述第二消息还包括m、n和所述预设阈值。

12.根据权利要求3所述的方法，其特征在于，所述第三消息包括所述接收队列编号、所述第一序列号。

13.根据权利要求12所述的方法，其特征在于，所述第三消息还包括m、n和所述预设阈值。

14.一种流量控制方法，其特征在于，包括：

15.根据权利要求14所述的方法，其特征在于，所述第二节点的接收队列接收第一节点根据其发送队列的可用令牌数发送的报文之前，还包括：所述第二节点与所述第一节点进行会话协商。

16.根据权利要求15所述的方法，其特征在于，所述第二节点与所述第一节点进行会话协商，包括：

17.根据权利要求16所述的方法，其特征在于，所述第二节点向所述第一节点发送第三消息，包括：

18.根据权利要求16所述的方法，其特征在于，所述第二节点接收第一节点根据可用令牌数向第二节点发送的报文之后，还包括：

19.根据权利要求18所述的方法，其特征在于，所述第四消息包括丢包码，其中，在所述第二节点在所述会话协商后第一次发送所述第四消息的情况下，将所述第四消息中的丢包码设置为1；否则，所述第四消息中的丢包码设置为等于上一个第四消息中的丢包码加1。

20.根据权利要求16所述的方法，其特征在于，所述第二节点向所述第一节点发送第一消息，还包括：

21.根据权利要求16所述的方法，其特征在于，所述第二节点向所述第一节点发送第一消息，还包括：

22.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质中存储有计算机程序，其中，所述计算机程序被处理器执行时实现所述权利要求1至13任一项中所述的方法的步骤，或者实现权利要求14-21任一项中所述的方法的步骤。

23.一种电子装置，包括存储器、处理器以及存储在所述存储器上并可在所述处理器上运行的计算机程序，其特征在于，所述处理器执行所述计算机程序时实现所述权利要求1至13任一项中所述的方法的步骤，或者实现权利要求14-21任一项中所述的方法的步骤。

24.一种计算机程序产品，包括计算机程序，其特征在于，所述计算机程序被处理器执行时实现所述权利要求1至13任一项中所述的方法的步骤，或者实现权利要求14-21任一项中所述的方法的步骤。