专利快速检索-快速检索全球专利，免费商用专利数据库-IPRDB

1. 发明授权

US06760340B1 Message sequencing for ordered multicasting of a message across a routing network 失效
标题翻译：通过路由网络对消息进行有序组播的消息排序
公开(公告)号：US06760340B1
公开(公告)日：2004-07-06
申请号：US09280530
申请日：1999-03-30
申请人： Guruduth Somasekhara Banavar , Tushar Deepak Chandra , Kevan Lee Miller , Robert Evan Strom , Daniel Charles Sturman , Michael James Ward
发明人： Guruduth Somasekhara Banavar , Tushar Deepak Chandra , Kevan Lee Miller , Robert Evan Strom , Daniel Charles Sturman , Michael James Ward
IPC分类号： H04L1228
CPC分类号： H04L12/1881 , H04L12/1868
摘要： A technique for reliably multicasting a message within a router network in a sequenced order with other messages is provided. At least one special router in the network has associated persistent storage for sequencing a message being routed to one or more clients. When a message is received at this sequencer node, the sequencer places a sequence number for the message in persistent storage and sends a sequencing acknowledgment back to those routers to which the message was originally routed, as well as back towards the source of the message. The sequencer acknowledgment includes the message id, and the sequencing number. When the sequencer acknowledgment is received by a router, it looks up the routing information from the original message, and sends the acknowledgment to those neighboring routers to which the original message was sent, excluding the link from which the sequencer acknowledgment was received. If the original message corresponding to the sequencer acknowledgment was buffered at this router waiting to be delivered, the message is then delivered to its client nodes.
摘要翻译：提供了一种以其他消息的顺序可靠地组播路由器网络内的消息的技术。网络中至少有一个特殊路由器具有关联的持久存储器，用于对正在路由到一个或多个客户端的消息进行排序。当在该定序器节点处接收到消息时，定序器将消息的序列号放置在持久存储器中，并将排序确认发送回消息最初路由到的那些路由器，以及返回到消息的源。定序器确认包括消息标识和序列号。当定序器确认由路由器接收时，它从原始消息中查找路由信息，并将确认发送给发送了原始消息的相邻路由器，不包括接收定序器确认的链路。如果在等待传递的路由器上缓冲对应于定序器确认的原始消息，则将该消息传递给其客户机节点。

2. 发明授权

US6091724A Routing messages within a network using the data content of the message 失效
标题翻译：使用消息的数据内容在网络中路由消息
公开(公告)号：US6091724A
公开(公告)日：2000-07-18
申请号：US975303
申请日：1997-11-20
申请人： Tushar Deepak Chandra , Robert Evan Strom , Daniel Charles Sturman
发明人： Tushar Deepak Chandra , Robert Evan Strom , Daniel Charles Sturman
IPC分类号： H04L12/58 , H04L12/54
CPC分类号： H04L12/1854
摘要： A router within a network uses the data of a message received at the router to determine on which links out of the router the message needs to be forwarded. The router does not need any destination information from the message, and thus, the message need not include any destination information. Instead, the router uses an annotated search data structure to determine which links correspond to consumers interested in receiving the message. The message is sent only over those links.
摘要翻译：网络内的路由器使用在路由器接收到的消息的数据来确定路由器哪个链路需要转发该消息。路由器不需要来自消息的任何目的地信息，因此，该消息不需要包括任何目的地信息。相反，路由器使用带注释的搜索数据结构来确定哪些链接对应于对接收消息感兴趣的消费者。该消息仅通过这些链接发送。

3. 发明授权

US07050432B1 Message logging for reliable multicasting across a routing network 失效
标题翻译：通过路由网络进行可靠组播的消息记录
公开(公告)号：US07050432B1
公开(公告)日：2006-05-23
申请号：US09281421
申请日：1999-03-30
申请人： Guruduth Somasekhara Banavar , Tushar Deepak Chandra , Kevan Lee Miller , Robert Evan Strom , Daniel Charles Sturman , Michael James Ward
发明人： Guruduth Somasekhara Banavar , Tushar Deepak Chandra , Kevan Lee Miller , Robert Evan Strom , Daniel Charles Sturman , Michael James Ward
IPC分类号： H04L12/28 , H04L12/56
CPC分类号： H04L12/1868 , H04L12/1895 , H04L67/26 , H04L67/327
摘要： A technique for reliably multicasting a message within a router network is provided. At least one special router in the network has associated persistent storage for logging a message being routed to one or more clients. When a message is received at this logger node, the logger places the message in persistent storage and sends a logging acknowledgment back to those routers to which the message was originally routed, as well as back towards the source of the message. The logger acknowledgment includes the message id, the logger id, and a logging number. When the logger acknowledgment is received by a router, it looks up the routing information from the original message, and sends the acknowledgment to those neighboring routers to which the original message was sent, excluding the link from which the logger acknowledgment was received. If the original message corresponding to the logger acknowledgment was buffered at this router waiting to be delivered, the message is then delivered to its client nodes. Processes for recovering from node or link failure within the router network, and for at most once delivery of messages, at least once delivery of messages, and exactly once delivery of messages are also provided.
摘要翻译：提供了一种在路由器网络内可靠地组播消息的技术。网络中至少有一个特殊路由器具有关联的持久存储器，用于记录被路由到一个或多个客户端的消息。当在此记录器节点接收到消息时，记录器将消息放置在持久存储器中，并将记录确认发送回消息最初路由到的那些路由器，并返回消息的源。记录器确认包括消息标识，记录器ID和日志记录号。当路由器接收到记录器确认时，它将从原始消息中查找路由信息，并将确认发送给发送原始消息的相邻路由器，不包括接收到记录器确认的链路。如果与该记录器确认相对应的原始消息在等待传送的路由器中被缓冲，则该消息被传送到其客户机节点。还提供了用于从路由器网络内的节点或链路故障恢复的过程，以及至少一次传送消息，至少一次传送消息，以及一次传送消息。

4. 发明授权

US06216132B1 Method and system for matching consumers to events 失效
标题翻译：消费者与事件匹配的方法和系统
公开(公告)号：US06216132B1
公开(公告)日：2001-04-10
申请号：US08975280
申请日：1997-11-20
申请人： Tushar Deepak Chandra , Robert Evan Strom , Daniel Charles Sturman , Mark Christopher Astley
发明人： Tushar Deepak Chandra , Robert Evan Strom , Daniel Charles Sturman , Mark Christopher Astley
IPC分类号： G06F1700
CPC分类号： G06Q30/02 , G06F17/30961 , H04L12/185 , H04L12/1859 , Y10S707/99944 , Y10S707/99945 , Y10S707/99948
摘要： A generalized search data structure is used to match consumers to events in event computing systems. The search data structure includes one or more paths from a root of the structure to one or more leaves of the structure. Each path has at least one level and each level corresponds to a filter attribute. The value of at least one filter attribute in at least one path is a don't care value indicating traversal of that path is guaranteed to proceed. In addition to following the path with the don't care value, one or more additional paths may also be followed. Thus, traversal of the search data structure may yield zero or more results, indicating that zero or more consumers match the specified event. Various optimizations of the search data structure are possible.
摘要翻译：广义搜索数据结构用于将消费者与事件计算系统中的事件相匹配。搜索数据结构包括从结构的根到结构的一个或多个叶的一个或多个路径。每个路径至少有一个级别，每个级别对应一个过滤器属性。至少一个路径中的至少一个过滤器属性的值是一个不关心的值，表示该路径的遍历被保证继续。除了遵循不关心值的路径之外，还可以遵循一个或多个附加路径。因此，搜索数据结构的遍历可以产生零个或多个结果，指示零个或多个消费者匹配指定的事件。搜索数据结构的各种优化是可能的。

5. 发明授权

US06907011B1 Quiescent reconfiguration of a routing network 失效
标题翻译：路由网络的静态重配置
公开(公告)号：US06907011B1
公开(公告)日：2005-06-14
申请号：US09282101
申请日：1999-03-30
申请人： Kevan Lee Miller , Robert Evan Strom , Daniel Charles Sturman , Michael James Ward
发明人： Kevan Lee Miller , Robert Evan Strom , Daniel Charles Sturman , Michael James Ward
IPC分类号： G01R31/08 , G06F11/00 , G08C15/00 , H04J1/16 , H04J3/14 , H04L1/00 , H04L12/26 , H04L12/56
CPC分类号： H04L45/02 , H04L45/306
摘要： Reconfiguration of a continuously available routing network of a publish/subscribe system is achieved by quiescing data messages and control messages within the routing network to preserve first-in first-out ordering thereof, and then, reconfiguring the quiesced routing network. This reconfiguration technique is particularly applicable to a routing network having at least one special node comprising one of a logger node or a sequencer node, wherein the logger node is used to store a message to persistent storage within the routing network prior to delivery of the message to one or more clients, and the sequencer sequences a message with other messages received by the network prior to delivery thereof for ordered delivery of the messages to one or more clients of the network.
摘要翻译：发布/订阅系统的连续可用的路由网络的重新配置通过使数据消息静态并且在路由网络内控制消息来实现，以保持先入先出的排序，然后重新配置静态路由网络。这种重新配置技术特别适用于具有包括记录器节点或定序器节点之一的至少一个特殊节点的路由网络，其中记录器节点用于在传送消息之前将消息存储到路由网络内的持久存储器到一个或多个客户端，并且定序器在发送之前对网络接收到的其他消息进行排序，以将消息有序传送到网络的一个或多个客户端。

6. 发明授权

US07792038B2 Method for applying stochastic control optimization for messaging systems 有权
标题翻译：应用消息系统的随机控制优化的方法
公开(公告)号：US07792038B2
公开(公告)日：2010-09-07
申请号：US12115742
申请日：2008-05-06
申请人： Robert Evan Strom
发明人： Robert Evan Strom
IPC分类号： H04L12/56
CPC分类号： H04L67/322 , H04L67/325
摘要： A computer implemented method, apparatus, and computer usable program code for controlling when to send messages in a stream processing system. A policy is determined by utilizing probability statistics and a cost function prior to stream processing. The policy specifies under which conditions a message is sent eagerly and under which other conditions the message is delayed. A filter is operated during stream processing that selects which of the messages to send from a sending transform based upon a threshold. A controller is operated during stream processing that observes a current state of a receiving transform and that applies the policy based on the current state to determine whether to change the threshold.
摘要翻译：一种用于控制在流处理系统中发送消息的时间的计算机实现的方法，装置和计算机可用程序代码。策略通过在流处理之前利用概率统计和成本函数来确定。该策略指定在哪个条件下热切地发送消息，在哪个条件下消息被延迟。在流处理期间操作滤波器，其基于阈值选择要从发送变换发送的哪个消息。在流处理期间操作控制器，其观察接收变换的当前状态，并且基于当前状态应用策略以确定是否改变阈值。

7. 发明申请

US20080209440A1 DISTRIBUTED MESSAGING SYSTEM SUPPORTING STATEFUL SUBSCRIPTIONS 有权
标题翻译：分布式消息传递系统支持强大的订阅
公开(公告)号：US20080209440A1
公开(公告)日：2008-08-28
申请号：US12114464
申请日：2008-05-02
申请人： Roman Ginis , Robert Evan Strom
发明人： Roman Ginis , Robert Evan Strom
IPC分类号： G06F9/54
CPC分类号： G06F9/542 , H04L67/28 , H04L67/2823 , H04L67/288
摘要： A distributed messaging system supporting stateful subscriptions is provided. A stateful publish-subscribe system extends the functionality of the content-based approach to include more general state-valued expressions. Stateful subscriptions may refer to one or more message histories and may include more complex expressions. Therefore, subscribers may receive different information than that provided in the published messages. A plurality of broker machines is provided to deliver messages sent by publishing clients toward subscribing clients based upon the contents of the messages and stateful transformations requested by the subscribing clients. Subscription specifications are analyzed by a compiler and converted into a collection of transform objects and view objects. The messaging system builds a structure containing all transform objects and view objects needed for all intermediate and subscribed views of all subscriptions. This messaging system uses this structure to allocate transform objects and view objects to broker machines in the overlay network.
摘要翻译：提供了支持有状态订阅的分布式消息传递系统。有状态的发布订阅系统扩展了基于内容的方法的功能，以包括更一般的状态表达式。有状态订阅可以指一个或多个消息历史，并且可以包括更复杂的表达。因此，订阅者可以接收与发布的消息中提供的信息不同的信息。提供多个代理机器，用于根据订阅客户端请求的消息内容和有状态转换，将发布客户端发送的消息发送给订阅客户端。订阅规范由编译器分析，并转换成变换对象和查看对象的集合。消息传递系统构建包含所有转换对象的结构，并查看所有订阅的所有中间和订阅视图所需的对象。此消息传递系统使用此结构来分配转换对象并将对象查看到覆盖网络中的代理机器。

8. 发明授权

US06425016B1 System and method for providing collaborative replicated objects for synchronous distributed groupware applications 失效
标题翻译：用于为同步分布式组件应用程序提供协作复制对象的系统和方法
公开(公告)号：US06425016B1
公开(公告)日：2002-07-23
申请号：US08863782
申请日：1997-05-27
申请人： Guruduth Somasekhara Banavar , Kevan Lee Miller , Atul Prakash , Robert Evan Strom , Michael James Ward
发明人： Guruduth Somasekhara Banavar , Kevan Lee Miller , Atul Prakash , Robert Evan Strom , Michael James Ward
IPC分类号： G06F900
CPC分类号： G06Q10/00
摘要： A system and method featuring a collection of model objects which hold data to be shared, and supporting interfaces to read and write the data, to create and destroy collaboration relationships and to attach “view objects” containing application code which will be automatically notified of value changes. Each user environment is provided with a model object control entity, referred to herein as a Collaboration Manager, which creates model objects, executes transactions, and creates association objects related to the collaboration. A concurrency control mechanism records the reads and updates of the data and of collaboration relationships within a single transaction site and guarantees that they are applied atomically and consistently to both the local and to all remote replica objects of the collaboration.
摘要翻译：一种系统和方法，其特征在于包含要共享的数据的模型对象的集合，以及支持用于读取和写入数据的接口，以创建和销毁协作关系并附加包含将被自动通知值的应用代码的“视图对象” 变化。为每个用户环境提供了一个模型对象控制实体，这里称为协作管理器，其创建模型对象，执行事务以及创建与该协作相关的关联对象。并发控制机制将单个事务站点内的数据和协作关系的读取和更新记录在一起，并保证将它们原子地和一致地应用于协作的本地和所有远程副本对象。

9. 发明授权

US07962650B2 Dynamic component placement in an event-driven component-oriented network data processing system 有权
标题翻译：动态组件放置在事件驱动的面向组件的网络数据处理系统中
公开(公告)号：US07962650B2
公开(公告)日：2011-06-14
申请号：US12100915
申请日：2008-04-10
申请人： Geetika Tewari Lakshmanan , Chitra Dorai , Robert Evan Strom
发明人： Geetika Tewari Lakshmanan , Chitra Dorai , Robert Evan Strom
IPC分类号： G06F15/173
CPC分类号： H04L45/22 , H04L45/02 , H04L45/08 , H04L45/122
摘要： Method, system and computer usable program code for dynamic component placement in an event processing system having producers, consumers, a plurality of nodes between the producers and the consumers, and a flow graph representing computational components to be executed between the producers and the consumers. A description of a change to the system is received. At each node, next-hop neighbor nodes for each consumer are identified. A routing value is assigned to each next-hop neighbor node for each consumer. Using the routing values in a context of the change, a performance cost of the system is estimated based on hypothetical changed placements of the computational components at nodes along paths from a producer to a consumer through the next-hop neighbor nodes for each consumer, and a changed placement of the computational components that minimizes performance cost of the system relative to the hypothetical changed placements is selected.
摘要翻译：在具有生产者，消费者，生产者和消费者之间的多个节点的事件处理系统中的动态组件放置的方法，系统和计算机可用程序代码以及表示在生产者和消费者之间执行的计算组件的流程图。接收到对系统更改的描述。在每个节点处，识别每个消费者的下一跳邻居节点。路由值被分配给每个消费者的每个下一跳邻居节点。在变化的上下文中使用路由值，系统的性能成本基于通过每个消费者的下一跳邻居节点沿着从生产者到消费者的路径的节点处的计算组件的假想改变的布局来估计，以及选择最小化系统的性能成本相对于假设的改变的位置的计算组件的改变的位置。

10. 发明授权

US07761401B2 Stochastic control optimization for sender-based flow control in a distributed stateful messaging system 失效
标题翻译：在分布式状态消息系统中基于发件人的流控制的随机控制优化
公开(公告)号：US07761401B2
公开(公告)日：2010-07-20
申请号：US11759639
申请日：2007-06-07
申请人： Chitra Dorai , Jeong-Hyon Hwang , Robert Evan Strom
发明人： Chitra Dorai , Jeong-Hyon Hwang , Robert Evan Strom
IPC分类号： G06F15/18
CPC分类号： H04L67/325
摘要： A method and system for controlling message flow in distributed stream processing. State transition probabilities in a Markov model having one state per staleness value of data are determined for sending or withholding updates of data to subscribers using expected message rates from an information provider. A cost function annotates each state transition in the model with a state transition cost for each decision to “send” or “withhold”. A propagation policy specifying whether to send or withhold the message is determined for each state. The propagation policy is then deployed. If a new message comprising an update of data is received during a lapsed time unit, a staleness value of the data held by subscribers is increased. The propagation policy is used to determine whether to send or withhold the message. If the message should be sent, the message is propagated and the staleness value of the data is reset.
摘要翻译：一种用于控制分布式流处理中的消息流的方法和系统。确定具有每个数据的每个数据值的一个状态的马尔科夫模型中的状态转移概率，用于使用来自信息提供者的预期消息速率向用户发送或拒绝更新数据。成本函数用模型中的每个状态转换来注释每个决定“发送”或“扣留”的状态转移成本。确定是否为每个状态确定发送或保留消息的传播策略。然后部署传播策略。如果在经过的时间单位期间接收到包括数据更新的新消息，则增加了由订户保持的数据的陈旧值。传播策略用于确定是发送还是保留消息。如果要发送消息，则传播消息并重置数据的陈旧值。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式