Interprocess communication mechanism
    1.
    发明授权
    Interprocess communication mechanism 失效
    进程间通信机制

    公开(公告)号:US06792604B1

    公开(公告)日:2004-09-14

    申请号:US09676994

    申请日:2000-09-29

    IPC分类号: G06F946

    CPC分类号: G06F9/524 G06F9/546

    摘要: Provided are a method, computer program product and data processing apparatus for recovery from interprocess communication failures, the method comprising: in response to an initiator process requesting interprocess communication (IPC) with a responder process via an IPC link, recognizing if the initiator process does not have the expected write control of the IPC link and setting an indicator. A process other than the initiator process checks the indicator (such as after a timeout, or periodically) and, if the indicator has been set, notifies the initiator process to take control. This method avoids potential stalemate situations in which neither the initiator nor the responder process can take control, without reliance on mutex locks for every exchange of data and control.

    摘要翻译: 提供了一种用于从进程间通信故障中恢复的方法,计算机程序产品和数据处理装置,所述方法包括:响应于通过IPC链路与响应者进程请求进程间通信(IPC)的发起者进程,识别发起者进程是否 没有IPC链接的预期写入控制和设置指标。 发起者进程之外的过程检查指示符(例如超时或周期性)之后,如果指示符已经设置,则通知发起者进程进行控制。 这种方法避免了潜在的僵持状态,既不要求发起者或响应者进程都可以控制,而不依赖互斥锁来进行数据和控制。

    Persistent messaging in a transaction processing environment
    2.
    发明授权
    Persistent messaging in a transaction processing environment 有权
    在事务处理环境中的持久消息传递

    公开(公告)号:US07240349B2

    公开(公告)日:2007-07-03

    申请号:US10324673

    申请日:2002-12-20

    IPC分类号: G06F9/46

    CPC分类号: G06F9/546 G06F9/466

    摘要: A method and computer program product is provided for sending a persistent message in a transaction-enabled messaging and queuing system. A message queue manager is responsible for transferring messages from a sender program to a receiving program via a message queue. A message is sent from the sender program to the message queue manager. The message is defined to permit the message queue manager to select whether to treat the message transactionally or non-transactionally.

    摘要翻译: 提供了一种方法和计算机程序产品,用于在启用事务的消息和排队系统中发送持久消息。 消息队列管理器负责通过消息队列将消息从发送者程序传送到接收程序。 从发送程序发送消息到消息队列管理器。 该消息被定义为允许消息队列管理器选择是事务处理还是非事务处理消息。

    Controlling access to a destination in a data processing network
    3.
    发明授权
    Controlling access to a destination in a data processing network 有权
    控制访问数据处理网络中的目的地

    公开(公告)号:US08355401B2

    公开(公告)日:2013-01-15

    申请号:US13196199

    申请日:2011-08-02

    IPC分类号: H04L12/28

    摘要: Access to a device is controlled in a data processing network by receiving a first request from a client to connect to a device where the device is limited to a fixed number of client connections and connecting the client to an available client connection of the device if the fixed number of client connections on the device would not be exceeded by connecting the client. Access is further controlled by testing liveness of a current client connection on the device if the fixed number of client connections on the device would be exceeded by connecting the client and dropping the current client connection if the liveness testing indicates that the current client connection is not live.

    摘要翻译: 通过从客户端接收到连接到设备被限制到固定数量的客户端连接并将客户机连接到设备的可用客户端连接的设备的数据处理网络中来控制对设备的访问,如果 连接客户端不会超过设备上固定数量的客户端连接。 如果活动测试表明当前客户端连接不是,通过连接客户端并删除当前客户端连接来超过设备上的客户端连接的固定数量,则可以通过测试设备上当前客户端连接的活动来进一步控制访问。 生活。

    Mechanism for delivering messages to competing consumers in a point-to-point system
    4.
    发明授权
    Mechanism for delivering messages to competing consumers in a point-to-point system 失效
    在点对点系统中向竞争消费者传递消息的机制

    公开(公告)号:US07525964B2

    公开(公告)日:2009-04-28

    申请号:US10980034

    申请日:2004-11-03

    IPC分类号: H04L12/24

    摘要: A method, system, and computer program for delivering messages and data to competing consumers. One aspect of the invention includes a message delivery system including a destination messaging engine, one or more receiver messaging engines, and a message pool. The destination messaging engine is configured to distribute data from one or more producers. The receiver messaging engines are configured to request data from the destination messaging engine and transmit the data to one or more consumers. The message pool is configured to store data from the producers, with the destination messaging engine arbitrating data in the message pool among the receiver messaging engines.

    摘要翻译: 用于将消息和数据传递给竞争消费者的方法,系统和计算机程序。 本发明的一个方面包括消息传递系统,其包括目的地消息收发引擎,一个或多个接收者消息传递引擎和消息池。 目的地消息传递引擎被配置为从一个或多个生产者分发数据。 接收器消息传递引擎被配置为从目的地消息收发引擎请求数据并将数据发送到一个或多个消费者。 消息池被配置为存储来自生产者的数据,目的地消息收发引擎在接收器消息传递引擎之间对消息池中的数据进行仲裁。

    Method of routing messages to multiple consumers
    5.
    发明授权
    Method of routing messages to multiple consumers 失效
    将消息路由到多个消费者的方法

    公开(公告)号:US08180823B2

    公开(公告)日:2012-05-15

    申请号:US12198939

    申请日:2008-08-27

    IPC分类号: G06F15/16

    CPC分类号: G06Q10/00 G06Q30/00

    摘要: A method of routing messages to multiple consumers comprises determining a probability function defining message classification probabilities for each of a plurality of consumer sets, receiving a plurality of messages, classifying each message, storing each message in a queue, receiving notification of a consumer available to process a message, ascertaining the consumer set to which the available consumer belongs, accessing the probabilities for the ascertained consumer set, selecting a message classification according to the accessed probabilities, and transmitting a message, of the selected classification, to the available consumer.

    摘要翻译: 将消息路由到多个消费者的方法包括确定为多个消费者集合中的每个消费者集合定义消息分类概率的概率函数,接收多个消息,对每个消息进行分类,将每个消息存储在队列中,接收可用于消费者的消费者的通知 处理消息,确定可用消费者所属的消费者集合,访问所确定的消费者集合的概率,根据所访问的概率选择消息分类,以及将所选择的分类的消息发送到可用消费者。

    INBOUND MESSAGE RATE LIMIT BASED ON MAXIMUM QUEUE TIMES
    6.
    发明申请
    INBOUND MESSAGE RATE LIMIT BASED ON MAXIMUM QUEUE TIMES 有权
    基于最大队列时间的接收消息速率限制

    公开(公告)号:US20090307393A1

    公开(公告)日:2009-12-10

    申请号:US12134366

    申请日:2008-06-06

    IPC分类号: G06F5/14

    CPC分类号: H04L47/564

    摘要: A system for managing inbound messages in a server complex including one or more message consumers. The system includes a server configured to receive the inbound messages from a first peripheral device and to transmit messages to one or more of the plurality of message consumers. The system also includes an inbound message queue coupled to the server, the inbound message queue configured to store inbound message until an age of any message stored on the inbound message queue exceeds a predetermined threshold.

    摘要翻译: 用于管理服务器组合中的入站消息的系统,包括一个或多个消息消费者。 该系统包括被配置为从第一外围设备接收入站消息并将消息发送到多个消息消费者中的一个或多个的服务器。 系统还包括耦合到服务器的入站消息队列,入站消息队列被配置为存储入站消息,直到存储在入站消息队列上的任何消息的时间超过预定阈值。

    Data transfer in a messaging system
    7.
    发明授权
    Data transfer in a messaging system 失效
    消息系统中的数据传输

    公开(公告)号:US07466648B2

    公开(公告)日:2008-12-16

    申请号:US11044598

    申请日:2005-01-27

    CPC分类号: H04L1/1874

    摘要: There is disclosed a source messaging system having a queue for receiving messages. The source messaging system has means for determining whether a message should be permitted to become INDOUBT. This is done by retrieving a value denoting the maximum number of messages that may be permitted to become INDOUBT at any one time; determining whether the message falls within the range denoted by the value; and responsive to determining that the message falls within the range, permitting the message to become INDOUBT.

    摘要翻译: 公开了一种具有用于接收消息的队列的源消息传递系统。 源消息传递系统具有用于确定消息是否应被允许变为INDOUBT的装置。 这是通过检索表示任何一次可能被允许变为INDOUBT的消息的最大数量的值来完成的; 确定消息是否落在由该值表示的范围内; 并且响应于确定消息落在该范围内,允许该消息变为INDOUBT。

    Method for Attaching to a Partitioned Queue Spread Across a Plurality of Messaging Servers
    8.
    发明申请
    Method for Attaching to a Partitioned Queue Spread Across a Plurality of Messaging Servers 失效
    连接到跨多个消息服务器的分区队列的方法

    公开(公告)号:US20080040396A1

    公开(公告)日:2008-02-14

    申请号:US11744929

    申请日:2007-05-07

    IPC分类号: G06F17/30

    CPC分类号: G06F9/546 G06F2209/548

    摘要: There is disclosed a method, apparatus and computer program for an application instance to request attachment to a queue partition on a messaging server within a plurality of messaging servers, each messaging server holding at least one queue partition, the set of queue partitions together forming a single queue. An application instance requests attachment to a queue partition, the request requesting exclusivity with regard to other application instances having a common identifier. Responsive to an indicating that the request has been successful, the application instance interacts with the queue partition.

    摘要翻译: 公开了一种用于应用实例的方法,装置和计算机程序,用于请求附接到多个消息收发服务器内的消息收发服务器上的队列分区,每个消息收发服务器保持至少一个队列分区,该组队列分区一起形成 单队列 应用程序实例请求对队列分区的附件,该请求针对具有公共标识符的其他应用程序实例请求排他性。 响应于指示请求已成功,应用程序实例与队列分区进行交互。

    Method, apparatus, system and computer program for reducing I/O in a messaging environment
    9.
    发明授权
    Method, apparatus, system and computer program for reducing I/O in a messaging environment 失效
    方法,设备,系统和计算机程序,用于减少消息传递环境中的I / O

    公开(公告)号:US07249163B2

    公开(公告)日:2007-07-24

    申请号:US10317651

    申请日:2002-12-12

    IPC分类号: G06F15/167 G06F15/16

    摘要: Requests from a client to put messages into an input queue are intercepted before reaching the input queue. The intercepted requests which refer to a message destined for the server application are established. Information associated with the server application indicates that the server application will process such a message according to a predetermined manner. A request associated with the server application for retrieving such a message is transactional, and the server application uses a one-phase commit for retrieving such a message. Such a message can then be matched with the server application's request such that the server application can retrieve the message. In this way, such messages by-pass the input queue, and are, therefore, not logged, resulting in a reduction of I/O.

    摘要翻译: 从客户端将消息发送到输入队列中的请求在到达输入队列之前被截获。 建立了涉及发往服务器应用程序的消息的拦截请求。 与服务器应用相关联的信息指示服务器应用将根据预定方式处理这样的消息。 与用于检索这样的消息的服务器应用相关联的请求是事务性的,并且服务器应用使用一阶段提交来检索这样的消息。 然后可以将这样的消息与服务器应用程序的请求相匹配,使得服务器应用程序可以检索该消息。 以这种方式,这样的消息会绕过输入队列,因此不会被记录,导致I / O的减少。