公开(公告)号：US20070245018A1

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

申请号：US11402685

申请日：2006-04-12

申请人： Sumeer Bhola ,  Daniel Sturman ,  Yuanyuan Zhao

发明人： Sumeer Bhola ,  Daniel Sturman ,  Yuanyuan Zhao

IPC分类号： G06F15/173

CPC分类号： H04L63/102 ,  G06F21/6218 ,  G06F2221/2105 ,  G06F2221/2141 ,  H04L51/00 ,  H04L67/00

摘要： Improved access control techniques for distributed messaging systems such as content-based publish/subscribe systems are disclosed. For example, a method for providing access control in a content-based publish/subscribe system, wherein messages are delivered from publishing clients to subscribing clients via a plurality of brokers, includes the following steps/operations. One or more changes to an access control policy are specified. An access control version identifier is associated to the one or more changes. The one or more changes are sent to one or more brokers of the plurality of brokers that have a publishing client or a subscribing client associated therewith that is affected by the one or more changes. The access control version identifier associated with the one or more changes is sent to each of the plurality of brokers.

摘要翻译： 公开了用于诸如基于内容的发布/订阅系统之类的分布式消息系统的改进的访问控制技术。 例如，一种用于在基于内容的发布/订阅系统中提供访问控制的方法，其中消息通过多个经纪人从发布客户端传递到订阅客户端包括以下步骤/操作。 指定访问控制策略的一个或多个更改。 访问控制版本标识符与一个或多个更改相关联。 将一个或多个更改发送给多个经纪人的一个或多个经纪人，其具有受一个或多个变化影响的发布客户端或与之相关联的订阅客户端。 将与一个或多个变化相关联的访问控制版本标识符发送给多个经纪人中的每一个。

公开(公告)号：US20060085507A1

公开(公告)日：2006-04-20

申请号：US10965458

申请日：2004-10-14

申请人： Yuanyuan Zhao ,  Daniel Sturman ,  Sumeer Bhola

发明人： Yuanyuan Zhao ,  Daniel Sturman ,  Sumeer Bhola

IPC分类号： G06F15/16

CPC分类号： G06Q10/10

摘要： The present invention is directed to a publish/subscribe system containing a plurality of brokers, a plurality of subscribers and plurality of brokers including publisher connecting brokers, intermediate brokers and subscriber connecting brokers. Subscriptions are introduced into the system by the subscribers through associated subscription brokers. New subscriptions are aggregated, assigned a virtual start time and propagated through the system toward the publishers. Each broker maintains subscription information in the form of a directed acyclic graph and a broker vector. Messages are published through the system by the publishers through their associated publisher connecting brokers. Each message is assigned a message vector associating subscriptions to that message. The published messages are routed through the brokers toward the subscribers in accordance with comparisons of message brokers and vector brokers conducted at each broker.

摘要翻译： 本发明涉及包含多个经纪人，多个订阅者和多个经纪人的发布/订阅系统，包括出版商连接经纪人，中间经纪人和订户连接经纪人。 用户通过相关订阅经纪人将订阅引入系统。 新订阅被聚合，分配一个虚拟的开始时间，并通过系统向发布商传播。 每个经纪人以有向无环图和代理向量的形式维护订阅信息。 消息通过系统由发布商通过其关联的发布商连接经纪人发布。 为每个消息分配一个将订阅关联到该消息的消息向量。 根据在每个经纪人进行的消息经纪人和向量经纪人的比较，所发布的消息通过经纪人路由到订户。

公开(公告)号：US08185649B2

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

申请号：US12166250

申请日：2008-07-01

申请人： Yuanyuan Zhao ,  Daniel Charles Sturman ,  Sumeer Bhola

发明人： Yuanyuan Zhao ,  Daniel Charles Sturman ,  Sumeer Bhola

IPC分类号： G06F15/16

CPC分类号： G06Q10/10

摘要： The present invention is directed to a publish/subscribe system containing a plurality of brokers, a plurality of subscribers and plurality of brokers including publisher connecting brokers, intermediate brokers and subscriber connecting brokers. Subscriptions are introduced into the system by the subscribers through associated subscription brokers. New subscriptions are aggregated, assigned a virtual start time and propagated through the system toward the publishers. Each broker maintains subscription information in the form of a directed acyclic graph and a broker vector. Messages are published through the system by the publishers through their associated publisher connecting brokers. Each message is assigned a message vector associating subscriptions to that message. The published messages are routed through the brokers toward the subscribers in accordance with comparisons of message brokers and vector brokers conducted at each broker.

摘要翻译： 本发明涉及包含多个经纪人，多个订阅者和多个经纪人的发布/订阅系统，包括出版商连接经纪人，中间经纪人和订户连接经纪人。 用户通过相关订阅经纪人将订阅引入系统。 新订阅被聚合，分配一个虚拟的开始时间，并通过系统向发布商传播。 每个经纪人以有向无环图和代理向量的形式维护订阅信息。 消息通过系统由发布商通过其关联的发布商连接经纪人发布。 为每个消息分配一个将订阅关联到该消息的消息向量。 根据在每个经纪人进行的消息经纪人和向量经纪人的比较，所发布的消息通过经纪人路由到订户。

公开(公告)号：US20080288655A1

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

申请号：US12166250

申请日：2008-07-01

申请人： Yuanyuan Zhao ,  Daniel Charles Sturman ,  Sumeer Bhola

发明人： Yuanyuan Zhao ,  Daniel Charles Sturman ,  Sumeer Bhola

IPC分类号： G06F15/173

CPC分类号： G06Q10/10

摘要： The present invention is directed to a publish/subscribe system containing a plurality of brokers, a plurality of subscribers and plurality of brokers including publisher connecting brokers, intermediate brokers and subscriber connecting brokers. Subscriptions are introduced into the system by the subscribers through associated subscription brokers. New subscriptions are aggregated, assigned a virtual start time and propagated through the system toward the publishers. Each broker maintains subscription information in the form of a directed acyclic graph and a broker vector. Messages are published through the system by the publishers through their associated publisher connecting brokers. Each message is assigned a message vector associating subscriptions to that message. The published messages are routed through the brokers toward the subscribers in accordance with comparisons of message brokers and vector brokers conducted at each broker.

摘要翻译： 本发明涉及包含多个经纪人，多个订阅者和多个经纪人的发布/订阅系统，包括出版商连接经纪人，中间经纪人和订户连接经纪人。 用户通过相关订阅经纪人将订阅引入系统。 新订阅被聚合，分配一个虚拟的开始时间，并通过系统向发布商传播。 每个经纪人以有向无环图和代理向量的形式维护订阅信息。 消息通过系统由发布商通过其关联的发布商连接经纪人发布。 为每个消息分配一个将订阅关联到该消息的消息向量。 根据在每个经纪人进行的消息经纪人和向量经纪人的比较，所发布的消息通过经纪人路由到订户。

公开(公告)号：US20060248219A1

公开(公告)日：2006-11-02

申请号：US11479264

申请日：2006-06-30

申请人： Mark Astley ,  Joshua Auerbach ,  Sumeer Bhola ,  Marc Kaplan ,  Robert Strom ,  Yuanyuan Zhao

发明人： Mark Astley ,  Joshua Auerbach ,  Sumeer Bhola ,  Marc Kaplan ,  Robert Strom ,  Yuanyuan Zhao

IPC分类号： G06F15/16

CPC分类号： H04L67/26 ,  H04L67/306 ,  H04L69/329

摘要： A content-based publish/subscribe system for providing gapless message delivery from a publishing client to a subscribing client, the system includes a plurality of brokers operatively coupled to one another via a network. Each of the brokers include at least one processor and are configured as a publisher-hosting broker, a subscriber-hosting broker or an intermediate broker. The subscriber-hosting broker is operatively coupled to the publisher-hosting broker via the network through the intermediate broker. At least a portion of the plurality of brokers are configured so as to eliminate a need for persistent storage of messages at the intermediate broker and to substantially guarantee a gapless delivery of one or more messages transmitted by the publishing client to the subscribing client, even in the presence of a failure in the publish/subscribe system.

摘要翻译： 一种基于内容的发布/订阅系统，用于提供从发布客户端到订阅客户端的无间隙消息传递，该系统包括经由网络可操作地彼此耦合的多个代理。 每个经纪人包括至少一个处理器，并且被配置为发行人托管代理，订户托管代理或中间代理。 订户托管代理通过中间代理经由网络可操作地耦合到发行商托管代理。 多个代理的至少一部分被配置为消除对在中间代理处的消息的持久存储的需要，并且基本上保证发布客户端发送给订阅客户端的一个或多个消息的无间隙传递，即使在 发布/订阅系统中出现故障。

公开(公告)号：US07822801B2

公开(公告)日：2010-10-26

申请号：US10965458

申请日：2004-10-14

申请人： Yuanyuan Zhao ,  Daniel Charles Sturman ,  Sumeer Bhola

发明人： Yuanyuan Zhao ,  Daniel Charles Sturman ,  Sumeer Bhola

IPC分类号： G06F15/16

CPC分类号： G06Q10/10

摘要： The present invention is directed to a publish/subscribe system containing a plurality of brokers, a plurality of subscribers and plurality of brokers including publisher connecting brokers, intermediate brokers and subscriber connecting brokers. Subscriptions are introduced into the system by the subscribers through associated subscription brokers. New subscriptions are aggregated, assigned a virtual start time and propagated through the system toward the publishers. Each broker maintains subscription information in the form of a directed acyclic graph and a broker vector. Messages are published through the system by the publishers through their associated publisher connecting brokers. Each message is assigned a message vector associating subscriptions to that message. The published messages are routed through the brokers toward the subscribers in accordance with comparisons of message brokers and vector brokers conducted at each broker.

摘要翻译： 本发明涉及包含多个经纪人，多个订阅者和多个经纪人的发布/订阅系统，包括发行商连接经纪人，中间经纪人和订户连接经纪人。 用户通过相关订阅经纪人将订阅引入系统。 新订阅被聚合，分配一个虚拟的开始时间，并通过系统向发布商传播。 每个经纪人以有向无环图和代理向量的形式维护订阅信息。 消息通过系统由发布商通过其关联的发布商连接经纪人发布。 为每个消息分配一个将订阅关联到该消息的消息向量。 根据在每个经纪人进行的消息经纪人和向量经纪人的比较，所发布的消息通过经纪人路由到订户。

公开(公告)号：US20060092933A1

公开(公告)日：2006-05-04

申请号：US10980034

申请日：2004-11-03

申请人： Mark Astley ,  Andrew Banks ,  Sumeer Bhola ,  Ignacio Silva-Lepe ,  Michael Ward ,  David Ware

发明人： Mark Astley ,  Andrew Banks ,  Sumeer Bhola ,  Ignacio Silva-Lepe ,  Michael Ward ,  David Ware

IPC分类号： H04L12/28

CPC分类号： H04L67/2814 ,  H04L67/26 ,  H04L67/2842 ,  H04L67/322

摘要： 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.

公开(公告)号：US20090178047A1

公开(公告)日：2009-07-09

申请号：US11970906

申请日：2008-01-08

申请人： MARK C. ASTLEY ,  Sumeer Bhola ,  Cristian Lumezanu

发明人： MARK C. ASTLEY ,  Sumeer Bhola ,  Cristian Lumezanu

IPC分类号： G06F9/50

CPC分类号： H04L47/822 ,  G06F9/5038

摘要： A system and method for latency assignment in a system having shared resources for performing jobs including computing a new resource price at each resource and sending the new resource price to a task controller in a task path that has at least one job running in the task path. A path price is computed for each task path of the task controller, if there is a critical time specified for the task. New deadlines are determined for the resources in a task path based on the resource price and the path price. The new deadlines are sent to the resources where the at least one job is running to improve system performance.

摘要翻译： 一种用于具有用于执行作业的共享资源的系统中的等待时间分配的系统和方法，包括在每个资源处计算新的资源价格，并将新的资源价格发送到任务路径中的任务控制器，所述任务路径具有在任务路径中运行的至少一个作业 。 如果为任务指定了关键时间，则为任务控制器的每个任务路径计算路径价格。 基于资源价格和路径价格确定任务路径中的资源的新截止日期。 新的最后期限被发送到运行至少一个作业的资源以提高系统性能。

公开(公告)号：US06321252B1

公开(公告)日：2001-11-20

申请号：US09118517

申请日：1998-07-17

申请人： Sumeer Bhola ,  Srinivas Prasad Doddapaneni ,  Bodhistattwa Mukherjee ,  Keeranoor Ganapathy Kumar ,  Marc Hubert Willebeek-LeMair

发明人： Sumeer Bhola ,  Srinivas Prasad Doddapaneni ,  Bodhistattwa Mukherjee ,  Keeranoor Ganapathy Kumar ,  Marc Hubert Willebeek-LeMair

IPC分类号： G06F1300

CPC分类号： H04N21/234 ,  H04N7/15 ,  H04N21/4307 ,  H04N21/4788

摘要： A system and method for temporal synchronization of media streams in multimedia collaborative applications (i.e., a multi-user distributed applications used for interaction, both in the synchronous and asynchronous fashion among a group of users) in a wide-area distributed environment. The invention presents two abstractions; event streams and collaboration space, that together provide for coarse-grained temporal synchronization by using separate streams for different media and synchronizing the streams at the client location. VCR-like controls are also provided on groups of components in a collaborative application. The event stream provides many services such as replication, persistence, buffering, reading, and writing to archive. By implementing simple interfaces, existing collaborative applications, media players, and encoders become components that can be used to build complex multimedia collaborative applications. To efficiently implement a seeking function on a data component, the present invention introduces a framework for application-specific updates to a component state.

摘要翻译： 用于在广域分布式环境中的多媒体协作应用程序（即，用于一组用户中的同步和异步方式中的交互的多用户分布式应用程序）中的媒体流的时间同步的系统和方法。 本发明提出了两个抽象; 事件流和协作空间，它们通过为不同媒体使用单独的流并在客户端位置同步流来共同提供粗粒度的时间同步。 在协作应用程序中的组件组中也提供类似VCR的控件。 事件流提供许多服务，如复制，持久性，缓冲，读取和写入到归档。 通过实现简单的接口，现有的协作应用程序，媒体播放器和编码器成为可用于构建复杂多媒体协作应用程序的组件。 为了有效地实现对数据组件的寻求功能，本发明引入了用于组件状态的应用特定更新的框架。

公开(公告)号：US09342363B2

公开(公告)日：2016-05-17

申请号：US11970906

申请日：2008-01-08

申请人： Mark C. Astley ,  Sumeer Bhola ,  Cristian Lumezanu

发明人： Mark C. Astley ,  Sumeer Bhola ,  Cristian Lumezanu

IPC分类号： G06F9/46 ,  G06F9/50

CPC分类号： H04L47/822 ,  G06F9/5038

摘要： A system and method for latency assignment in a system having shared resources for performing jobs including computing a new resource price at each resource and sending the new resource price to a task controller in a task path that has at least one job running in the task path. A path price is computed for each task path of the task controller, if there is a critical time specified for the task. New deadlines are determined for the resources in a task path based on the resource price and the path price. The new deadlines are sent to the resources where the at least one job is running to improve system performance.

摘要翻译： 一种用于具有用于执行作业的共享资源的系统中的等待时间分配的系统和方法，包括在每个资源处计算新的资源价格，并将新的资源价格发送到任务路径中的任务控制器，所述任务路径具有在任务路径中运行的至少一个作业 。 如果为任务指定了关键时间，则为任务控制器的每个任务路径计算路径价格。 基于资源价格和路径价格确定任务路径中的资源的新截止日期。 新的最后期限被发送到运行至少一个作业的资源以提高系统性能。