Coordinated processing of data by networked computing resources

• US 9,959,572 B2
• Filed: 02/26/2016
• Issued: 05/01/2018
• Est. Priority Date: 12/10/2009
• Status: Active Grant

• Current Assignee: Royal Bank of Canada (The PNC Financial Services Group, Inc.)
• Original Assignee: Royal Bank of Canada (The PNC Financial Services Group, Inc.)
• Inventors: Iannaccone, Philip, Pitio, Walter Michael, Park, Robert, Schwall, John, Steiner, Richard, Zhang, Allen, Popejoy, Thomas L., Aisen, Daniel, Katsuyama, Bradley
• Primary Examiner(s): NGUYEN, THU HA T
• Application Number:
  US15/055,144
• Publication Number:
  US 20160182331A1
• Time in Patent Office: 795 Days
• Field of Search: 709223, 709224, 709248
• CPC Class Codes: G06Q 10/06 Resources, workflows, human or project management; Enterprise or organisation planning; Enterprise or organisation modelling
• CPC Class Codes: G06Q 40/04 Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange
• CPC Class Codes: H04L 41/0631 using root cause analysis; using analysis of correlation between notifications, alarms or events based on decision criteria, e.g. hierarchy, tree or time analysis
• CPC Class Codes: H04L 43/0864 Round trip delays
• CPC Class Codes: H04L 43/10 Active monitoring, e.g. heartbeat, ping or trace-route
• CPC Class Codes: H04L 43/16 Threshold monitoring
• CPC Class Codes: H04L 47/283 in response to processing delays, e.g. caused by jitter or round trip time [RTT]
• CPC Class Codes: H04L 67/1095 Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
• CPC Class Codes: H04L 67/62 Establishing a time schedule for servicing the requests

Abstract

Systems, methods, and computer-readable media for coordinating processing of data by multiple networked computing resources include monitoring data associated with a plurality of networked computing resources, and coordinating the routing of data processing segments to the networked computing resources.

Claims

1. A system for coordinating processing of data by multiple networked computing resources, the system comprising at least one processor configured to:

receive from one or more data sources signals representing instructions for execution of a plurality of data processes executable by a plurality of networked computing resources, the data processes representing a proposed trade in a financial interest;

obtaining data associated with available liquidity of the financial interest at each of the plurality of networked computing resources;

divide each of the plurality of data processes into a plurality of data processing segments, each data processing segment divided from a single data process to be routed to at least one of the plurality of networked computing resources;

based at least partly on latencies in execution of prior data processing requests routed by the system to each of the plurality of networked computing resources, determine a plurality of timing parameters, each of the plurality of timing parameters to be associated with a corresponding one of the plurality of data processing segments;

based on the timing parameters and the available liquidity at each of the plurality of networked computing resources associated with each of the plurality of data processes, determine a timing sequence for routing the data processing segments for all of the plurality of data processes, the timing sequence determined to cause synchronized execution of the plurality of data processing segments by the plurality of networked computing resources; and

route the plurality of data processing segments to the plurality of corresponding networked computing resources based on the timing sequence.

2. The system of claim 1, wherein dividing the at least one data process into a plurality of data processing segments comprises:

selecting to which of the plurality networked computing resources at least one of the plurality of data processing segments is to be routed; and

for each of the selected networked computing resources, determining a size of the corresponding at least one data process processing segments.

3. The system of claim 2 wherein the selection and the size determination are based at least partly on the available liquidity and a distribution of historical execution latencies associated with the plurality of computing resources.

4. The system of claim 3, wherein the at least one processor is configured to:

when the distribution for a particular networked computing resource is a multimodal distribution;

the plurality of data processing segments include at least two data processing segments to be routed to the particular networked computing resource based on the multimodal distribution, and

determine the timing parameters for the at least two data processing segments based on the multimodal distribution.

5. The system of claim 3, wherein dividing the at least one data process into a plurality of data processing segments comprises dividing the at least one data process into at least two data processing segments to be routed to the same networked computing resource;

wherein the at least one processor is configured to determine the timing parameters for each of the at least two data processing segments.

6. The system of claim 3, wherein the selection and the size determination are a function of the variance of the distributions of historical execution latencies for the plurality of networked computing resources.

7. The system of claim 1 wherein the at least one processor is configured to determine whether liquidity in addition to posted available liquidity is historically available at a particular networked computing resource;

and wherein dividing the at least one data process includes dividing the at least one data process into at least two data processing segments to be routed to the particular networked computing resource, the at least two data processing segments having timing parameters to target the posted available trade liquidity and the additional liquidity.

8. A method for coordinating processing of data by multiple networked computing resources, the method comprising:

receiving from one or more data sources signals representing instructions for execution of a plurality of data processes executable by a plurality of networked computing resources, the data processes representing a proposed trade in a financial interest;

obtaining data associated with available liquidity of the financial interest at each of the plurality of networked computing resources;

dividing each of the plurality of data processes into a plurality of data processing segments, each data processing segment divided from a single data process to be routed to at least one of the plurality of networked computing resources;

based at least partly on latencies in execution of prior data processing requests routed by the system to each of the plurality of networked computing resources, determining a plurality of timing parameters, each of the plurality of timing parameters to be associated with a corresponding one of the plurality of data processing segments;

based on the timing parameters and the available liquidity at each of the plurality of networked computing resources associated with each of the plurality of data processes, determining a timing sequence for routing the data processing segments for all of the plurality of data processes, the timing sequence determined to cause synchronized execution of the plurality of data processing segments by the plurality of networked computing resources; and

routing the plurality of data processing segments to the plurality of corresponding networked computing resources based on the timing sequence.

9. The method of claim 8, wherein dividing the at least one data process into a plurality of data processing segments comprises:

selecting to which of the plurality networked computing resources at least one of the plurality of data processing segments is to be routed; and

for each of the selected networked computing resources, determining a size of the corresponding at least one data process processing segments.

10. The method of claim 9 wherein the selection and the size determination are based at least partly on the available liquidity and a distribution of historical execution latencies associated with the plurality of computing resources.

11. The method of claim 10, wherein

when the distribution for a particular networked computing resource is a multimodal distribution:

the plurality of data processing segments include at least two data processing segments to be routed to the particular networked computing resource based on the multimodal distribution, and

the method comprises determining the timing parameters for the at least two data processing segments based on the multimodal distribution.

12. The method of claim 10, wherein dividing the at least one data process into a plurality of data processing segments comprises dividing the at least one data process into at least two data processing segments to be routed to the same networked computing resource;

wherein the method comprises determining the timing parameters for each of the at least two data processing segments.

13. The method of claim 10, wherein the selection and the size determination are a function of the variance of the distributions of historical execution latencies for the plurality of networked computing resources.

14. The method of claim 8 wherein the method comprises determining whether liquidity in addition to posted available liquidity is historically available at a particular networked computing resource;

and wherein dividing the at least one data process includes dividing the at least one data process into at least two data processing segments to be routed to the particular networked computing resource, the at least two data processing segments having timing parameters to target the posted available trade liquidity and the additional liquidity.

15. A non-transitory computer-readable medium having stored thereon instructions which when executed by at least one processor, configure the at least one processor to:

receive from one or more data sources signals representing instructions for execution of a plurality of data processes executable by a plurality of networked computing resources, the data processes representing a proposed trade in a financial interest;

obtaining data associated with available liquidity of the financial interest at each of the plurality of networked computing resources;

divide each of the plurality of data processes into a plurality of data processing segments, each data processing segment divided from a single data process to be routed to at least one of the plurality of networked computing resources;

based at least partly on latencies in execution of prior data processing requests routed by the system to each of the plurality of networked computing resources, determine a plurality of timing parameters, each of the plurality of timing parameters to be associated with a corresponding one of the plurality of data processing segments;

based on the timing parameters and the available liquidity at each of the plurality of networked computing resources associated with each of the plurality of data processes, determine a timing sequence for routing the data processing segments for all of the plurality of data processes, the timing sequence determined to cause synchronized execution of the plurality of data processing segments by the plurality of networked computing resources; and

route the plurality of data processing segments to the plurality of corresponding networked computing resources based on the timing sequence.