2.6.4 AM Ring示例
在上节的“Ping-Pong”示例中,通信仅发生在Request和对发送端的Reply上。该例子使用的是最简单的逻辑通信类型。然而,现实的应用通常至少需要使用“A-to-B-to-C”的通信模式,本节介绍的“Ring”示例(如代码清单2-4和代码清单2-5所示)即为这种通信类型的典型实现。与“Ping-Pong”示例一样,代码清单2-4和代码清单2-5分别替换了“Hello,World!”示例中的第19~21行和第32~34行代码。
本示例主要是从节点0开始依次按照升序发送消息,在最大编号的节点之后回到节点0形成一个多次传递的虚拟令牌环。由于每个节点必须从其前一个节点接收并发送给下一个节点,因此“Ping-Pong”示例的Request+Reply逻辑只适用于1个或2个节点。对于多个节点的计数需要使用不同的方法。具体而言,当节点接收到AM时,它必须推迟发送下个消息,直到控制返回到非应用程序代码部分。理解这个概念非常重要,因为“延迟执行”是许多“如何与活动消息进行X?”问题的解决方案。因此我们使得“Ring”示例具有更多的通用性而不是必要性。
本例有一个处理程序,此时希望能有一个在运行在main()上的代码检索排队信息前打印包括AM负载项消息的Medium AM。需要注意的是当在节点0上执行时,接收的参数在入队前是递增的,以保证环遍历能够最终结束。本例中的设想是以顺序遍历环的方式执行,因此需要将((mynode+1)%nodes)表达式作为第一个参数传递给Enqueue()。但是在实际应用中,下个消息的目的可能是处理程序参数和负载项的某种组合函数,以便能够实现更加复杂的任务。
首先重点分析下代码清单2-5中的main()函数逻辑,首先可以发现这里确定步长计数的逻辑与上节例子中的相同,然后构造了一个非常简单的节点特定消息。而实际的通信开始于节点0向环中的“next”节点发送的首个AM Request,如果运行在单个节点上,则负载“由0发送”且单个参数值为1。通过依次调用gasnet_AMPoll和Dequeue函数,所有节点进入轮询循环。如果没有到达,gasnet_AMPoll将以无阻塞方式执行AM,那么Dequeue函数的返回值可能为0,表示没有在排队的任务。但是当AM处理程序有排队的任务时,将向排队的目的节点发送新的AM Request(带有发送方标记的msg以及排队参数)。每个节点在接收到等于预期的步长计数参数消息后终止循环。此外,还有一些不常见的逻辑操作以防止节点0在完成时发送“额外”消息。
值得注意的是不同节点的输出可以重新排序,没有命令行参数的3个节点运行的输出结果如下所示。