Parallel data transmission

• US 10,461,898 B2
• Filed: 06/08/2017
• Issued: 10/29/2019
• Est. Priority Date: 06/08/2017
• Status: Active Grant

• Current Assignee: Bank of America Corp.
• Original Assignee: Bank of America Corp.
• Inventors: Kurian, Manu J.
• Primary Examiner(s): Elliott, IV, Benjamin H
• Assistant Examiner(s): Cox, Brian P
• Application Number:
  US15/617,463
• Publication Number:
  US 20180359059A1
• Time in Patent Office: 873 Days
• CPC Class Codes: H04L 1/0006 by adapting the transmission format
• CPC Class Codes: H04L 1/08 by repeating transmission, e.g. Verdan system H04L1/1858 and H04L1/189 take precedence
• CPC Class Codes: H04L 1/22 using redundant apparatus to increase reliability
• CPC Class Codes: H04L 2001/0096 Channel splitting in point-to-point links
• CPC Class Codes: H04L 63/0227 Filtering policies mail message filtering H04L51/212
• CPC Class Codes: H04L 63/1483 service impersonation, e.g. phishing, pharming or web spoofing detection of rogue wireless access points H04W12/12

Abstract

An example embodiment includes a first, second, and third subsystem, each in different locations, where the first subsystem receives a request to deliver data to the third subsystem, sends a first subset of the data to the second subsystem, and sends, through first nodes, a first data stream containing a second subset of the data different from the first subset to the third subsystem. The second subsystem receives the first subset from the first subsystem, and sends, through second nodes that differ from the first nodes, a second data stream containing the first subset to the third subsystem. Furthermore, the third subsystem receives the first and second data streams, determines that the first and second data streams, in combination, contain the data, builds a data set containing the data based on the first and second data streams, and sends the data set to a downstream component of the third subsystem.

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;

determine whether to deliver the data via transmission in series or transmission in parallel, based on a time of day and the third location of the third subsystem, wherein transmission in series comprises sending the plurality of packets along a single transmission path and transmission in parallel comprises sending subsets of the plurality of packets along different transmission paths; and

responsive to a determination to deliver the data via transmission in parallel, inform the first delivery engine of the request and the determination to deliver the data via transmission in parallel;

the first delivery engine configured to;

determine a first subset of the plurality of packets and a second subset of the plurality of packets to transmit in parallel, wherein the second subset of the plurality of packets is different from the first subset of the plurality of packets;

send the first subset 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 the second subset of the plurality of packets and first information identifying the first data stream as part of a parallel transmission;

the second subsystem comprises a second analytics engine and a second delivery engine, the second analytics engine configured to;

receive the first subset of the plurality of packets from the first subsystem; and

inform the second delivery engine to deliver the first subset of 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 the first subset of the plurality of packets and second information identifying the second data stream as part of the parallel transmission;

the third subsystem comprising a data stream processor, the data stream processor configured to;

receive the first and second data streams;

determine, based on the first and second information, that the first and second data streams are part of the parallel transmission;

responsive to determining that the first and second data streams are part of the parallel transmission, determine that the first and second data streams, in combination, comprise each of the plurality of packets;

responsive to determining that the first and second data streams, in combination, comprise each of the plurality of packets, build a data set based on the first and second data streams, wherein the data set comprises the plurality of packets; and

send the data set to a downstream component of the third subsystem.

2. The system of claim 1, wherein the data comprises a cloud object.

3. The system of claim 1, wherein the data stream processor is further configured to discard at least some packets from one of the first data stream and the second data stream, wherein the at least some packet are packets that are common to both the first data stream and the second data stream.

4. The system of claim 1, wherein the data stream processor is further configured to build the data set based on one or more rebuilding rules.

5. The system of claim 4, wherein the one or more rebuilding rules are received by the data stream processor from the downstream component of the third subsystem.

6. The system of claim 4, wherein the one or more rebuilding rules are received by the data stream processor from an entity that is different from any entity operating at least one of the first subsystem, the second subsystem, and the third subsystem.

7. A front-end system, comprising:

a data receiving engine configured to;

receive, from a first subsystem, a first data stream sent to a third subsystem, wherein the first data stream comprises a first subset of data comprising a plurality of packets and first information identifying the first data stream as part of a parallel transmission, wherein the first subsystem is configured to determine whether to deliver the data via transmission in series or transmission in parallel, based on a time of day and a location of the third subsystem, wherein transmission in series comprises sending the plurality of packets along a single transmission path and transmission in parallel comprises sending subsets of the plurality of packets along different transmission paths;

receive, from a second subsystem that is in a different geographical location than the first subsystem, a second data stream sent to the third subsystem, wherein the second data stream comprises a second subset of the data and second information identifying the second data stream as part of the parallel transmission, wherein the second subset of the data is different from the first subset of the data; and

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, based on the first and second information, that the first and second data streams are part of the parallel transmission;

responsive to determining that the first and second data streams are part of the parallel transmission, determine that the first and second data streams, in combination, comprise each of the plurality of packets;

responsive to determining that the first and second data streams, in combination, comprise each of the plurality of packets, build a data set based on the first and second data streams, wherein the data set comprises the plurality of packets; and

send the data set to a downstream component of the third subsystem.

8. The system of claim 7, wherein the data comprises a cloud object.

9. The system of claim 7, wherein the data stream processor is further configured to discard at least some packets from one of the first data stream and the second data stream.

10. The system of claim 7, wherein the data stream processor is further configured to build the data set based on one or more rebuilding rules.

11. The system of claim 10, wherein the one or more rebuilding rules are received by the data stream processor from the downstream component of the third subsystem.

12. The system of claim 10, wherein the one or more rebuilding rules are received by the data stream processor from an entity that is different from any entity operating at least one of the first subsystem, the second subsystem, and the third subsystem.

13. A method, comprising:

receiving, by a first subsystem, a request to deliver data to a third subsystem, the data comprising a plurality of packets;

determining, by the first subsystem, whether to deliver the data via transmission in series or transmission in parallel, based on a time of day and the third location of the third subsystem, wherein transmission in series comprises sending the plurality of packets along a single transmission path and transmission in parallel comprises sending subsets of the plurality of packets along different transmission paths;

sending, by the first subsystem, a first subset of the plurality of packets to a second sub system;

sending, by the first subsystem, through a first combination of nodes, a first data stream to the third subsystem, the first data stream comprising a second subset of the plurality of packets and first information identifying the first data stream as part of a parallel transmission, wherein the second subset of the plurality of packets is different from the first subset of the plurality of packets;

receiving, by the second subsystem, the first subset 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 the first subset of the plurality of packets and second information identifying the second data stream as part of the parallel transmission;

receiving, by the third subsystem, the first and second data streams;

determining, based on the first and second information, that the first and second data streams are part of the parallel transmission;

responsive to determining that the first and second data streams are part of the parallel transmission, determining, by the third subsystem, that the first and second data streams, in combination, comprise each of the plurality of packets;

responsive to determining that the first and second data streams, in combination, comprise each of the plurality of packets, building, by the third subsystem, a data set based on the first and second data streams, wherein the data set comprises the plurality of packets; and

sending, by the third subsystem, the data set to a downstream component of the third sub system;

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.

14. The method of claim 13, wherein the data comprises a cloud object.

15. The method of claim 13, further comprising discarding, by the third subsystem, at least some packets from one of the first data stream and the second data stream, wherein the at least some packet are packets that are common to both the first data stream and the second data stream.

16. The method of claim 13, further comprising building the data set based on one or more rebuilding rules.

17. The method of claim 16, wherein the one or more rebuilding rules are received by the data stream processor from the downstream component of the third subsystem.

18. The method of claim 16, wherein the one or more rebuilding rules are received by the data stream processor from an entity that is different from any entity operating at least one of the first subsystem, the second subsystem, and the third subsystem.