公开(公告)号：CN101089819A

公开(公告)日：2007-12-19

申请号：CN200710089349.7

申请日：2007-03-23

Applicant: 国际商业机器公司

Inventor： 安舒尔·塞赫加尔 ,  丽萨·阿米尼 ,  杰雷米·I.·西尔伯 ,  奥利维尔·沃斯彻

IPC: G06F9/46 ,  H04L29/08 ,  H04L12/56

CPC classification number: H04L29/06027 ,  H04L47/10 ,  H04L47/125 ,  H04L47/30 ,  H04L65/80

Abstract: 说明了用于动态地稳定流处理系统的方法、上游处理节点以及计算机可读介质。该方法包括接收至少一个计算资源分配目标。进一步包括确定至少一个上游处理单元的输入数据流速率改变。响应所述上游处理单元的输入速率改变，动态地分配计算资源给上游处理单元。在所述上游处理单元和至少一个下游处理单元之间动态地控制数据流。

公开(公告)号：CN101089818A

公开(公告)日：2007-12-19

申请号：CN200710089342.5

申请日：2007-03-23

Applicant: 国际商业机器公司

Inventor： 安舒尔·塞赫加尔 ,  丽萨·阿米尼 ,  杰雷米·I.·西尔伯 ,  奥利维尔·沃斯彻 ,  朱尔·L.·沃尔夫

IPC: G06F9/46 ,  H04L29/08 ,  H04L12/56

CPC classification number: H04L47/10 ,  H04L47/125 ,  H04L49/90 ,  H04L65/601

Abstract: 说明了用于处理数据包的方法、上游处理节点以及计算机可读介质。该方法包括接收至少一个对计算资源的分配。在上游处理节点中的一个或多个上游处理单元上接收至少一个数据包。该方法还包括确定所述上游处理单元的至少一个输出队列是否包括用于对所述数据包进行处理的可用空间。响应输出队列包括可用空间对所述数据包进行处理，以形成结果数据包。该方法进一步包括确定多个下游处理单元中的至少一个下游处理单元的输入队列是否包括用于接收所述结果数据包的可用空间。响应所述确定结果，将所述结果数据包从所述上游处理单元传输到所述下游处理单元。