OUT OF ORDER DURABLE MESSAGE PROCESSING
    1.
    发明申请
    OUT OF ORDER DURABLE MESSAGE PROCESSING 有权
    没有订单耐久消息处理

    公开(公告)号:US20110153713A1

    公开(公告)日:2011-06-23

    申请号:US12645322

    申请日:2009-12-22

    IPC分类号: G06F15/16

    CPC分类号: G06F9/546

    摘要: The dispatching of messages from an incoming message pool to service instance(s). Message are received non-destructively and exclusively from the incoming message pool. If a particular service instance receives a message out of order, the processing of the message is deferred without releasing the exclusivity in the incoming message queue. Thus, the target service instance may continue to process one or more other messages until the target service instance is ready to process one or more deferred messages. In this way, messages may be pulled from the incoming message queue for dispatch to service instance(s), while maintaining correct order of processing, even if messages do not arrive into the incoming message queue in the correct order.

    摘要翻译: 将消息从传入消息池分派到服务实例。 消息被非破坏性地从接收到的消息池接收。 如果特定的服务实例接收到不正确的消息,则消息的处理被推迟而不释放传入消息队列中的排他性。 因此,目标服务实例可以继续处理一个或多个其他消息,直到目标服务实例准备好处理一个或多个延迟消息。 以这种方式,即使消息没有以正确的顺序到达进入的消息队列,也可以在保持正确的处理顺序的同时,将消息从传入的消息队列中拉出以进行调度到服务实例。

    Out of order durable message processing
    2.
    发明授权
    Out of order durable message processing 有权
    乱序耐用消息处理

    公开(公告)号:US08375095B2

    公开(公告)日:2013-02-12

    申请号:US12645322

    申请日:2009-12-22

    IPC分类号: G06F15/16

    CPC分类号: G06F9/546

    摘要: The dispatching of messages from an incoming message pool to service instance(s). Message are received non-destructively and exclusively from the incoming message pool. If a particular service instance receives a message out of order, the processing of the message is deferred without releasing the exclusivity in the incoming message queue. Thus, the target service instance may continue to process one or more other messages until the target service instance is ready to process one or more deferred messages. In this way, messages may be pulled from the incoming message queue for dispatch to service instance(s), while maintaining correct order of processing, even if messages do not arrive into the incoming message queue in the correct order.

    摘要翻译: 将消息从传入消息池分派到服务实例。 消息被非破坏性地从接收到的消息池接收。 如果特定的服务实例接收到不正确的消息,则消息的处理被推迟而不释放传入消息队列中的排他性。 因此,目标服务实例可以继续处理一个或多个其他消息,直到目标服务实例准备好处理一个或多个延迟消息。 以这种方式,即使消息没有以正确的顺序到达进入的消息队列,也可以在保持正确的处理顺序的同时,将消息从传入的消息队列中拉出以进行调度到服务实例。

    INFERENCE OF CONTRACT USING DECLARATIVE PROGRAM DEFINITION
    3.
    发明申请
    INFERENCE OF CONTRACT USING DECLARATIVE PROGRAM DEFINITION 有权
    使用声明程序定义的合同约定

    公开(公告)号:US20110078509A1

    公开(公告)日:2011-03-31

    申请号:US12567610

    申请日:2009-09-25

    IPC分类号: G06F11/07 G06F11/00

    CPC分类号: G06F11/0766 G06F11/0709

    摘要: A declarative program definition. The definition is analyzed to produce an application contract that describes semantics for sending and receiving application messages during the successful execution of operations by the program. In addition, this analysis may also generate local behaviors associated with the local execution of the program. Alternatively or in addition, the analysis may infer secondary contracts regarding the sending and receiving of application messages, even though the full details of the secondary contracts are not present in the declarative program definition. For instance, the secondary contracts might include error contracts or consistency contracts.

    摘要翻译: 声明式程序定义。 分析定义以产生一个应用程序合同,该应用程序合同描述在程序成功执行操作期间发送和接收应用程序消息的语义。 此外,此分析还可能产生与本地程序执行相关的本地行为。 或者或另外,分析可以推断关于应用消息的发送和接收的次级合同,即使次要合同的全部细节不存在于声明性程序定义中。 例如,次级合同可能包括错误合同或一致性合同。

    Inference of contract using declarative program definition
    4.
    发明授权
    Inference of contract using declarative program definition 有权
    使用声明式程序定义推断合同

    公开(公告)号:US08074117B2

    公开(公告)日:2011-12-06

    申请号:US12567610

    申请日:2009-09-25

    IPC分类号: G06F11/00

    CPC分类号: G06F11/0766 G06F11/0709

    摘要: A declarative program definition. The definition is analyzed to produce an application contract that describes semantics for sending and receiving application messages during the successful execution of operations by the program. In addition, this analysis may also generate local behaviors associated with the local execution of the program. Alternatively or in addition, the analysis may infer secondary contracts regarding the sending and receiving of application messages, even though the full details of the secondary contracts are not present in the declarative program definition. For instance, the secondary contracts might include error contracts or consistency contracts.

    摘要翻译: 声明式程序定义。 分析定义以产生一个应用程序合同,该应用程序合同描述了在程序成功执行操作期间发送和接收应用程序消息的语义。 此外,此分析还可能产生与本地程序执行相关的本地行为。 或者或另外,分析可以推断关于应用消息的发送和接收的次级合同,即使次要合同的全部细节不存在于声明性程序定义中。 例如,次级合同可能包括错误合同或一致性合同。

    PROBABILISTIC MESH ROUTING
    5.
    发明申请
    PROBABILISTIC MESH ROUTING 有权
    概况网路路由

    公开(公告)号:US20100057933A1

    公开(公告)日:2010-03-04

    申请号:US12203826

    申请日:2008-09-03

    IPC分类号: G06F15/173

    摘要: Routing messages using unreliable routing data. A method includes receiving a message from a computer readable communication medium. Characteristic properties of the message are calculated so as to determine state requirements for a service instance at a service for processing of the message. An attempt is made to acquire an appropriate service instance that satisfies the state requirements for processing the message. A determination is made that attempting to acquire an appropriate service instance that satisfies the state requirements for processing the message is not successful at acquiring an appropriate service instance. As a result, the message is redirected using an unreliable local cache of routing information and without coordination between processing nodes.

    摘要翻译: 使用不可靠的路由数据路由消息。 一种方法包括从计算机可读通信介质接收消息。 计算消息的特征属性,以便确定服务处理消息的服务实例的状态要求。 尝试获取满足处理消息的状态要求的适当服务实例。 确定在获取适当的服务实例时尝试获取满足处理该消息的状态要求的适当服务实例是不成功的。 结果,使用路由信息的不可靠本地缓存重定向消息,并且在处理节点之间没有协调。

    Query-oriented message characterization
    6.
    发明授权
    Query-oriented message characterization 有权
    面向查询的消息表征

    公开(公告)号:US08473455B2

    公开(公告)日:2013-06-25

    申请号:US12203790

    申请日:2008-09-03

    IPC分类号: G06F17/00

    CPC分类号: G06F17/30442 G06Q10/107

    摘要: Messages are processed based on a characteristic derived from information in messages, metadata about messages, or other information external to messages. Values for one or more pieces of information are received. At least one of the values for one or more pieces of information is associated with a first message. Queries are received. The queries specify one or more of the pieces of information. At least a portion of the plurality of values for the one or more pieces of information is processed in conjunction with the one or more queries to create one or more normalized characteristics for the first message. The one or more normalized characteristics for the first message are in a same format irrespective of the format of the pieces of information. The first message, and/or other messages, is processed based on at least one of the one or more normalized characteristics.

    摘要翻译: 基于从消息中的信息,关于消息的元数据或消息外部的其他信息导出的特征来处理消息。 收到一条或多条信息的值。 一个或多个信息的值中的至少一个与第一消息相关联。 收到查询。 这些查询指定了一条或多条信息。 结合该一个或多个查询来处理用于一条或多条信息的多个值中的至少一部分,以便为第一消息创建一个或多个归一化特征。 第一消息的一个或多个归一化特征是与相同信息格式无关的格式。 基于一个或多个归一化特征中的至少一个来处理第一消息和/或其他消息。

    Probabilistic mesh routing
    7.
    发明授权
    Probabilistic mesh routing 有权
    概率网格路由

    公开(公告)号:US08099498B2

    公开(公告)日:2012-01-17

    申请号:US12203826

    申请日:2008-09-03

    IPC分类号: G06F15/173

    摘要: Routing messages using unreliable routing data. A method includes receiving a message from a computer readable communication medium. Characteristic properties of the message are calculated so as to determine state requirements for a service instance at a service for processing of the message. An attempt is made to acquire an appropriate service instance that satisfies the state requirements for processing the message. A determination is made that attempting to acquire an appropriate service instance that satisfies the state requirements for processing the message is not successful at acquiring an appropriate service instance. As a result, the message is redirected using an unreliable local cache of routing information and without coordination between processing nodes.

    摘要翻译: 使用不可靠的路由数据路由消息。 一种方法包括从计算机可读通信介质接收消息。 计算消息的特征属性,以便确定服务处理消息的服务实例的状态要求。 尝试获取满足处理消息的状态要求的适当服务实例。 确定在获取适当的服务实例时尝试获取满足处理该消息的状态要求的适当服务实例是不成功的。 结果,使用路由信息的不可靠本地缓存重定向消息,并且在处理节点之间没有协调。

    QUERY-ORIENTED MESSAGE CHARACTERIZATION
    8.
    发明申请
    QUERY-ORIENTED MESSAGE CHARACTERIZATION 有权
    基于查询的消息特征

    公开(公告)号:US20100057707A1

    公开(公告)日:2010-03-04

    申请号:US12203790

    申请日:2008-09-03

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30442 G06Q10/107

    摘要: Processing messages. Messages are processed based on a characteristic derived from information in messages, metadata about messages, or other information external to messages. Values for one or more pieces of information are received. At least one of the values for one or more pieces of information is associated with a first message. Queries are received. The queries specify one or more of the pieces of information. At least a portion of the plurality of values for the one or more pieces of information is processed in conjunction with the one or more queries to create one or more normalized characteristics for the first message. The one or more normalized characteristics for the first message are in a same format irrespective of the format of the pieces of information. The first message, and/or other messages, is processed based on at least one of the one or more normalized characteristics.

    摘要翻译: 处理邮件 基于从消息中的信息,关于消息的元数据或消息外部的其他信息导出的特征来处理消息。 收到一条或多条信息的值。 一个或多个信息的值中的至少一个与第一消息相关联。 收到查询。 这些查询指定了一条或多条信息。 结合该一个或多个查询来处理用于一条或多条信息的多个值中的至少一部分,以便为第一消息创建一个或多个归一化特征。 第一消息的一个或多个归一化特征是与相同信息格式无关的格式。 基于一个或多个归一化特征中的至少一个来处理第一消息和/或其他消息。

    Message Exchange Pattern Rendezvous Abstraction
    9.
    发明申请
    Message Exchange Pattern Rendezvous Abstraction 有权
    消息交换模式汇总抽象

    公开(公告)号:US20100036859A1

    公开(公告)日:2010-02-11

    申请号:US12189020

    申请日:2008-08-08

    IPC分类号: G06F17/30

    CPC分类号: G06F8/70 G06F17/30

    摘要: A rendezvous abstraction that is used to correlate messages within message exchange. The rendezvous abstraction may be instantiated to correlate messages regardless of the type of message exchange pattern, and regardless of the underlying protocols used to communication message. Messages exchanges of primitive protocols are modeled as unilateral message exchanges. The rendezvous abstraction is used to correlate messages of the unilateral message exchange, and serves as an abstraction that is used to represented the rendezvous point where the message of the message exchange pattern are handled. Accordingly, instead of focusing on the protocol-specific mechanisms for correlation, if even available, the application author may simply work with a standard rendezvous abstraction.

    摘要翻译: 用于在消息交换中关联消息的会合抽象。 无论消息交换模式的类型如何,并且无论用于通信消息的底层协议如何,都可以实例化会合抽象以关联消息。 原始协议的消息交换被建模为单向消息交换。 会合抽象用于将单向消息交换的消息相关联,并且用作用于表示消息交换模式的消息被处理的会合点的抽象。 因此,不是专注于协议特定的相关机制,如果甚至可用,应用程序作者可以简单地使用标准会合抽象。

    Dispatch mechanism for coordinating application and communication medium state
    10.
    发明授权
    Dispatch mechanism for coordinating application and communication medium state 有权
    协调应用和通信媒体状态的调度机制

    公开(公告)号:US08719841B2

    公开(公告)日:2014-05-06

    申请号:US12605236

    申请日:2009-10-23

    IPC分类号: G06F9/44 G06F17/30 G06F15/16

    CPC分类号: G06F9/546

    摘要: The present invention extends to methods, systems, and computer program products for coordinating application state and communication medium state. Embodiments of the invention provide mechanisms by which a dispatcher can enable application code to coordinate changes in application state with the consumption of messages from a communication medium. The coordination can be automatic where the dispatcher performs the coordination, or manual, where the coordination is performed more expressly by application code. Embodiments also include mechanisms by which applications targeting an execution (e.g., continuation based) runtime may compose alternative state transitions in the application with a peek lock protocol.

    摘要翻译: 本发明扩展到用于协调应用状态和通信媒体状态的方法,系统和计算机程序产品。 本发明的实施例提供了一种机制,通过该机制,调度员可以使得应用代码能够协调来自通信介质的消息消耗的应用状态的改变。 协调可以是自动调度员执行协调或手动,协调由应用代码更明确地执行。 实施例还包括针对执行(例如,基于连续的)运行时间的应用程序可以使用窥视锁协议来组合应用中的备选状态转换的机制。