Patent EP-3252606-A1 (EP)
Inventor: LEVINE BORIS
IPC: G06F11/16
Filed: 2016-05-31
Abstract: Systems and methods for synchronisation of independent first (302, 304) and second (310, 312) data handling systems, where each of the first and second data handling systems receive data from the same plurality of data providers (301), the first and second data handling systems process first (302) and second (310) data streams (600) generated from the received data from the plurality of data providers, wherein the first and second data streams are near identical, and wherein the first and second data handling systems are disposed in different locations, are disclosed. A first data handling system (302, 304) at a first location comprises: a first data stream generation module (302), comprising a first compiler for combining received data from the plurality of data providers into a first data stream (600); and a first processing and storage system (304), comprising: a first data store (402) for storing the first data stream; a first duplicator module (404) for duplicating data from the first data stream; a first combiner module (406) for combining received data with the first data stream; and at least one first communications port for transmitting information and/or data to and receiving information and/or data from a communications network (308). A second data handling system (310, 312) at a second location remote from the first location, comprises: a second data stream generation module (310), comprising a second compiler for combining received data from the plurality of data providers into a second data stream (600); and a second processing and storage system (312), comprising: a second data store (402) for storing the second data stream; a second duplicator module (404) for duplicating data from the second data stream; a second combiner module (406) for combining received data with the second data stream; and at least one second communications port for transmitting information and/or data to and receiving information and/or data from a communications network (308). The system further comprises at least one comparator module (306, 314) for comparing information from the first and second data streams. The first and second processing and storage systems are configured to, via the at least one first and second communications ports, transmit information to and from the at least one comparator module, and to transmit data between the first and second processing and storage systems, via the communications network. The first and second data stream generation modules are configured to generate first and second data streams for processing and storage in the respective first and second processing and storage systems. Following receipt of the first and second data streams at the first and second processing and storage systems, the first processing and storage system is configured to transmit (502) first information from a most recent section (608) of the first data stream to the comparator module, and the second processing and storage system is configured to transmit second information from a corresponding most recent section of the second data stream to the comparator module. The comparator module is configured to: compare (504) the first and second information; measure a value for discrepancy between the first and second information; test (506) the discrepancy value against a threshold; and, where the discrepancy value exceeds the threshold, generate: from the first and second information an indicator (508) of which of said first data stream most recent section and said second data stream corresponding most recent section contains a higher quality of data; and a duplication instruction (422) for the duplicator module of the respective processing and storage system whose data stream has been indicated by the indicator to contain the higher quality of data. The duplicator module for the indicated data stream is configured to, if instructed, duplicate (422) the data from said most recent section of the indicated data stream. The processing and storage system for the indicated data stream is configured to transmit, via the communications port, the duplicated data to the combiner module of the processing and storage system for the other stream. The combiner module for the other stream is configured to replace (424, 707) said corresponding most recent section of the other stream with the duplicated data from said most recent section (710) of the indicated stream.