Ranging scalable time stamp data synchronization

摘要

Embodiments of the present invention address deficiencies of the art in respect to time stamp based data synchronization and provide a method, system and computer program product for scalable, ranging time stamp based data synchronization. In an embodiment of the invention, a ranging time stamp synchronization method can include computing a time range for a specified time, and producing time stamp synchronization anchors using the time range for each of the anchors. Optionally, a drift value can be computed for the time range and the computing and producing steps can be repeated when the drift value exceeds a threshold. Finally, the anchors can be used to determine whether to update data items in a remote data source in the remote host computing platform with data items from a primary data source in the primary host computing platform.

主权项

1. A computer program product comprising a non-transitory computer usable storage medium having stored therein computer usable program code for performing ranging time stamp synchronization between a primary data source in a primary host computing platform and a remote data source in a remote host computing platform, the computer usable program code which when executed by the primary host computing platform causes the primary host computing platform to:
compute a first time range for a specified time; produce first time stamp synchronization anchors according to the first time range; compute a drift value for the first time range as a difference between a mean time of a current synchronization time stamp and a previous synchronization time stamp divided by an actual elapsed time in between producing the current synchronization time stamp and the previous synchronization time stamp; upon determining that the computed drift value exceeds a threshold, compute a second time range for the specified time and also produce second time stamp synchronization anchors; and, use the second time stamp synchronization anchors to update data items in a remote data source in the remote host computing platform upon determining that a time stamp of each of the data items from the primary data source falls within a range defined by a minimum time of a last time stamp synchronization anchor and a maximum time of a next time stamp synchronization anchor.