公开(公告)号：US20060277317A1

公开(公告)日：2006-12-07

申请号：US11144412

申请日：2005-06-03

申请人： Wayne Clark ,  Lee Graber ,  Kartik Paramasivam ,  Siddhartha Roy ,  Sanjib Saha ,  Sumitra Sujanani

发明人： Wayne Clark ,  Lee Graber ,  Kartik Paramasivam ,  Siddhartha Roy ,  Sanjib Saha ,  Sumitra Sujanani

IPC分类号： G06F15/16

CPC分类号： H04L47/22 ,  G06Q10/06 ,  H04L47/10 ,  H04L47/25

摘要： Systems and methods for controlling the work load on a distributed system comprising a plurality of stages are provided. The capacity of a present stage is monitored, using either various resources of the present stage or rates of work completion and work receipt of the present stage. Information indicating the capacity of a succeeding stage are obtained and communicated to the present stage. The monitored capacity information of the present stage and the communicated information of the succeeding stage, either alone or in combination, are used to determine if a throttling action is necessary to control the load of work at the present stage. A provided throttling technique inserts an appropriate delay before the present stage to allow the present stage to process an amount of work without saturating the capacity of the present stage. This technique is applied at each stage of the distributed system to control the work load of the overall system by controlling the work load at each stage.

摘要翻译： 提供了用于控制包括多个级的分布式系统上的工作负载的系统和方法。 使用现阶段的各种资源或工作完成率和现阶段工作收到情况监测现阶段的能力。 获得指示后续能力的信息并传达到现阶段。 目前阶段的监控能力信息和后续阶段的通信信息单独或组合用于确定是否需要节流动作来控制现阶段的工作负荷。 提供的节流技术在当前阶段之前插入适当的延迟，以允许当前阶段处理一定量的工作而不使本阶段的容量饱和。 该技术应用于分布式系统的各个阶段，通过控制各阶段的工作负荷来控制整个系统的工作负荷。

公开(公告)号：US08150994B2

公开(公告)日：2012-04-03

申请号：US11144412

申请日：2005-06-03

申请人： Wayne A. Clark ,  Lee B. Graber ,  Kartik Paramasivam ,  Siddhartha Roy ,  Sanjib Saha ,  Sumitra Sujanani

发明人： Wayne A. Clark ,  Lee B. Graber ,  Kartik Paramasivam ,  Siddhartha Roy ,  Sanjib Saha ,  Sumitra Sujanani

IPC分类号： G06F15/16

CPC分类号： H04L47/22 ,  G06Q10/06 ,  H04L47/10 ,  H04L47/25

摘要： Systems and methods for controlling the work load on a distributed system comprising a plurality of stages are provided. The capacity of a present stage is monitored, using either various resources of the present stage or rates of work completion and work receipt of the present stage. Information indicating the capacity of a succeeding stage are obtained and communicated to the present stage. The monitored capacity information of the present stage and the communicated information of the succeeding stage, either alone or in combination, are used to determine if a throttling action is necessary to control the load of work at the present stage. A provided throttling technique inserts an appropriate delay before the present stage to allow the present stage to process an amount of work without saturating the capacity of the present stage. This technique is applied at each stage of the distributed system to control the work load of the overall system by controlling the work load at each stage.

摘要翻译： 提供了用于控制包括多个级的分布式系统上的工作负载的系统和方法。 使用现阶段的各种资源或工作完成率和现阶段工作收到情况监测现阶段的能力。 获得指示后续能力的信息并传达到现阶段。 目前阶段的监控能力信息和后续阶段的通信信息单独或组合用于确定是否需要节流动作来控制现阶段的工作负荷。 提供的节流技术在当前阶段之前插入适当的延迟，以允许当前阶段处理一定量的工作而不使本阶段的容量饱和。 该技术应用于分布式系统的各个阶段，通过控制各阶段的工作负荷来控制整个系统的工作负荷。

公开(公告)号：US20060277538A1

公开(公告)日：2006-12-07

申请号：US11143536

申请日：2005-06-02

申请人： Sanjib Saha ,  Sumitra Sujanani ,  Lee Graber

发明人： Sanjib Saha ,  Sumitra Sujanani ,  Lee Graber

IPC分类号： G06F9/44

CPC分类号： G06F11/1438

摘要： Methods for providing dynamic process recovery that supports recovery of event driven services. The present invention addresses situations where a service-hosting process fails as well as all of the services which were running in that process. To recover from this scenario, the present invention restarts the services a different process from a last know good state. The present invention also provides for situations where a process is shut down in a controlled manner, but the services running within it are still able to drive. Here again, the services are restarted in a secondary process. The recovery modal described here, therefore, advantageously addresses a problem in the design of a distributed event-driven environment.

摘要翻译： 提供支持事件驱动服务恢复的动态过程恢复的方法。 本发明解决了服务承载过程失败的情况以及在该过程中运行的所有服务。 为了从这种情况中恢复，本发明重新启动与最近的知道状态不同的进程的服务。 本发明还提供了以受控的方式关闭进程的情况，但是其中运行的服务仍然能够驱动。 再次，这些服务在次要过程中重新启动。 因此，这里描述的恢复模式有利地解决了分布式事件驱动环境的设计中的问题。

公开(公告)号：US20060274727A1

公开(公告)日：2006-12-07

申请号：US11146644

申请日：2005-06-06

申请人： Eldar Musayev ,  Jean-Emile Elien ,  Kartik Paramasivam ,  Kevin Smith ,  Lee Graber ,  Sanjib Saha ,  Satish Thatte

发明人： Eldar Musayev ,  Jean-Emile Elien ,  Kartik Paramasivam ,  Kevin Smith ,  Lee Graber ,  Sanjib Saha ,  Satish Thatte

IPC分类号： H04L12/66

CPC分类号： H04L67/32

摘要： A transport-neutral in-order delivery in a distributed environment is provided. Typically, in-order delivery guarantees that sequential orders received by a transport engine are sent out in the same order they are received. Such delivery may be forwarded either to another transport engine or to some application. In case there is a failure of delivery of messages in a stream, the messages are either resubmitted, suspended, or moved to backup. A user or administrator can configure the desired action. Additionally, any stream can be manually aborted or a specified port can be unenlisted. Deliverable streams of messages are locked on to a back-end transport engines or applications and dequeued sequentially unless one of the above mentioned failure scenarios occurs.

摘要翻译： 在分布式环境中提供运输中立的按顺序交货。 通常，按顺序传送保证传输引擎接收到的顺序是按照接收到的顺序发出的。 这种传送可以被转发到另一个传输引擎或某些应用。 如果流中的消息传递失败，则消息将被重新提交，暂停或移动到备份。 用户或管理员可以配置所需的操作。 此外，任何流都可以手动中止或指定的端口可以取消登录。 可传递的消息流被锁定到后端传输引擎或应用程序，并且顺序排队，除非出现上述任何一种故障情况之一。

公开(公告)号：US07783742B2

公开(公告)日：2010-08-24

申请号：US11143536

申请日：2005-06-02

申请人： Sanjib Saha ,  Sumitra Sujanani ,  Lee B. Graber

发明人： Sanjib Saha ,  Sumitra Sujanani ,  Lee B. Graber

IPC分类号： G06F15/173 ,  G06F15/16

CPC分类号： G06F11/1438

摘要： Methods for providing dynamic process recovery that supports recovery of event driven services. The present invention addresses situations where a service-hosting process fails as well as all of the services which were running in that process. To recover from this scenario, the present invention restarts the services from a last known good state. The present invention also provides for situations where a process is shut down in a controlled manner, but the services running within it are still able to drive. Here again, the services are restarted in a secondary process. The recovery modal described here, therefore, advantageously addresses a problem in the design of a distributed event-driven environment.

摘要翻译： 提供支持事件驱动服务恢复的动态过程恢复的方法。 本发明解决了服务承载过程失败的情况以及在该过程中运行的所有服务。 为了从这种情况中恢复，本发明从最后一个已知的良好状态重新启动服务。 本发明还提供了以受控的方式关闭进程的情况，但是其中运行的服务仍然能够驱动。 再次，这些服务在次要过程中重新启动。 因此，这里描述的恢复模式有利地解决了分布式事件驱动环境的设计中的问题。

公开(公告)号：US07747894B2

公开(公告)日：2010-06-29

申请号：US11146644

申请日：2005-06-06

申请人： Eldar A. Musayev ,  Jean-Emile Elien ,  Kartik Paramasivam ,  Kevin Bowen Smith ,  Lee B. Graber ,  Sanjib Saha ,  Satish R. Thatte

发明人： Eldar A. Musayev ,  Jean-Emile Elien ,  Kartik Paramasivam ,  Kevin Bowen Smith ,  Lee B. Graber ,  Sanjib Saha ,  Satish R. Thatte

IPC分类号： G06F11/00

CPC分类号： H04L67/32

摘要： A transport-neutral in-order delivery in a distributed environment is provided. Typically, in-order delivery guarantees that sequential orders received by a transport engine are sent out in the same order they are received. Such delivery may be forwarded either to another transport engine or to some application. In case there is a failure of delivery of messages in a stream, the messages are either resubmitted, suspended, or moved to backup. A user or administrator can configure the desired action. Additionally, any stream can be manually aborted or a specified port can be unenlisted. Deliverable streams of messages are locked on to a back-end transport engines or applications and dequeued sequentially unless one of the above mentioned failure scenarios occurs.

摘要翻译： 在分布式环境中提供运输中立的按顺序交货。 通常，按顺序传送保证传输引擎接收到的顺序是按照接收到的顺序发出的。 这种传送可以转发到另一个传输引擎或某些应用。 如果流中的消息传递失败，则消息将被重新提交，暂停或移动到备份。 用户或管理员可以配置所需的操作。 此外，任何流都可以手动中止或指定的端口可以取消登录。 可传递的消息流被锁定到后端传输引擎或应用程序，并且顺序排队，除非发生上述故障情形之一。

公开(公告)号：US08010608B2

公开(公告)日：2011-08-30

申请号：US11146714

申请日：2005-06-07

申请人： Kartik Paramasivam ,  Sanjib Saha ,  Jean-Emile Elien

发明人： Kartik Paramasivam ,  Sanjib Saha ,  Jean-Emile Elien

IPC分类号： G06F15/16 ,  G06F15/173

CPC分类号： G06F9/546 ,  H04L69/40

摘要： The subject invention provides a system and/or a method that facilitates enhancing an adapter utilizing a locking mechanism between a receive location and a process. An interface component can receive a message related to a receive location that is an endpoint. A lock component binds the receive location to the process such that the process exclusively receives the messages from the endpoint at a single instance in real time. Moreover, the lock component can provide a replacement/switching technique, wherein a process that participates in a locking relationship can be switched with another process based at least in part upon the health of the process.

摘要翻译： 本发明提供一种有助于利用接收位置和过程之间的锁定机构来增强适配器的系统和/或方法。 接口组件可以接收与作为端点的接收位置相关的消息。 锁定组件将接收位置绑定到进程，使得该进程实时地在单个实例处从端点单独接收消息。 此外，锁定部件可以提供替换/切换技术，其中参与锁定关系的过程可以至少部分地基于过程的健康而与另一进程切换。

公开(公告)号：US20060277261A1

公开(公告)日：2006-12-07

申请号：US11146714

申请日：2005-06-07

申请人： Kartik Paramasivam ,  Sanjib Saha ,  Jean-Emile Elien

发明人： Kartik Paramasivam ,  Sanjib Saha ,  Jean-Emile Elien

IPC分类号： G06F15/16

CPC分类号： G06F9/546 ,  H04L69/40

摘要： The subject invention provides a system and/or a method that facilitates enhancing an adapter utilizing a locking mechanism between a receive location and a process. An interface component can receive a message related to a receive location that is an endpoint. A lock component binds the receive location to the process such that the process exclusively receives the messages from the endpoint at a single instance in real time. Moreover, the lock component can provide a replacement/switching technique, wherein a process that participates in a locking relationship can be switched with another process based at least in part upon the health of the process.

摘要翻译： 本发明提供一种有助于利用接收位置和过程之间的锁定机构来增强适配器的系统和/或方法。 接口组件可以接收与作为端点的接收位置相关的消息。 锁定组件将接收位置绑定到进程，使得该进程实时地在单个实例处从端点单独接收消息。 此外，锁定部件可以提供替换/切换技术，其中参与锁定关系的过程可以至少部分地基于过程的健康而与另一进程切换。

公开(公告)号：US08516498B2

公开(公告)日：2013-08-20

申请号：US10698762

申请日：2003-10-31

申请人： Bimal Mehta ,  Paul Maybee ,  Lee Graber ,  Alexander Dadjomov ,  Jean-Emile Elien ,  Eldar Azerovich Musayev ,  Johannes Klein ,  Sanjib Saha ,  Kevin Bowen Smith

发明人： Bimal Mehta ,  Paul Maybee ,  Lee Graber ,  Alexander Dadjomov ,  Jean-Emile Elien ,  Eldar Azerovich Musayev ,  Johannes Klein ,  Sanjib Saha ,  Kevin Bowen Smith

IPC分类号： G06F9/44 ,  G06F11/00

CPC分类号： G06Q10/107 ,  G06Q10/087

摘要： A system and method of processing a message in an asynchronous architecture is provided. In the method, a determination is made that a response to a message sent by an instance of software code is to be received, where the response indicates whether the message succeeded or failed. Another determination is made as to whether the response has been received. If the response has not been received, the instance of the software code is stored in memory, thereby suspending the instance. The response is received, the instance resumed and the response is processed.

摘要翻译： 提供了一种在异步架构中处理消息的系统和方法。 在该方法中，确定将接收对由软件代码的实例发送的消息的响应，其中响应指示消息是成功还是失败。 另外决定是否收到了答复。 如果没有收到响应，则软件代码的实例存储在内存中，从而挂起实例。 收到响应后，实例恢复并响应处理。

公开(公告)号：US20080276238A1

公开(公告)日：2008-11-06

申请号：US12172984

申请日：2008-07-14

申请人： Yossi Levanoni ,  Sanjib Saha ,  Bimal Kumar Mehta ,  Paul Maybee ,  Lee Graber ,  Balasubramanian Sriram ,  Eldar Azerovich Musayev ,  Kevin Bowen Smith

发明人： Yossi Levanoni ,  Sanjib Saha ,  Bimal Kumar Mehta ,  Paul Maybee ,  Lee Graber ,  Balasubramanian Sriram ,  Eldar Azerovich Musayev ,  Kevin Bowen Smith

IPC分类号： G06F9/44

CPC分类号： G06F9/4881 ,  G06F9/5083

摘要： A system and method of using metrics to control throttling and swapping in a message processing system is provided. A workload status of a message processing system is determined, and the system polls for a new message according to the workload status. The message processing system identifies a blocked instance and calculates an expected idle time for the blocked instance. The system dehydrates the blocked instance if the expected idle time exceeds a predetermined threshold.

摘要翻译： 提供了一种使用度量来控制消息处理系统中的调节和交换的系统和方法。 确定消息处理系统的工作负载状态，并且系统根据工作负载状态轮询新消息。 消息处理系统识别被阻止的实例并计算被阻止的实例的预期空闲时间。 如果预期的空闲时间超过预定的阈值，系统将阻塞的实例脱水。