公开(公告)号：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.

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

公开(公告)号：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.

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

公开(公告)号：US07917912B2

公开(公告)日：2011-03-29

申请号：US11728850

申请日：2007-03-27

申请人： Gidon Gershinsky ,  Avraham Harpaz ,  Nir Naaman ,  Foluso O. Okunseinde ,  Cornell G. Wright, Jr.

发明人： Gidon Gershinsky ,  Avraham Harpaz ,  Nir Naaman ,  Foluso O. Okunseinde ,  Cornell G. Wright, Jr.

IPC分类号： G06F13/00 ,  G06F15/16

CPC分类号： H04L63/0227 ,  H04L67/327

摘要： Methods, systems, and products are disclosed for filtering application messages in a high speed, low latency data communications environment that include: receiving an application message in a transport engine of a message receiving device from a message transmitting device, the application message having a message contents label and a collision indicator, the message contents label representing contents of the application message, the collision indicator specifying whether the message contents label represents different contents in at least one other application message; determining, by the transport engine, whether contents of the application message satisfy a transport layer constraint in dependence upon the message contents label; providing, by the transport engine, the application message and the collision indicator to messaging middleware of the message receiving device if the contents of the application message satisfy the transport layer constraint; and administering the application message, by the messaging middleware, in dependence upon the collision indicator.

摘要翻译： 公开了用于在高速，低延迟的数据通信环境中过滤应用消息的方法，系统和产品，其包括：从消息发送设备在消息接收设备的传输引擎中接收应用消息，所述应用消息具有消息 内容标签和冲突指示符，所述消息内容标签表示所述应用消息的内容，所述冲突指示符指定所述消息内容标签是否表示至少一个其他应用消息中的不同内容; 由所述传输引擎确定所述应用消息的内容是否根据所述消息内容标签满足传输层约束; 如果应用消息的内容满足传输层约束，则通过传输引擎将应用消息和冲突指示符提供给消息接收设备的消息中间件; 以及由所述消息收发中间件根据所述冲突指示器来管理所述应用消息。

公开(公告)号：US20100074255A1

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

申请号：US12235626

申请日：2008-09-23

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

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

IPC分类号： H04L12/56

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

摘要： Efficient Light-Weight Multicasting Communication Protocol 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而将所述第一数据分组重新发送到所述第一组。

公开(公告)号：US20080104266A1

公开(公告)日：2008-05-01

申请号：US11586076

申请日：2006-10-25

申请人： Eliezer Dekel ,  John J. Duigenan ,  Gidon Gershinsky ,  Avraham Harpaz ,  Nir Naaman ,  Foluso O. Okunseinde ,  Hilary A. Pike ,  Yoav Tock ,  Cornell G. Weight

发明人： Eliezer Dekel ,  John J. Duigenan ,  Gidon Gershinsky ,  Avraham Harpaz ,  Nir Naaman ,  Foluso O. Okunseinde ,  Hilary A. Pike ,  Yoav Tock ,  Cornell G. Weight

IPC分类号： G06F15/16

CPC分类号： H04L51/30

摘要： Methods, apparatus, and products are disclosed for reliable messaging using message streams in a high speed, low latency data communications environment that include: receiving, in a transport engine of a message receiving device from an active message sending device, active transport packets on an active message stream established from the active message sending device to the message receiving device, the active message sending device encapsulating active application messages in the active transport packets; identifying, by the transport engine, a missing active application message from the active message sending device; and requesting, by the transport engine from a backup message sending device, transmission of a backup application message that corresponds to the missing active application message, the backup message sending device encapsulating backup application messages in backup transport packets for transmission on a backup message stream, each backup application message representing a duplicate of a corresponding active application message.

摘要翻译： 公开了用于在高速，低延迟数据通信环境中使用消息流的可靠消息的方法，装置和产品，包括：在来自活动消息发送设备的消息接收设备的传输引擎中，在主动传输分组 主动消息流从活动消息发送设备建立到消息接收设备，活动消息发送设备将活动应用消息封装在活动传输分组中; 由所述传输引擎识别来自所述活动消息发送设备的丢失的活动应用消息; 并且通过传输引擎从备份消息发送设备发送与所述丢失的活动应用消息相对应的备份应用消息的传输，所述备份消息发送设备将备份应用消息封装在备份传输分组中以便在备份消息流上传输， 每个备份应用程序消息表示对应的活动应用程序消息的副本。

公开(公告)号：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.

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

公开(公告)号：US08428065B2

公开(公告)日：2013-04-23

申请号：US11764233

申请日：2007-06-18

申请人： Eliezer Dekel ,  Gidon Gershinsky ,  Avraham Harpaz ,  Alexander Krits ,  Benjamin Mandler ,  Nir Naaman ,  Idan Zach

发明人： Eliezer Dekel ,  Gidon Gershinsky ,  Avraham Harpaz ,  Alexander Krits ,  Benjamin Mandler ,  Nir Naaman ,  Idan Zach

IPC分类号： H04L12/28 ,  H04L12/56

CPC分类号： H04L12/1877 ,  H04L12/1881

摘要： A group communication service maintains synchronization limiting the group to the processing entities that receive a plurality of source message streams from sources outside the group and transmit delivery message streams to destinations that are outside the group. Synchronization of message ordering and other state synchronization directives are communicated from a leader exclusively to other group members. Once having declared themselves to be synchronized and active by a reply protocol message, which is an opaque object and is interpreted by an application layer, the processing entities independently process the source message streams in accordance with the order specified in the directives, without requiring additional sequencing information from another processing entity.

摘要翻译： 组通信服务维护同步，将组限制到从组外的源接收多个源消息流的处理实体，并将传送消息流发送到组外的目的地。 消息排序和其他状态同步指令的同步从领导者专门传达给其他组成员。 一旦声明自己被一个不透明对象的应答协议消息（由协议消息）同步并且被应用层解释，则处理实体根据指令中指定的顺序独立地处理源消息流，而不需要额外的 来自另一个处理实体的排序信息。

公开(公告)号：US20080310423A1

公开(公告)日：2008-12-18

申请号：US11764232

申请日：2007-06-18

申请人： Eliezer Dekel ,  Gidon Gershinsky ,  Avraham Harpaz ,  Alexander Krits ,  Benjamin Mandler ,  Nir Naaman

发明人： Eliezer Dekel ,  Gidon Gershinsky ,  Avraham Harpaz ,  Alexander Krits ,  Benjamin Mandler ,  Nir Naaman

IPC分类号： H04L12/28

CPC分类号： H04L12/1881 ,  H04L51/34

摘要： A group communication service is adapted for multi-point to multi-point communication. Identical message streams are received by a tier of processing servers from a tier of sources. The processing servers deliver the message streams to a tier of destinations. The group communication service enables the processing servers to deal with newly added message streams and deleted message streams while preserving total ordering.

摘要翻译： 组通信服务适用于多点到多点通信。 相同消息流由一层处理服务器从源层接收。 处理服务器将消息流传递到目的地层。 组通信服务使得处理服务器能够处理新添加的消息流和删除的消息流，同时保持总的排序。

公开(公告)号：US06335733B1

公开(公告)日：2002-01-01

申请号：US09082796

申请日：1998-05-21

申请人： Mila Keren ,  Doron Cohen ,  Avraham Harpaz ,  Alan Hartman ,  Mel Shalev

发明人： Mila Keren ,  Doron Cohen ,  Avraham Harpaz ,  Alan Hartman ,  Mel Shalev

IPC分类号： G06F1500

CPC分类号： G06Q10/06

摘要： A method and system for displaying a resource schedule containing a plurality of objects in an N-level multiple hierarchy all of which objects are subject to a common dependency, comprising the steps of allocating different non-overlapping areas of a display device for each level of the resource schedules, and graphically displaying each level of the resource schedule in the respective area of the display device in synchronized relationship on a common axis representative of the common dependency. Editing tools are provided for allowing objects of the same level to be interchanged, objects of a given level i (where i 1) to be disassembled into an object of a lower level (i−1). The method and system are particularly suited for constructing and editing crew pairings for airlines and allow simple and efficient on-line, interactive manipulation of resources.

摘要翻译： 一种用于显示包含在N级多层次中的多个对象的资源调度的方法和系统，所有这些对象都具有公共依赖性，包括以下步骤：为每个级别的每个级别分配显示设备的不同的非重叠区域 资源调度，并且在表示公共依赖关系的公共轴上以同步关系在图形显示在显示设备的各个区域中的资源调度的每个级别。 提供编辑工具以允许相同级别的对象互换，给定级别i（其中i 1）被分解成较低级别（i-1）的对象。 该方法和系统特别适用于构建和编辑航空公司的人员配对，并允许简单有效的在线交互式操纵资源。