com.hazelcast.enterprise.wan.sync

Class WanSyncManager

java.lang.Object

com.hazelcast.enterprise.wan.sync.WanSyncManager

public class WanSyncManager
extends Object

Manages the initiation of WAN sync requests

Constructor Summary

Constructors

Constructor and Description
WanSyncManager(EnterpriseWanReplicationService wanReplicationService, com.hazelcast.instance.Node node)

Method Summary

Modifier and Type	Method and Description
com.hazelcast.monitor.WanSyncState	getWanSyncState()
void	incrementSyncedPartitionCount()
void	initiateAntiEntropyRequest(String wanReplicationName, String targetGroupName, WanAntiEntropyEvent event) Initiates a WAN anti-entropy event and designates this member as the coordinator to broadcast the event to other cluster members.
void	publishAntiEntropyEventOnMembers(String wanReplicationName, String targetGroupName, WanAntiEntropyEvent event) Keeps broadcasting the WAN anti-entropy event to all members until it has been triggered for all partitions or some partitions have failed for times.
void	resetSyncedPartitionCount()
void	shutdown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WanSyncManager

public WanSyncManager(EnterpriseWanReplicationService wanReplicationService,
                      com.hazelcast.instance.Node node)

Method Detail

shutdown

public void shutdown()

initiateAntiEntropyRequest

public void initiateAntiEntropyRequest(String wanReplicationName,
                                       String targetGroupName,
                                       WanAntiEntropyEvent event)

Initiates a WAN anti-entropy event and designates this member as the coordinator to broadcast the event to other cluster members. This method will return as soon as the anti-entropy publication has initiated but not yet processed.

Parameters:

wanReplicationName - name of WAN replication configuration (scheme)

targetGroupName - WAN target cluster group name

event - the WAN anti-entropy event

Throws:

SyncFailedException - if there is an ongoing anti-entropy event being processed

getWanSyncState

public com.hazelcast.monitor.WanSyncState getWanSyncState()

publishAntiEntropyEventOnMembers

public void publishAntiEntropyEventOnMembers(String wanReplicationName,
                                             String targetGroupName,
                                             WanAntiEntropyEvent event)

Keeps broadcasting the WAN anti-entropy event to all members until it has been triggered for all partitions or some partitions have failed for times.

This method merely is concerned with publishing the event on all partitions. Whether the event is fully processed when this method returns depends on the semantics of processing each event type. In case of WAN sync event, the sync is not complete when this method returns. After this method returns, entries for all partitions have been enqueued but not yet replicated.

Parameters:

wanReplicationName - name of WAN replication configuration (scheme)

targetGroupName - WAN target cluster group name

event - the WAN anti-entropy event

incrementSyncedPartitionCount

public void incrementSyncedPartitionCount()

resetSyncedPartitionCount

public void resetSyncedPartitionCount()