Method, system and computer program for replicating data in a distributed computed environment
First Claim
Patent Images
1. A method for replicating data in a distributed system, comprising the steps of:
- from each of a plurality of originating nodes, sending updates and associated origination sequence numbers to a central hub, wherein a given update is directed to a distribution group comprising a set of the originating nodes;
from the central hub, sending updates and associated distribution sequence numbers to the plurality of originating nodes;
in the central hub, tracking acknowledgments sent by originating nodes, each acknowledgment identifying a last in-sequence distribution sequence number processed by a respective originating node; and
in the central hub, periodically sending a message to each originating node, the message including information identifying a highest origination sequence number acknowledged by originating nodes comprising the given distribution group.
1 Assignment
0 Petitions
Accused Products
Abstract
A method for replicating data in a distributed computer environment wherein a plurality of servers are configured about one or more central hubs in a hub and spoke arrangement. In each of a plurality of originating nodes, updates and associated origination sequence numbers are sent to the central hub. The hub sends updates and associated distribution sequence numbers to the plurality of originating nodes. The hub tracks acknowledgments sent by nodes for a destination sequence number acknowledged by all nodes. Thereafter, a highest origination sequence number is sent from the central hub back to each originating node.
177 Citations
22 Claims
-
1. A method for replicating data in a distributed system, comprising the steps of:
-
from each of a plurality of originating nodes, sending updates and associated origination sequence numbers to a central hub, wherein a given update is directed to a distribution group comprising a set of the originating nodes;
from the central hub, sending updates and associated distribution sequence numbers to the plurality of originating nodes;
in the central hub, tracking acknowledgments sent by originating nodes, each acknowledgment identifying a last in-sequence distribution sequence number processed by a respective originating node; and
in the central hub, periodically sending a message to each originating node, the message including information identifying a highest origination sequence number acknowledged by originating nodes comprising the given distribution group. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12)
from the central hub, rebroadcasting updates and associated distribution sequence numbers to originating nodes whose acknowledgments indicate lack of receipt of updates from the central hub.
-
-
6. The method as described in claim 5 wherein the rebroadcasting step begins with an update associated with a lowest unacknowledged distribution sequence number.
-
7. The method as described in claim 1 further including the step of:
upon failure of a given originating node, isolating the given originating node from other nodes in the given distribution group.
-
8. The method as described in claim 1 further including the steps of:
-
subsequently associating the given originating node with another originating node of the given distribution group; and
readmitting the given originating node to the given distributing group.
-
-
9. The method as described in claim 1 further including the step of:
-
upon failure of the central hub, having a given set of the originating nodes confer to designate a substitute central hub; and
transferring hub responsibilities to the substitute central hub.
-
-
10. The method as described in claim 9 further including the step of having each originating node retransmit to the substitute central hub each update for which the central hub, upon failure of the central hub, had not indicated successful receipt by every node of the plurality of originating nodes.
-
11. The method as described in claim 1 wherein a given originating node sends a plurality of updates to the central hub in a package.
-
12. The method as described in claim 11 wherein the central hub sends a plurality of updates to a given originating node in a package.
-
13. A computer program product in a computer-readable medium for replicating data in a distributed system comprising a plurality of originating nodes associated with a central hub, wherein origination nodes send updates and associated origination sequence numbers to the central hub, comprising:
-
wherein a given update is directed to a distribution group comprising a set of the originating nodes, means operative in the central hub for sending updates and associated distribution sequence numbers to the plurality of originating nodes;
means operative in the central hub for tracking acknowledgments sent by originating nodes, each acknowledgment identifying a last in-sequence distribution sequence number processed by a respective originating node; and
means operative in the central hub for periodically sending a message to each originating node, the message including information identifying a highest origination sequence number acknowledged by originating nodes comprising the given distribution group. - View Dependent Claims (14, 15, 16, 17)
-
-
18. An apparatus for replicating data in a distributed data processing system, the apparatus comprising:
-
receiving means for receiving updates and associated origination sequence numbers from a plurality of originating nodes;
first sending means for sending updates and associated disribution sequence numbers to the plurality of originating nodes;
tracking means for tracking acknowledgments sent by originating nodes, each acknowledgment identifying a last in-sequence distribution sequence number processed by a respective originating node; and
second sending means for periodically sending a message to originating nodes, the message comprising information identifying a highest origination sequence number acknowledged by originating nodes. - View Dependent Claims (19, 20, 21, 22)
means for rebroadcasting updates and associated distribution sequence numbers to originating nodes whose acknowledgments indicate lack of receipt of updates during a given time period.
-
-
21. The apparatus as described in claim 18 for comprising:
means for isolating a given originating node from a given distribution group.
-
22. The apparatus as described in claim 18 further comprising:
means for packaging a plurality of updates in a batch.
Specification