公开(公告)号：US20090313637A1

公开(公告)日：2009-12-17

申请号：US12138585

申请日：2008-06-13

Applicant: Tom Evans ,  Graham D. Wallis ,  David Ware ,  Christopher Wilkinson

Inventor： Tom Evans ,  Graham D. Wallis ,  David Ware ,  Christopher Wilkinson

IPC: G06F9/54

CPC classification number: G06F9/546 ,  G06F2209/548

Abstract: A method for preferential reply routing, the method includes: receiving a request-reply message from a requesting application; detecting there is a preferred partition of a reply queue managed locally to an application server to which the requesting application is connected; qualifying a name of a reply queue stored in the request-reply message so that the name refers to the local partition that is managed locally to the application server; determining whether the local partition is available; wherein in the event the local partition is available: storing a reply message in the local partition; and retrieving the reply message from the local partition in response to the requesting application.

Abstract translation: 一种用于优先回复路由的方法，所述方法包括：从请求应用接收请求应答消息; 检测到本地管理的应答队列的优选分区到请求应用连接到的应用服务器; 限定存储在请求 - 回复消息中的回复队列的名称，以便该名称引用本地管理到应用服务器的本地分区; 确定本地分区是否可用; 其中在本地分区可用的情况下：在本地分区中存储回复消息; 以及响应于所述请求应用从所述本地分区检索所述应答消息。

公开(公告)号：US06978400B2

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

申请号：US10232251

申请日：2002-08-29

Applicant: Andrew I Hickson ,  Richard S Maxwell ,  David Ware

Inventor： Andrew I Hickson ,  Richard S Maxwell ,  David Ware

IPC: G06F11/00

CPC classification number: G06F17/30067 ,  G06F11/1471

Abstract: The invention relates to a method, apparatus and computer program for reducing the number of data elements checkpointed in a system having at least one data store where operations on said at least one data store are recorded in a log. A point in the log is recorded. The oldest data element in each of the least one data store is determined and it is then determined for each of the at least one data store whether a logged representation of the data store's oldest data element is more recent than the point recorded. Responsive to determining that a data store's logged representation is more recent than the point recorded, it is realised that it is not necessary to force data elements from that data store to disk if the point recorded is made the point of restart for that data store.

Abstract translation: 本发明涉及一种用于减少在具有至少一个数据存储器的系统中检查点的数量元素的数量的方法，装置和计算机程序，其中在所述至少一个数据存储器上的操作被记录在日志中。 记录日志中的一点。 确定至少一个数据存储器中的每一个中最早的数据元素，然后确定至少一个数据存储器中的每一个数据存储器的最早数据元素的记录表示是否比记录的点更近。 响应于确定数据存储的记录表示比记录的点更新，实现如果将记录的点作为该数据存储的重新启动点，则不需要将数据元素从该数据存储器强制到磁盘。

公开(公告)号：US06792604B1

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

申请号：US09676994

申请日：2000-09-29

Applicant: Andrew Ian Hickson ,  Richard Scott Maxwell ,  Timothy Steven Raff ,  David Ware

Inventor： Andrew Ian Hickson ,  Richard Scott Maxwell ,  Timothy Steven Raff ,  David Ware

IPC: G06F946

CPC classification number: G06F9/524 ,  G06F9/546

Abstract: 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.

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

公开(公告)号：US06334151B1

公开(公告)日：2001-12-25

申请号：US09288988

申请日：1999-04-09

Applicant: Steven William Bolam ,  Brian Clive Homewood ,  Andrew Hickson ,  John Michael Knapman ,  David Ware

Inventor： Steven William Bolam ,  Brian Clive Homewood ,  Andrew Hickson ,  John Michael Knapman ,  David Ware

IPC: G06F15173

CPC classification number: G06Q40/04

Abstract: In a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data from a subscriber application, a first broker data processing apparatus has: a unit for receiving a data message published on a first topic by a first publisher application; and a unit for forwarding the received published data message to a subscriber application which has requested, by entering subscription data, to receive a message on the first topic; wherein the first broker data processing apparatus sends a declaration to at least one other broker data processing apparatus of said plurality of broker data processing apparatuses declaring that the first broker data processing apparatus is the only broker data processing apparatus that is directly communicating with a publisher application that is publishing on the first topic.

Abstract translation: 在具有多个代理数据处理装置的发布/订阅数据处理代理网络中，每个代理数据处理装置具有用于直接从发布者应用接收已发布消息的输入和/或从订户应用接收订阅数据的第一代理数据处理装置， ：用于接收由第一发行商应用在第一主题上发布的数据消息的单元; 以及用于将接收到的已发布数据消息转发到已经通过输入订阅数据来请求接收关于第一主题的消息的订户应用的单元; 其中所述第一代理数据处理设备向所述多个代理数据处理设备中的至少一个其他代理数据处理设备发送声明，该代理数据处理设备宣布所述第一代理数据处理设备是与发布者应用程序直接通信的唯一代理数据处理设备 那就是出版第一个话题。

公开(公告)号：US6154781A

公开(公告)日：2000-11-28

申请号：US289011

申请日：1999-04-09

Applicant: Steven William Bolam ,  Brian Clive Homewood ,  Andrew Hickson ,  John Michael Knapman ,  David Ware

Inventor： Steven William Bolam ,  Brian Clive Homewood ,  Andrew Hickson ,  John Michael Knapman ,  David Ware

IPC: H04L29/08 ,  G06F13/38 ,  G06F15/17

CPC classification number: H04L67/26 ,  H04L67/2819 ,  H04L69/329 ,  Y10S707/99931 ,  Y10S707/99936

Abstract: In a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data from a subscriber application, a first broker apparatus has: a software unit for receiving via said input subscription data from a subscriber application; a software unit for providing an acknowledgement to said subscriber application to acknowledge that the subscription data has been received; a software unit for propagating said subscription data to a group of other broker apparatuses; a software unit for determining whether said means for propagating has propagated said subscription data to the group of other broker apparatuses; and a software unit for receiving via said input an indication from said subscriber application that said acknowledgement should not be sent to the subscriber application until the means for determining has determined that said means for propagating has propagated said subscription data to the group of other broker apparatuses.

Abstract translation: 在具有多个代理数据处理装置的发布/订阅数据处理代理网络中，每个代理数据处理装置具有用于直接从发布者应用接收已发布消息的输入和/或从订户应用接收订阅数据，第一代理装置具有： 软件单元，用于经由所述输入订阅数据从订户应用接收; 软件单元，用于向所述用户应用提供确认已经接收到所述订阅数据的确认; 用于将所述订阅数据传播到一组其他代理设备的软件单元; 用于确定所述用于传播的装置是否已将所述订阅数据传播到所述其他代理设备的组的软件单元; 以及软件单元，用于经由所述输入从所述订户应用接收所述确认不应发送到订户应用的指示，直到所述用于确定的装置已经确定所述用于传播的装置已经将所述订阅数据传播到所述其他代理设备的组 。

公开(公告)号：US09146788B2

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

申请号：US12049908

申请日：2008-03-17

Applicant: Malcolm D. Ayres ,  Andrew I. Hickson ,  Andrew M. Leonard ,  David Ware ,  Andrew J. Whitfield

Inventor： Malcolm D. Ayres ,  Andrew I. Hickson ,  Andrew M. Leonard ,  David Ware ,  Andrew J. Whitfield

IPC: G06F9/46 ,  G06F13/00 ,  G06F9/54

CPC classification number: G06F9/546

Abstract: Disclosed is a method for administering messages. In response to a determination that one or more consuming applications have failed to process the same message on a queue a predetermined number of times, the message is made unavailable to consuming applications. Responsive to determining that a predetermined number of messages have been made unavailable to consuming applications, one or more consuming applications are prevented from consuming messages from the queue.

Abstract translation: 公开了一种管理消息的方法。 响应于确定一个或多个消费应用程序未能在队列上预定次数处理相同的消息，使得该消息对消费应用不可用。 响应于确定已经使预定数量的消息对消费应用程序不可用，防止一个或多个消费应用程序消耗来自队列的消息。

公开(公告)号：US08589605B2

公开(公告)日：2013-11-19

申请号：US12134366

申请日：2008-06-06

Applicant: Srinivas Hasti ,  Michael J. Spreitzer ,  Graham D. Wallis ,  David Ware ,  Neil G. S. Young

Inventor： Srinivas Hasti ,  Michael J. Spreitzer ,  Graham D. Wallis ,  David Ware ,  Neil G. S. Young

IPC: G06F5/14

CPC classification number: H04L47/564

Abstract: 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.

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

公开(公告)号：US08199668B2

公开(公告)日：2012-06-12

申请号：US11744929

申请日：2007-05-07

Applicant: Graham Derek Wallis ,  David Ware

Inventor： Graham Derek Wallis ,  David Ware

IPC: H04L12/28

CPC classification number: G06F9/546 ,  G06F2209/548

Abstract: 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.

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

公开(公告)号：US08195382B2

公开(公告)日：2012-06-05

申请号：US12258200

申请日：2008-10-24

Applicant: William R. Bowen ,  Reid G. Oliver ,  David Ware

Inventor： William R. Bowen ,  Reid G. Oliver ,  David Ware

IPC: G06F19/00

CPC classification number: B60P3/08 ,  B61D3/18 ,  B61D47/005 ,  Y02T30/30

Abstract: The multiple driver occupied passenger vehicles transporter system (Autobus) provides a way to efficiently, economically and safely increase the highway vehicle flow rate of cars per lane per hour. Autobus employs a vehicle transporter, terminal, sensors and systems that provide a way to quickly load and unload driver occupied passenger vehicles on and off of the vehicle transporter. Autobus provides a way to safely transport multiple driver occupied passenger vehicles, including cars, sport utility vehicles (SUVs) and light trucks.

Abstract translation: 多辆驾驶员乘客车辆运输系统（Autobus）提供了一种有效，经济和安全地提高每小时车道公路车辆流量的方法。 汽车公司采用车辆运输车，终端，传感器和系统，提供快速装载和卸载驾驶员乘客车辆在车辆运输工具上和运出的方法。 Autobus提供了一种安全运输多个驾驶员乘客车辆的方式，包括汽车，运动型多用途车（SUV）和轻型卡车。

公开(公告)号：US08023498B2

公开(公告)日：2011-09-20

申请号：US12466553

申请日：2009-05-15

Applicant: Adrian James Preston ,  David Ware

Inventor： Adrian James Preston ,  David Ware

IPC: H04L12/66

CPC classification number: H04L67/14 ,  H04L67/145 ,  H04L69/14 ,  H04L69/40

Abstract: A method and system of controlling access to a destination (17, 23, 24) in a data processing network where the destination is limited to a fixed number of requesters responds to a new request (50) for access from a given requestor (20) by determining whether the fixed number would be exceeded. If the fixed number would not be exceeded (51), the new request is granted by connecting (52) the given requester to the destination. If the fixed number would be exceeded, the liveness of the or each current connection to a respective requester is tested (55). If the liveness test succeeds, the new request is rejected but if the liveness test fails, the new request is granted (52).

Abstract translation: 控制对数据处理网络中的目的地（17,23,24）的访问的方法和系统，其中目的地被限制到固定数量的请求者响应来自给定请求者（20）的访问的新请求（50） 通过确定是否超过固定数量。 如果不超过固定号码（51），则通过连接（52）给定的请求者到目的地来授予新的请求。 如果超过固定数量，则测试与相应请求者的当前连接或每个当前连接的活动性（55）。 如果活动测试成功，新请求被拒绝，但是如果活动测试失败，则新请求被授予（52）。