public class LocalCBVLSNUpdater
extends java.lang.Object
Constructor and Description |
---|
LocalCBVLSNUpdater(NameIdPair nameIdPair,
RepNode repNode) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
doUpdate(VLSN vlsn,
java.lang.String source) |
(package private) static boolean |
getSuppressGroupDBUpdates() |
static void |
setSuppressGroupDBUpdates(boolean suppressGroupDBUpdates)
Used during testing to suppress CBVLSN updates at this node.
|
void |
update()
Update the database, with the local CBVLSN associated with the node ID
if required.
|
(package private) void |
updateForMaster(LocalCBVLSNTracker tracker)
As a master, update the database with the local CBVLSN for this node.
|
void |
updateForReplica(Protocol.HeartbeatResponse heartbeat)
Sets the current CBVLSN for this node.
|
void |
updateForReplica(VLSN syncableVLSN)
Exercise caution when using this method.
|
LocalCBVLSNUpdater(NameIdPair nameIdPair, RepNode repNode)
public void updateForReplica(VLSN syncableVLSN)
updateForReplica(com.sleepycat.je.rep.stream.Protocol.HeartbeatResponse)
. The two methods together, must maintain the invariant that the local
CBVLSN value must always be ascending.syncableVLSN
- the new local CBVLSNpublic void updateForReplica(Protocol.HeartbeatResponse heartbeat)
heartbeat
- The incoming heartbeat response message from the
replica containing its newest local cbvlsn.void updateForMaster(LocalCBVLSNTracker tracker)
void doUpdate(VLSN vlsn, java.lang.String source)
public void update()
public static void setSuppressGroupDBUpdates(boolean suppressGroupDBUpdates)
suppressGroupDBUpdates
- If true, the group DB and the group CBVLSN
won't be updated at the master.static boolean getSuppressGroupDBUpdates()
Copyright (c) 2004-2012 Oracle. All rights reserved.