Migration of Message Topics over Multicast Streams and Groups
    1.
    发明申请
    Migration of Message Topics over Multicast Streams and Groups 审中-公开
    通过组播流和组迁移消息主题

    公开(公告)号:US20080031243A1

    公开(公告)日:2008-02-07

    申请号:US11461495

    申请日:2006-08-01

    IPC分类号: H04L12/56

    摘要: A method for migrating data transmitted from a transmitter to a receiver over a first stream to a second stream in a reliable multicast system is provided. The method comprises transmitting a first message from the transmitter to the receiver over the first stream to notify the receiver that a first data flow transmitted on the first stream will be transmitted on the second stream. The transmitter transmits a second message to the receiver over the second stream after a second threshold has expired. The receiver tunes to the second stream based on the second message. The transmitter transmits a third message to the receiver over the first stream after a third threshold has expired to notify the receiver that transmission of the first data flow over the first stream will be terminated. The transmitter then transmits a fourth message from the transmitter to the receiver over the second stream after a fourth threshold has expired.

    摘要翻译: 提供了一种用于将从发送器发送到接收器的数据通过第一流迁移到可靠多播系统中的第二流的方法。 该方法包括通过第一流从发射机向接收机发送第一消息,以通知接收机将在第二流上发送在第一流上发送的第一数据流。 在第二阈值到期之后,发射机通过第二流向接收机发送第二消息。 接收机根据第二个消息调谐到第二个流。 发射机在第三阈值到期之后通过第一流发送第三消息给接收机,以通知接收机,第一流上的第一数据流的传输将被终止。 发射机然后在第四阈值到期之后通过第二流从发射机向接收机发送第四消息。

    Message filtering and demultiplexing system
    2.
    发明授权
    Message filtering and demultiplexing system 失效
    消息过滤和解复用系统

    公开(公告)号:US07958257B2

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

    申请号:US11039583

    申请日:2005-01-19

    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.

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

    Reliable messaging using message streams in a high speed, low latency data communications environment
    3.
    发明申请
    Reliable messaging using message streams in a high speed, low latency data communications environment 审中-公开
    在高速,低延迟的数据通信环境中使用消息流的可靠消息

    公开(公告)号:US20080104266A1

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

    申请号:US11586076

    申请日:2006-10-25

    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.

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

    Message filtering and demultiplexing system
    4.
    发明申请
    Message filtering and demultiplexing system 失效
    消息过滤和解复用系统

    公开(公告)号:US20060159096A1

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

    申请号:US11039583

    申请日:2005-01-19

    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.

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

    RELIABLE MESSAGING USING A MESSAGE STREAM IN A HIGH SPEED, LOW LATENCY DATA COMMUNICATIONS ENVIRONMENT
    5.
    发明申请
    RELIABLE MESSAGING USING A MESSAGE STREAM IN A HIGH SPEED, LOW LATENCY DATA COMMUNICATIONS ENVIRONMENT 审中-公开
    在高速,低端数据通信环境中使用信息流可靠的消息传递

    公开(公告)号:US20070300235A1

    公开(公告)日:2007-12-27

    申请号:US11426857

    申请日:2006-06-27

    IPC分类号: G06F9/46 H04L9/32

    CPC分类号: H04L69/326

    摘要: Methods, apparatus, and products are disclosed for reliable messaging using a message stream in a high speed, low latency data communications environment that include brokering, by a stream administration server, establishment of an active message stream to a subscribing client device from an active feed adapter; receiving, in a transport engine of the subscribing client device from the active feed adapter on an active message stream, active application messages encapsulated in active transport packets; receiving, by the transport engine from the active feed adapter, an active transport packet containing an active mapping; identifying, by the transport engine in dependence upon active sequence numbers, a missing active transport packet; identifying, by the transport engine, missing active application messages of the missing active transport packet in dependence upon the active mapping; and requesting, by the transport engine, transmission of the missing active application messages from the active feed adapter.

    摘要翻译: 公开了方法,装置和产品,用于使用消息流在高速,低延迟的数据通信环境中的可靠消息传递,其包括由流管理服务器从活动馈送向订阅客户端设备建立活动消息流 适配器; 在活动消息流中从主动馈送适配器在订阅客户端设备的传输引擎中接收封装在活动传输分组中的活动应用消息; 通过传输引擎从主动馈送适配器接收包含活动映射的主动传输分组; 通过传输引擎根据活动序列号识别丢失的活动传输分组; 由传输引擎根据主动映射来识别丢失的活动传输分组的活动应用消息; 并且由传输引擎请求从活动馈送适配器传输丢失的活动应用消息。

    SELECTING APPLICATION MESSAGES FROM AN ACTIVE FEED ADAPTER AND A BACKUP FEED ADAPTER FOR APPLICATION-LEVEL DATA PROCESSING IN A HIGH SPEED, LOW LATENCY DATA COMMUNICATIONS ENVIRONMENT
    6.
    发明申请
    SELECTING APPLICATION MESSAGES FROM AN ACTIVE FEED ADAPTER AND A BACKUP FEED ADAPTER FOR APPLICATION-LEVEL DATA PROCESSING IN A HIGH SPEED, LOW LATENCY DATA COMMUNICATIONS ENVIRONMENT 审中-公开
    从高速,低位数据通信环境中选择用于应用级数据处理的主动进给适配器和备份进纸适配器的应用程序消息

    公开(公告)号:US20070300234A1

    公开(公告)日:2007-12-27

    申请号:US11426819

    申请日:2006-06-27

    IPC分类号: G06F9/46

    摘要: Selecting application messages from redundant feed adapters for application-level data processing in a high speed, low latency data communications environment, including brokering establishment of an active message stream to a subscribing client device from an active feed adapter; brokering establishment of a backup message stream to the subscribing client device from a backup feed adapter; receiving active transport packets in a transport engine of the subscribing client device from the active feed adapter; receiving and buffering backup transport packets; identifying a missing active transport packet; determining whether a corresponding backup transport packet for the missing active transport packet has been received from the backup transport adapter; and replacing the missing active transport packet with the corresponding backup transport packet for further data processing if the corresponding backup transport packet for the missing active transport packet has been received.

    摘要翻译: 从冗余馈送适配器中选择应用消息以在高速,低延迟数据通信环境中进行应用级数据处理,包括从活动馈送适配器向订阅客户端设备建立活动消息流; 从备用馈送适配器代理建立备用消息流到订阅客户端设备; 在所述订阅客户端设备的传输引擎中从所述活动馈送适配器接收活动传输分组; 接收和缓冲备份传输数据包; 识别丢失的活动传输分组; 确定是否已经从备用传输适配器接收到用于丢失的活动传输分组的对应的备份传输分组; 并且如果已经接收到用于丢失的活动传输分组的对应的备份传输分组,则用相应的备份传输分组替换丢失的活动传输分组用于进一步的数据处理。

    Group communication system achieving efficient total order and state synchronization in a multi-tier environment
    7.
    发明授权
    Group communication system achieving efficient total order and state synchronization in a multi-tier environment 失效
    组通信系统在多层环境中实现高效的总体顺序和状态同步

    公开(公告)号:US08428065B2

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

    申请号:US11764233

    申请日:2007-06-18

    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.

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