公开(公告)号：US08539502B1

公开(公告)日：2013-09-17

申请号：US11787912

申请日：2007-04-18

申请人： Aleksey Sanin ,  Mark Tsimelzon ,  Ian D. Marshall ,  Robert B. Hagmann

发明人： Aleksey Sanin ,  Mark Tsimelzon ,  Ian D. Marshall ,  Robert B. Hagmann

IPC分类号： G06F9/46 ,  G06F7/00

CPC分类号： G06F9/546 ,  G06F2209/548

摘要： The present invention provides a method for obtaining predicable and repeatable output results in a continuous processing system. The method involves processing messages and primitives in accordance with the following rules: (1) Messages are processed in accordance with timestamps, where messages are divided up into “time slices”; (2) message order within a data stream is preserved among messages with the same time stamp; (3) subject to rule #4, for each time slice, a primitive is executed when either the messages within such time slice show up in the input stream for such primitive or the state of the window immediately preceding such primitive changes due to messages within such time slice; and (4) for each time slice, primitives that are dependent on one or more upstream primitives are not executed until such upstream primitives have finished executing messages in such time slice that are queued for processing. If such rules are insufficient to determine the order in which primitives are processed, a deterministic “tie-breaking” rule is then applied.

摘要翻译： 本发明提供一种在连续处理系统中获得可预测和可重复的输出结果的方法。 该方法涉及根据以下规则处理消息和原语：（1）消息根据时间戳进行处理，消息被划分为“时间片”; （2）在具有相同时间戳的消息之间保留数据流内的消息顺序; （3）根据规则＃4，对于每个时间片，当在这样的时间片内的消息在这样的原语的输入流中显示时，或者由于由于消息内部的消息紧接在这样的原始改变之前的窗口的状态，执行原语 这样的时间片; 和（4）对于每个时间片，依赖于一个或多个上游基元的原语不被执行，直到这些上游原语已经完成在排队等待处理的时间片中执行消息。 如果这些规则不足以确定原语被处理的顺序，则应用确定性的“打破破产”规则。

公开(公告)号：US20100246421A1

公开(公告)日：2010-09-30

申请号：US12415670

申请日：2009-03-31

申请人： Ian D. Marshall

发明人： Ian D. Marshall

IPC分类号： H04L12/26 ,  H04W4/00

CPC分类号： H04L43/065 ,  H04L12/2801 ,  H04L12/2858 ,  H04L41/12 ,  H04L41/5035 ,  H04L41/507 ,  H04L41/5074 ,  H04L43/0817 ,  H04L43/0847

摘要： Performance data relating to each of multiple network devices distributed in a geographic region is analyzed. That data can include values for various parameters measured automatically by routine polling of subscriber devices and/or network elements serving those subscriber devices. Measured parameter values can then be stored in a database and made available, together with information about subscriber device locations, to one or more analysis servers that analyze different portions of the network. As part of that analysis, groups of devices experiencing performance problems are identified based on device location. Information about those groups is then communicated and can be made available for, e.g., monitoring by service personnel.

摘要翻译： 分析与分布在地理区域中的多个网络设备中的每一个相关的性能数据。 该数据可以包括通过用户设备和/或为这些用户设备服务的网络单元的例行轮询自动测量的各种参数的值。 然后可以将测量的参数值存储在数据库中，并将其与关于订户设备位置的信息一起提供给分析网络不同部分的一个或多个分析服务器。 作为该分析的一部分，基于设备位置识别遇到性能问题的设备组。 然后传达关于这些组的信息，并且可以使其可用于例如服务人员的监视。

公开(公告)号：US08064364B2

公开(公告)日：2011-11-22

申请号：US12415670

申请日：2009-03-31

申请人： Ian D. Marshall

发明人： Ian D. Marshall

IPC分类号： H04L12/28 ,  H04L12/66 ,  G06F15/173

CPC分类号： H04L43/065 ,  H04L12/2801 ,  H04L12/2858 ,  H04L41/12 ,  H04L41/5035 ,  H04L41/507 ,  H04L41/5074 ,  H04L43/0817 ,  H04L43/0847

摘要： Performance data relating to each of multiple network devices distributed in a geographic region is analyzed. That data can include values for various parameters measured automatically by routine polling of subscriber devices and/or network elements serving those subscriber devices. Measured parameter values can then be stored in a database and made available, together with information about subscriber device locations, to one or more analysis servers that analyze different portions of the network. As part of that analysis, groups of devices experiencing performance problems are identified based on device location. Information about those groups is then communicated and can be made available for, e.g., monitoring by service personnel.

摘要翻译： 分析与分布在地理区域中的多个网络设备中的每一个相关的性能数据。 该数据可以包括通过用户设备和/或为这些用户设备服务的网络单元的例行轮询自动测量的各种参数的值。 然后可以将测量的参数值存储在数据库中，并将其与关于订户设备位置的信息一起提供给分析网络不同部分的一个或多个分析服务器。 作为该分析的一部分，基于设备位置识别遇到性能问题的设备组。 然后传达关于这些组的信息，并且可以使其可用于例如服务人员的监视。

公开(公告)号：US08675500B2

公开(公告)日：2014-03-18

申请号：US13239782

申请日：2011-09-22

申请人： Ian D. Marshall

发明人： Ian D. Marshall

IPC分类号： H04L12/26 ,  H04J1/16 ,  G08C15/00 ,  G06F11/00 ,  G01R31/08

CPC分类号： H04L43/065 ,  H04L12/2801 ,  H04L12/2858 ,  H04L41/12 ,  H04L41/5035 ,  H04L41/507 ,  H04L41/5074 ,  H04L43/0817 ,  H04L43/0847

摘要： Performance data relating to each of multiple network devices distributed in a geographic region is analyzed. That data can include values for various parameters measured automatically by routine polling of subscriber devices and/or network elements serving those subscriber devices. Measured parameter values can then be stored in a database and made available, together with information about subscriber device locations, to one or more analysis servers that analyze different portions of the network. As part of that analysis, groups of devices experiencing performance problems are identified based on device location. Information about those groups is then communicated and can be made available for, e.g., monitoring by service personnel.

摘要翻译： 分析与分布在地理区域中的多个网络设备中的每一个相关的性能数据。 该数据可以包括通过用户设备和/或为这些用户设备服务的网络单元的例行轮询自动测量的各种参数的值。 然后可以将测量的参数值存储在数据库中，并将其与关于订户设备位置的信息一起提供给分析网络不同部分的一个或多个分析服务器。 作为该分析的一部分，基于设备位置识别遇到性能问题的设备组。 然后传达关于这些组的信息，并且可以使其可用于例如服务人员的监视。

公开(公告)号：US20120014262A1

公开(公告)日：2012-01-19

申请号：US13239782

申请日：2011-09-22

申请人： Ian D. Marshall

发明人： Ian D. Marshall

IPC分类号： H04L12/26

CPC分类号： H04L43/065 ,  H04L12/2801 ,  H04L12/2858 ,  H04L41/12 ,  H04L41/5035 ,  H04L41/507 ,  H04L41/5074 ,  H04L43/0817 ,  H04L43/0847

摘要： Performance data relating to each of multiple network devices distributed in a geographic region is analyzed. That data can include values for various parameters measured automatically by routine polling of subscriber devices and/or network elements serving those subscriber devices. Measured parameter values can then be stored in a database and made available, together with information about subscriber device locations, to one or more analysis servers that analyze different portions of the network. As part of that analysis, groups of devices experiencing performance problems are identified based on device location. Information about those groups is then communicated and can be made available for, e.g., monitoring by service personnel.

摘要翻译： 分析与分布在地理区域中的多个网络设备中的每一个相关的性能数据。 该数据可以包括通过用户设备和/或为这些用户设备服务的网络单元的例行轮询自动测量的各种参数的值。 然后可以将测量的参数值存储在数据库中，并将其与关于订户设备位置的信息一起提供给分析网络不同部分的一个或多个分析服务器。 作为该分析的一部分，基于设备位置识别遇到性能问题的设备组。 然后传达关于这些组的信息，并且可以使其可用于例如服务人员的监视。

公开(公告)号：US08560495B1

公开(公告)日：2013-10-15

申请号：US11820111

申请日：2007-06-18

申请人： Aleksey Sanin ,  Ian D. Marshall

发明人： Aleksey Sanin ,  Ian D. Marshall

IPC分类号： G06F7/00 ,  G06F17/00

CPC分类号： G06F9/522 ,  G06F8/458 ,  G06F17/30516

摘要： A system and method to synchronize the processing of messages in areas of an execution graph affected by primitives with potential for substantial delay is provided. A continuous processing system identifies primitives with potential for substantial delay. For each potentially-delayed primitive that is not in a loop, the continuous processing system creates a “timezone” downstream of such primitive. The output(s) of the potentially-delayed primitive is an input to the timezone. The continuous processing system then identifies all other inputs to the timezone and places a synchronizer across such inputs. In cases where the potentially-delayed primitive is within a loop, the timezone includes such primitive, as well all primitives downstream of such primitive.

摘要翻译： 提供了一种系统和方法，用于在受到基本元素影响的执行图形的区域中同步消息的处理，并且具有潜在的实质性延迟。 连续处理系统识别具有实质性延迟潜力的原语。 对于不在循环中的每个潜在延迟的原语，连续处理系统在这样的原语下游创建“时区”。 潜在延迟的基元的输出是时区的输入。 连续处理系统然后识别到时区的所有其他输入，并在这样的输入之间放置一个同步器。 在潜在延迟的原语在循环内的情况下，时区包括这样的原语，以及这些原语下游的所有原语。

公开(公告)号：US08046744B1

公开(公告)日：2011-10-25

申请号：US12148903

申请日：2008-04-23

申请人： Ian D. Marshall ,  Aleksey Sanin ,  Mark Tsimelzon ,  Robert B. Hagmann

发明人： Ian D. Marshall ,  Aleksey Sanin ,  Mark Tsimelzon ,  Robert B. Hagmann

IPC分类号： G06F9/44

CPC分类号： G06F11/3419

摘要： The present invention provides a system and method for measuring latency in a continuous processing system. The invention involves generating “tracer” messages that are specifically designed for measuring latency. A tracer message is configured to pass through and be outputted by each primitive in the tracer message's path regardless of the function of the primitive and without changing the state of the primitive. Tracer messages are not filtered by filter primitives or delayed by time-delay primitives. Tracer messages are detected and discarded within loops. These rules provide for predictable behavior of tracer messages, thereby making them reliable indicators of latency and liveness in the continuous processing system. A tracer message is inserted into the continuous processing system at a desired start point for measuring latency. At a desired end point for measuring latency, latency is measured by calculating the amount of time the tracer message took to travel from the start point to the end point.

摘要翻译： 本发明提供了一种用于在连续处理系统中测量等待时间的系统和方法。 本发明涉及产生专门用于测量延迟的“跟踪器”消息。 跟踪消息被配置为在跟踪消息的路径中的每个基元通过并输出，而不管原语的功能如何，而不改变原语的状态。 跟踪消息不被过滤器原语过滤，也不会被延时原语延迟。 跟踪消息在循环内被检测和丢弃。 这些规则提供了示踪消息的可预测行为，从而使其成为连续处理系统中可靠的延迟和活动指标。 在期望的开始点将跟踪消息插入到连续处理系统中以测量等待时间。 在用于测量延迟的期望终点，通过计算示踪消息从起点到终点行进的时间量来测量等待时间。