公开(公告)号：US08107451B2

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

申请号：US12202269

申请日：2008-08-31

申请人： Adnan Agbaria ,  Gidon Gershinsky ,  Nir Naaman ,  Konstantin Shagin

发明人： Adnan Agbaria ,  Gidon Gershinsky ,  Nir Naaman ,  Konstantin Shagin

IPC分类号： H04W4/00

CPC分类号： H04W4/02 ,  H04W64/00 ,  H04W64/006 ,  H04W72/04 ,  H04W76/30

摘要： Deallocating resources allocated to a network communications session, including extrapolating an expected location of a selected node that belongs to a communications path of a network communications session, determining if the extrapolated location is beyond a predefined range from a neighboring node that belongs to the communications path of the network communications session and that immediately neighbors the selected node along the communications path, and deallocating any resources allocated to the network communications session if the extrapolated location is beyond the range.

摘要翻译： 分配给网络通信会话的资源的分配，包括外推属于网络通信会话的通信路径的选定节点的预期位置，确定外推位置是否超出了属于通信路径的相邻节点的预定范围 并且如果外推位置超出该范围则立即将所选择的节点沿着通信路径相邻，并且释放分配给网络通信会话的任何资源。

公开(公告)号：US07958257B2

公开(公告)日：2011-06-07

申请号：US11039583

申请日：2005-01-19

申请人： Gidon Gershinsky ,  Avraham Harpaz ,  Nir Naaman ,  Yoav Tock

发明人： Gidon Gershinsky ,  Avraham Harpaz ,  Nir Naaman ,  Yoav Tock

IPC分类号： G06F15/173

CPC分类号： H04L12/1859 ,  H04L51/12

摘要： A publish/subscribe system includes a publisher and multiple subscribers. The published includes a packet generator to generate a packet with at least one of: a fixed length flow label labeling a message or a message bundle and a fixed length node label labeling at least one message bundle and indicating at least one of the nodes of a topic tree to which the flow label belongs. Each received includes a user selection data holder and a message selector. The data holder stores a selection of topics of interest to a user from the topic tree. The message selector receives a packet having a header and data, determines which flow and/or node labels are incorporated in the header and accepts the data if the user selection data holder indicates that the labels within the header are of interest to the user.

摘要翻译： 发布/订阅系统包括发布者和多个订阅者。 所发布的包括分组生成器，用于生成具有以下至少一个的分组：标签消息或消息束的固定长度流标签和标记至少一个消息束的固定长度节点标签，并且指示至少一个节点 流标签所属的主题树。 所接收的每个都包括用户选择数据保持器和消息选择器。 数据持有者从主题树存储用户感兴趣的主题的选择。 消息选择器接收具有报头和数据的分组，确定哪个流和/或节点标签被合并在报头中并且如果用户选择数据持有者指示报头内的标签对于用户感兴趣则接受该数据。

公开(公告)号：US20060159096A1

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

申请号：US11039583

申请日：2005-01-19

申请人： Gidon Gershinsky ,  Avraham Harpaz ,  Nir Naaman ,  Yoav Tock

发明人： Gidon Gershinsky ,  Avraham Harpaz ,  Nir Naaman ,  Yoav Tock

IPC分类号： H04J3/24 ,  H04L12/56

CPC分类号： H04L12/1859 ,  H04L51/12

摘要： A publish/subscribe system includes a publisher and multiple subscribers. The published includes a packet generator to generate a packet with at least one of: a fixed length flow label labeling a message or a message bundle and a fixed length node label labeling at least one message bundle and indicating at least one of the nodes of a topic tree to which the flow label belongs. Each received includes a user selection data holder and a message selector. The data holder stores a selection of topics of interest to a user from the topic tree. The message selector receives a packet having a header and data, determines which flow and/or node labels are incorporated in the header and accepts the data if the user selection data holder indicates that the labels within the header are of interest to the user.

摘要翻译： 发布/订阅系统包括发布者和多个订阅者。 所发布的包括分组生成器，用于生成具有以下至少一个的分组：标签消息或消息束的固定长度流标签和标记至少一个消息束的固定长度节点标签，并且指示至少一个节点 流标签所属的主题树。 所接收的每个都包括用户选择数据保持器和消息选择器。 数据持有者从主题树存储用户感兴趣的主题的选择。 消息选择器接收具有报头和数据的分组，确定哪个流和/或节点标签被合并在报头中并且如果用户选择数据持有者指示报头内的标签对于用户感兴趣则接受该数据。

公开(公告)号：US20130304886A1

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

申请号：US13470361

申请日：2012-05-14

申请人： Avraham Harpaz ,  Nir Naaman ,  Idan Zach

发明人： Avraham Harpaz ,  Nir Naaman ,  Idan Zach

IPC分类号： H04L12/24

CPC分类号： H04L41/00 ,  H04L45/125 ,  H04L45/22 ,  H04L45/28 ,  H04L67/1008

摘要： A method of routing dependent messages sent from a source node. The method comprises routing a plurality of messages including a plurality of dependent messages from a source node for processing by a group of a plurality of processing nodes, optionally while managing a failure recovery mechanism and complying with message dependencies. Each message having a weight, each dependent message is routed while at least one dependency thereof is complied with, acquiring a plurality of acknowledge notifications to at least some of the plurality of messages from the plurality of processing nodes, calculating, at the source node using a processor, a message load of each of the plurality of processing nodes according to the weight of respective messages of plurality of messages which are sent thereto and respective acknowledge notifications of the plurality of acknowledge notifications which are sent therefrom. The routing is performed according to the respective message load.

摘要翻译： 从源节点发送的路由依赖消息的方法。 该方法包括从源节点路由包括多个依赖消息的多个消息以供多个处理节点的组进行处理，可选地在管理故障恢复机制并遵守消息相关性的同时。 每个具有加权的消息，每个相关消息被路由，同时遵守其至少一个依赖性，从多个处理节点获取多个确认通知给多个消息中的至少一些，在源节点使用 处理器，根据发送给多个处理节点的多个消息的各个消息的权重的多个处理节点中的每一个的消息负载以及从其发送的多个确认通知的相应确认通知。 根据相应的消息负载执行路由。

公开(公告)号：US08682954B2

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

申请号：US12503087

申请日：2009-07-15

申请人： Avraham Harpaz ,  Nir Naaman ,  Idan Zach

发明人： Avraham Harpaz ,  Nir Naaman ,  Idan Zach

IPC分类号： G06F15/16

CPC分类号： G06F11/2097 ,  G06F11/2041

摘要： A method for server replication in a network environment is provided. The primary server provides a first service to a client. If the first service involves interaction with a non-deterministic data source, the primary server performs the interaction and provides information about the interaction to a secondary server that is a replica of the primary server. The secondary server uses the information about the interaction to synchronize the secondary server with the primary server.

摘要翻译： 提供了一种在网络环境中进行服务器复制的方法。 主服务器为客户端提供第一个服务。 如果第一个服务涉及与非确定性数据源的交互，则主服务器执行交互，并将交互信息提供给作为主服务器副本的辅助服务器。 辅助服务器使用有关交互的信息将辅助服务器与主服务器同步。

公开(公告)号：US08149830B2

公开(公告)日：2012-04-03

申请号：US12235626

申请日：2008-09-23

申请人： Avraham Harpaz ,  Nir Naaman ,  Idan Zach

发明人： Avraham Harpaz ,  Nir Naaman ,  Idan Zach

IPC分类号： H04L12/56 ,  H04L12/28 ,  G08C25/02 ,  H04L1/14

CPC分类号： H04L47/30 ,  H04L1/1874 ,  H04L47/10 ,  H04L47/115 ,  H04L2001/0093

摘要： A method for communication in a computing environment is provided. The method comprises transmitting a first data packet to one or more receiving units in a first set; receiving one or more acknowledgement messages (ACKs) from one or more receiving units in a second set, wherein the second set is a subset of the first set; removing the first data packet from a queue, in response to receiving at least one ACK from N receiving units within a time threshold; and re-transmitting the first data packet to the first set, in response to failing to receive at least one ACK from N receiving units within the time threshold.

摘要翻译： 提供了一种在计算环境中进行通信的方法。 该方法包括：向第一组中的一个或多个接收单元发送第一数据分组; 从第二组中的一个或多个接收单元接收一个或多个确认消息（ACK），其中第二组是第一组的子集; 响应于在时间阈值内从N个接收单元接收至少一个ACK，从队列中移除第一数据分组; 以及响应于在所述时间阈值内未接收到来自N个接收单元的至少一个ACK而将所述第一数据分组重新发送到所述第一组。

公开(公告)号：US08750131B2

公开(公告)日：2014-06-10

申请号：US13346747

申请日：2012-01-10

申请人： Lian Lewin-Eytan ,  Nir Naaman ,  Shahar Chen ,  Yoav Tock

发明人： Lian Lewin-Eytan ,  Nir Naaman ,  Shahar Chen ,  Yoav Tock

IPC分类号： G01R31/08

CPC分类号： H04L29/06455 ,  H04L29/06482 ,  H04L65/4076 ,  H04L65/601

摘要： Enhancing performance in a multicasting system comprising monitoring filtering costs in a multicasting system as system characteristics change over time, wherein the multicasting system is operating based on a first mapping, between a plurality of data flows and multicasting groups, to disseminate data to users that subscribe to one or more of the data flows; computing a second mapping in response to determining that overhead associated with filtering of unwanted flows at the user level has exceeded a threshold; and transitioning the multicasting system from using the first mapping to using the second mapping, in response to determining that the second mapping is feasible as applicable to one or more constraints associated with the multicasting system.

摘要翻译： 提高组播系统中的性能，包括当系统特性随时间变化时监视组播系统中的过滤成本，其中组播系统基于多个数据流和组播组之间的第一映射进行操作，以向订阅的用户传播数据 到一个或多个数据流; 响应于确定与在用户级别的不需要的流的过滤相关联的开销已经超过阈值来计算第二映射; 以及响应于确定所述第二映射适用于与所述多播系统相关联的一个或多个约束是可行的，并且将所述多播系统从使用所述第一映射转变为使用所述第二映射。

公开(公告)号：US20130124909A1

公开(公告)日：2013-05-16

申请号：US13296250

申请日：2011-11-15

申请人： Avraham Harpaz ,  Nir Naaman ,  Idan Zach

发明人： Avraham Harpaz ,  Nir Naaman ,  Idan Zach

IPC分类号： G06F11/20

CPC分类号： H04L67/1034 ,  G06F11/1425 ,  G06F11/1443 ,  G06F11/2028 ,  G06F11/2097

摘要： A computer-implemented method, a computerized system and a product for providing a cluster of replicated servers. The method performed by a computerized server in a cluster of servers, wherein the cluster of servers are executing replicated instances of an application, wherein the replicated instances are configured to perform the same processing of the same input, comprising: detecting a message loss in the server; electively determining a responsive action to the message loss; and notifying the cluster of servers of the responsive action determined by the server, whereby other servers of the cluster of servers are able to mimic operation of the server by simulating the responsive action.

摘要翻译： 计算机实现的方法，计算机化系统和用于提供复制服务器集群的产品。 由服务器集群中的计算机化服务器执行的方法，其中所述服务器集群正在执行应用程序的复制实例，其中所述复制实例被配置为执行相同输入的相同处理，包括：检测所述服务器中的消息丢失 服务器; 选择性地确定对消息丢失的响应动作; 以及通知由服务器确定的响应动作的服务器集群，由此服务器集群中的其他服务器能够通过模拟响应动作来模拟服务器的操作。

公开(公告)号：US20110016349A1

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

申请号：US12503087

申请日：2009-07-15

申请人： Avraham Harpaz ,  Nir Naaman ,  Idan Zach

发明人： Avraham Harpaz ,  Nir Naaman ,  Idan Zach

IPC分类号： G06F11/00

CPC分类号： G06F11/2097 ,  G06F11/2041

摘要： A method for server replication in a network environment is provided. The primary server provides a first service to a client. If the first service involves interaction with a non-deterministic data source, the primary server performs the interaction and provides information about the interaction to a secondary server that is a replica of the primary server. The secondary server uses the information about the interaction to synchronize the secondary server with the primary server.

摘要翻译： 提供了一种在网络环境中进行服务器复制的方法。 主服务器为客户端提供第一个服务。 如果第一个服务涉及与非确定性数据源的交互，则主服务器执行交互，并将交互信息提供给作为主服务器副本的辅助服务器。 辅助服务器使用有关交互的信息将辅助服务器与主服务器同步。

公开(公告)号：US08738959B2

公开(公告)日：2014-05-27

申请号：US13296250

申请日：2011-11-15

申请人： Avraham Harpaz ,  Nir Naaman ,  Idan Zach

发明人： Avraham Harpaz ,  Nir Naaman ,  Idan Zach

IPC分类号： G06F11/00

CPC分类号： H04L67/1034 ,  G06F11/1425 ,  G06F11/1443 ,  G06F11/2028 ,  G06F11/2097

摘要： A computer-implemented method, a computerized system and a product for providing a cluster of replicated servers. The method performed by a computerized server in a cluster of servers, wherein the cluster of servers are executing replicated instances of an application, wherein the replicated instances are configured to perform the same processing of the same input, comprising: detecting a message loss in the server; electively determining a responsive action to the message loss; and notifying the cluster of servers of the responsive action determined by the server, whereby other servers of the cluster of servers are able to mimic operation of the server by simulating the responsive action.

摘要翻译： 计算机实现的方法，计算机化系统和用于提供复制服务器集群的产品。 由服务器集群中的计算机化服务器执行的方法，其中所述服务器集群正在执行应用程序的复制实例，其中所述复制实例被配置为执行相同输入的相同处理，包括：检测所述服务器中的消息丢失 服务器; 选择性地确定对消息丢失的响应动作; 以及通知由服务器确定的响应动作的服务器集群，由此服务器集群中的其他服务器能够通过模拟响应动作来模拟服务器的操作。