Serial data transmission
First Claim
1. A system, comprising:
- a first subsystem located in a first location, a second subsystem located in a second location, and a third subsystem located in a third location, wherein the first, second, and third locations correspond to different geographical locations and wherein;
the first subsystem comprises a first analytics engine and a first delivery engine, the first analytics engine configured to;
receive a request to deliver data to the third subsystem, the data comprising a plurality of packets; and
inform the first delivery engine of the request;
the first delivery engine configured to;
send each of the plurality of packets to the second subsystem; and
send, through a first combination of nodes, a first data stream to the third subsystem, the first data stream comprising each of the plurality of packets;
the second subsystem comprises a second analytics engine and a second delivery engine, the second analytics engine configured to;
receive each of the plurality of packets from the first subsystem; and
inform the second delivery engine to deliver the plurality of packets to the third subsystem;
the second delivery engine configured to;
send, through a second combination of nodes that differ from the first combination of nodes, a second data stream to the third subsystem, the second data stream comprising each of the plurality of packets;
the third subsystem comprising a data stream processor, the data stream processor configured to;
receive the first and second data streams;
determine one or more packets are missing from at least one of the first data stream and the second data stream;
identify one or more missing packets from among the first data stream and the second data stream;
send a request for the one or more missing packets to at least one of the first subsystem and the second subsystem;
receive the missing packets in response to sending the request for the one or more missing packets;
combine the received missing packets with the packets from the first data stream and packets from the second data stream to generate a third data stream in response to determining that one or more packets are missing from at least one of the first data stream and the second data stream, wherein the third data stream comprises the plurality of packets; and
send the third data stream to a downstream component of the third subsystem.
1 Assignment
0 Petitions
Accused Products
Abstract
An example embodiment includes a first subsystem, a second subsystem, and a third subsystem in different locations, where the first subsystem is configured to receive a request to deliver a set of packets to the third subsystem, send the set of packets to the second subsystem, and send, through first nodes, a first data stream containing the a set of packets to the third subsystem. The second subsystem is configured to receive the a set of packets and send, through second nodes that differ from the first nodes, a second data stream containing a set of packets to the third subsystem. In addition, the third subsystem is configured to receive the first and second data streams, determine that each data stream comprises the a set of packets, and send the set of packets from one of the first and second data streams to a downstream component.
-
Citations
20 Claims
-
1. A system, comprising:
a first subsystem located in a first location, a second subsystem located in a second location, and a third subsystem located in a third location, wherein the first, second, and third locations correspond to different geographical locations and wherein; the first subsystem comprises a first analytics engine and a first delivery engine, the first analytics engine configured to; receive a request to deliver data to the third subsystem, the data comprising a plurality of packets; and inform the first delivery engine of the request; the first delivery engine configured to; send each of the plurality of packets to the second subsystem; and send, through a first combination of nodes, a first data stream to the third subsystem, the first data stream comprising each of the plurality of packets; the second subsystem comprises a second analytics engine and a second delivery engine, the second analytics engine configured to; receive each of the plurality of packets from the first subsystem; and inform the second delivery engine to deliver the plurality of packets to the third subsystem; the second delivery engine configured to; send, through a second combination of nodes that differ from the first combination of nodes, a second data stream to the third subsystem, the second data stream comprising each of the plurality of packets; the third subsystem comprising a data stream processor, the data stream processor configured to; receive the first and second data streams; determine one or more packets are missing from at least one of the first data stream and the second data stream; identify one or more missing packets from among the first data stream and the second data stream; send a request for the one or more missing packets to at least one of the first subsystem and the second subsystem; receive the missing packets in response to sending the request for the one or more missing packets; combine the received missing packets with the packets from the first data stream and packets from the second data stream to generate a third data stream in response to determining that one or more packets are missing from at least one of the first data stream and the second data stream, wherein the third data stream comprises the plurality of packets; and send the third data stream to a downstream component of the third subsystem. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
8. A front-end system, comprising:
-
a first subsystem comprising a delivery engine configured to; receive a first data stream comprising a plurality of packets from a second subsystem using a first combination of nodes; and send a second data stream to a third subsystem using a second combination of nodes that differ from the first combination of nodes, wherein the second data stream comprises each of the plurality of packets from the first data stream; and the third subsystem comprising a data receiving engine configured to; receive, from the second subsystem, the first data stream; receive, from the first subsystem that is in a different geographical location than the second subsystem, the second data stream; send the first and second data streams to a data stream processor; and the data stream processor configured to; receive the first and second data streams; determine one or more packets are missing from at least one of the first data stream and the second data stream in response to determining whether the first data stream included a full copy of data and whether the second data stream included a full copy of the data; identify one or more missing packets from among the first data stream and the second data stream; send a request for the one or more missing packets to the first subsystem; receive the one or more missing packets in response to sending the request for the one or more missing packets; combine the received missing packets with the packets from the first data stream and packets from the second data stream to generate a third data stream in response to determining that one or more packets are missing from at least one of the first data stream and the second data stream, wherein the third data stream comprises the plurality of packets; and send the third data stream to a downstream component of the third subsystem. - View Dependent Claims (9, 10, 11, 12, 13)
-
-
14. A method, comprising:
-
receiving, by a first subsystem, a request to deliver data to a third subsystem, the data comprising a plurality of packets; and sending, by the first subsystem, each of the plurality of packets to a second subsystem; sending, by the first subsystem, through a first combination of nodes, a first data stream to the third subsystem, the first data stream comprising each of the plurality of packets; receiving, by the second subsystem, each of the plurality of packets from the first subsystem; sending, by the second subsystem, through a second combination of nodes that differ from the first combination of nodes, a second data stream to the third subsystem, the second data stream comprising each of the plurality of packets; receiving, by the third subsystem, the first and second data streams; determining, by the third subsystem, one or more packets are missing from at least one of the first data stream and the second data stream in response to determining whether the first data stream included a full copy of the data and whether the second data stream included a full copy of the data; identifying, by the third subsystem, one or more missing packets from among the first data stream and the second data stream; sending, by the third subsystem, a request for the one or more missing packets to at least one of the first subsystem and the second subsystem; receiving, by the third subsystem, the missing packets in response to sending the request for the one or more missing packets; combining, by the third subsystem, the received missing packets with the packets from the first data stream and packets from the second data stream to generate a third data stream in response to determining that one or more packets are missing from at least one of the first data stream and the second data stream, wherein the third data stream comprises the plurality of packets; and sending, by the third subsystem, the third data stream to a downstream component of the third subsystem; wherein the first subsystem is located in a first location, the second subsystem located in a second location, and the third subsystem located in a third location, wherein the first, second, and third locations correspond to different geographical locations. - View Dependent Claims (15, 16, 17, 18, 19, 20)
-
Specification