公开(公告)号：US09471392B2

公开(公告)日：2016-10-18

申请号：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分类号： G06F15/16 ,  G06F9/50

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.

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

公开(公告)号：US09128180B2

公开(公告)日：2015-09-08

申请号：US13423109

申请日：2012-03-16

申请人： Sanjib Saha ,  Gang Zhao ,  Ashish Gadre

发明人： Sanjib Saha ,  Gang Zhao ,  Ashish Gadre

IPC分类号： H04W24/00 ,  G01S19/34 ,  H04W52/02 ,  G06F1/32

CPC分类号： G01S19/34 ,  G06F1/3206 ,  G06F1/3293 ,  H04W52/0254 ,  H04W52/0293 ,  Y02D10/122 ,  Y02D70/00 ,  Y02D70/142 ,  Y02D70/144 ,  Y02D70/164

摘要： Techniques and tools for reducing power consumption of computing devices (e.g., mobile devices such as mobile phones and tablet computers) that perform position tracking operations are described. In described examples, a low-power processor calculates (e.g., in real time) position information (e.g., GPS position fixes) based on information received from a positioning system (e.g., GPS) and stores the position information for later use in a buffer associated with the low-power processor (e.g., in storage on the low-power processor). Described examples allow position information to be calculated in real time and stored while the device is in a low-power state, and can be used with location-based applications that do not require position information to be delivered to the application in real time.

摘要翻译： 描述了用于降低执行位置跟踪操作的计算设备（例如，移动电话和平板计算机的移动设备）的功耗的技术和工具。 在所描述的示例中，低功率处理器基于从定位系统（例如，GPS）接收的信息来计算（例如，实时）位置信息（例如，GPS位置定位）），并将该位置信息存储在缓冲器中 与低功率处理器相关联（例如，在低功耗处理器上的存储器中）。 所描述的示例允许在设备处于低功率状态时实时计算并存储位置信息，并且可以与不需要位置信息的基于位置的应用程序一起实时地将其应用于应用程序。

公开(公告)号：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.

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

公开(公告)号：US20080167925A1

公开(公告)日：2008-07-10

申请号：US12054569

申请日：2008-03-25

申请人： Bimal Mehta ,  Johannes Klein ,  Lee Graber ,  Paul Maybee ,  Sriram Balasubramanian ,  Sanjib Saha ,  Satish R. Thatte ,  Paul F. Ringseth

发明人： Bimal Mehta ,  Johannes Klein ,  Lee Graber ,  Paul Maybee ,  Sriram Balasubramanian ,  Sanjib Saha ,  Satish R. Thatte ,  Paul F. Ringseth

IPC分类号： G06Q10/00

CPC分类号： G06F9/54 ,  G06F2209/542

摘要： An XLANG/s compiler detects convoy scenarios during compilation and generates runtime directives to correctly correlate incoming messages with business process instances. A convoy scenario, present in event driven processes, is defined by a correlation set initialized during a receive operation which is provided to a subsequent receive operation. The compiler detects those convoy scenarios by analyzing the control and dataflow of a XLANG/s program. Three convoy patterns are distinguished: (1) activation convoys, (2) uniform sequential convoys, and (3) non-uniform sequential convoys. XLANG/s allows declarative descriptions of convoy scenarios without requiring an understanding of the low-level details supporting their correct execution. Convoy scenarios are processed by statically analyzing a written workflow application to deduce the nature and type of convoy scenarios used by the application. Information is extracted at compile time to support the runtime infrastructure. The runtime infrastructure is tightly integrated with the underlying correlation and subscription evaluation framework.

摘要翻译： XLANG / s编译器在编译期间检测车队场景，并生成运行时指令，将传入的消息与业务流程实例正确关联。 存在于事件驱动过程中的车队场景由在提供给后续接收操作的接收操作期间初始化的相关集定义。 编译器通过分析XLANG / s程序的控制和数据流来检测这些车队场景。 三个车队模式有区别：（1）活动车队，（2）统一的顺序车队，（3）不均匀的顺序车队。 XLANG / s允许对车队场景的声明性描述，而不需要了解支持其正确执行的低级细节。 通过静态分析书面工作流应用程序来演绎应用程序使用的车队场景的性质和类型来处理方便情景。 在编译时提取信息以支持运行时基础设施。 运行时基础架构与底层的相关和订阅评估框架紧密集成。

公开(公告)号：US20060277319A1

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

申请号：US11144102

申请日：2005-06-03

申请人： Jean-Emile Elien ,  Lee Graber ,  Sanjib Saha

发明人： Jean-Emile Elien ,  Lee Graber ,  Sanjib Saha

IPC分类号： G06F15/173

CPC分类号： H04L67/26 ,  H04L51/00 ,  H04L51/26

摘要： Systems and methods for reducing the latency incurred during the publication of a message in a message publication system are provided. In a message publication system wherein the publishing component and the receiving component are located within the same processing space, several of the latency components that are usually unavoidably incurred may be eliminated. In such a system, the messaging queue is not used as a medium between the two components but is instead used as a secondary back-up storage. This results in the elimination of one latency component as the message is directly published from the publishing component to the receiving component. Further time reductions or optimizations occur when the durability, or reliability, of the message publication is not a concern and the messaging queue can be completely disregarded. Yet another optimization occurs when the identity of the subscriber is known in advance by the publisher.

摘要翻译： 提供了用于减少在消息发布系统中发布消息期间发生的延迟的系统和方法。 在其中发布组件和接收组件位于相同处理空间内的消息发布系统中，可以消除通常不可避免地引起的几个等待时间组件。 在这样的系统中，消息队列不用作两个组件之间的介质，而是用作辅助备用存储。 这导致消息从发布组件直接发布到接收组件时消除一个延迟组件。 当消息出版物的耐久性或可靠性不是关心且消息队列可以被完全忽视时，会发生进一步的时间缩减或优化。 当发布者预先知道用户的身份时，会发生另一个优化。

公开(公告)号：US07113942B2

公开(公告)日：2006-09-26

申请号：US10609283

申请日：2003-06-27

申请人： Yossi Levanoni ,  Wei-Lun Lo ,  Sanjib Saha ,  Paul Maybee ,  Bimal Mehta ,  Lee Graber ,  Anandhi Somasekaran ,  Akash Sagar ,  Balinder Malhi ,  Allen Zhang ,  Siunie Sutjahjo

发明人： Yossi Levanoni ,  Wei-Lun Lo ,  Sanjib Saha ,  Paul Maybee ,  Bimal Mehta ,  Lee Graber ,  Anandhi Somasekaran ,  Akash Sagar ,  Balinder Malhi ,  Allen Zhang ,  Siunie Sutjahjo

IPC分类号： G06F7/00

CPC分类号： G06F17/30929 ,  G06F17/30902 ,  G06F17/30938 ,  Y10S707/99933

摘要： Large messages in the form of hierarchically structured documents are processed in a streaming fashion using the ultimate consumer read requests as the driving force for the processing. The messages are partitioned into fixed length segments. The segments are processed in pipeline fashion. This processing chain includes simulating random access of hierarchical documents using stream transformations, mapping streams to a transport's native capabilities, composing streams into chains and using pipeline processing on the chains, staging fragments into a database and routing messages when complete messages have been formed, and providing tools to allow the end user to inspect partial messages.

公开(公告)号：US20050015776A1

公开(公告)日：2005-01-20

申请号：US10452961

申请日：2003-06-02

申请人： Bimal Mehta ,  Johannes Klein ,  Lee Graber ,  Paul Maybee ,  Sriram Balasubramanian ,  Sanjib Saha ,  Satish Thatte ,  Paul Ringseth

发明人： Bimal Mehta ,  Johannes Klein ,  Lee Graber ,  Paul Maybee ,  Sriram Balasubramanian ,  Sanjib Saha ,  Satish Thatte ,  Paul Ringseth

IPC分类号： G06F3/00 ,  G06F9/46

CPC分类号： G06F9/54 ,  G06F2209/542

摘要： An XLANG/s compiler detects convoy scenarios during compilation and generates runtime directives to correctly correlate incoming messages with business process instances. A convoy scenario, present in event driven processes, is defined by a correlation set initialized during a receive operation which is provided to a subsequent receive operation. The compiler detects those convoy scenarios by analyzing the control and dataflow of a XLANG/s program. Three convoy patterns are distinguished: (1) activation convoys, (2) uniform sequential convoys, and (3) non-uniform sequential convoys. XLANG/s allows declarative descriptions of convoy scenarios without requiring an understanding of the low-level details supporting their correct execution. Convoy scenarios are processed by statically analyzing a written workflow application to deduce the nature and type of convoy scenarios used by the application. Information is extracted at compile time to support the runtime infrastructure. The runtime infrastructure is tightly integrated with the underlying correlation and subscription evaluation framework.

摘要翻译： XLANG / s编译器在编译期间检测车队场景，并生成运行时指令，将传入的消息与业务流程实例正确关联。 存在于事件驱动过程中的车队场景由在提供给后续接收操作的接收操作期间初始化的相关集定义。 编译器通过分析XLANG / s程序的控制和数据流来检测这些车队场景。 三个车队模式有区别：（1）活动车队，（2）统一的顺序车队，（3）不均匀的顺序车队。 XLANG / s允许对车队场景的声明性描述，而不需要了解支持其正确执行的低级细节。 通过静态分析书面工作流应用程序来演绎应用程序使用的车队场景的性质和类型来处理方便情景。 在编译时提取信息以支持运行时基础设施。 运行时基础架构与底层的相关和订阅评估框架紧密集成。

公开(公告)号：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.

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

公开(公告)号：US08443379B2

公开(公告)日：2013-05-14

申请号：US12141081

申请日：2008-06-18

申请人： Affan Arshad Dar ,  Sanjib Saha

发明人： Affan Arshad Dar ,  Sanjib Saha

IPC分类号： G06F3/00 ,  G06F9/44 ,  G06F9/46 ,  G06F13/00

CPC分类号： G06F9/526 ,  G06F9/546

摘要： A queue management system may store a queue of messages in a main queue. When a message is processed by an application, the message may be moved to a subqueue. In the subqueue, the message may be locked from other applications. After processing the message, the application may delete the message from the subqueue and complete the action required. If the application fails to respond in a timely manner, the message may be moved from the subqueue to the main queue and released for another application to service the message. If the application responds after the time out period, a fault may occur when the application attempts to delete the message from the subqueue. Such an arrangement allows a “peek and lock” functionality to be implemented using a subqueue.

摘要翻译： 队列管理系统可以将消息队列存储在主队列中。 当应用程序处理消息时，消息可能会移动到子队列。 在子队列中，消息可能与其他应用程序锁定。 处理消息后，应用程序可能会从子队列中删除该消息，并完成所需的操作。 如果应用程序无法及时响应，则可以将消息从子队列移动到主队列，并释放给另一个应用程序来服务消息。 如果应用程序在超时时间后响应，则当应用程序尝试从子队列中删除该消息时，可能会发生故障。 这种安排允许使用子队列实现“窥视和锁定”功能。

公开(公告)号：US08135025B2

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

申请号：US12477606

申请日：2009-06-03

申请人： Sanjib Saha ,  Affan Arshad Dar ,  Xin Chen ,  Manohar Bangalore Puttaswamaiah

发明人： Sanjib Saha ,  Affan Arshad Dar ,  Xin Chen ,  Manohar Bangalore Puttaswamaiah

IPC分类号： H04L12/40

CPC分类号： H04L61/2507 ,  H04L12/1895 ,  H04L12/56 ,  H04L29/12301 ,  H04L29/12811 ,  H04L41/12 ,  H04L51/043 ,  H04L51/28 ,  H04L61/2076 ,  H04L61/6009

摘要： Embodiments are directed to promptly reestablishing communication between nodes in a dynamic computer network and dynamically maintaining an address list in an unstable network. A computer system sends a message to other message queuing nodes in a network, where each node in the message queuing network includes a corresponding persistent unique global identifier. The computer system maintains a list of unique global identifiers and the current network addresses of those network nodes from which the message queuing node has received a message or to which the message queuing node has sent a message. The computer system goes offline for a period of time and upon coming back online, sends an announcement message to each node maintained in the list indicating that the message queuing node is ready for communication in the message queuing network, where each message includes the destination node's globally unique identifier and the node's current network address.

摘要翻译： 实施例旨在及时重新建立动态计算机网络中节点之间的通信，并动态地维护不稳定网络中的地址列表。 计算机系统向网络中的其他消息队列节点发送消息，其中消息队列网络中的每个节点包括对应的持久唯一全局标识符。 计算机系统维护唯一全局标识符的列表以及消息队列节点已经从其接收到消息或消息队列节点已向其发送消息的那些网络节点的当前网络地址。 计算机系统脱机一段时间，并且在返回在线时，向列表中维护的每个节点发送通知消息，指示消息队列节点准备好在消息队列网络中进行通信，其中每个消息包括目的地节点 全局唯一标识符和节点的当前网络地址。