| | |
| | | // The operation should become a no-op |
| | | private static final int FRACTIONAL_BECOME_NO_OP = 3; |
| | | |
| | | // This configuration boolean indicates if this ReplicationDomain should log |
| | | // ChangeNumbers. |
| | | private boolean logChangeNumber = false; |
| | | |
| | | /** |
| | | * The thread that periodically saves the ServerState of this |
| | |
| | | heartbeatInterval = configuration.getHeartbeatInterval(); |
| | | isolationpolicy = configuration.getIsolationPolicy(); |
| | | configDn = configuration.dn(); |
| | | logChangeNumber = configuration.isLogChangenumber(); |
| | | this.updateToReplayQueue = updateToReplayQueue; |
| | | |
| | | // Get assured configuration |
| | |
| | | // Note that a failed non-replication operation might not have a change |
| | | // number. |
| | | ChangeNumber curChangeNumber = OperationContext.getChangeNumber(op); |
| | | if ((curChangeNumber != null) && (logChangeNumber)) |
| | | { |
| | | Message message = |
| | | Message.raw("replicationCN:%s", curChangeNumber.toString()); |
| | | op.appendAdditionalLogMessage(message); |
| | | } |
| | | |
| | | if ((result == ResultCode.SUCCESS) && (!op.isSynchronizationOperation())) |
| | | { |
| | |
| | | ReplicationDomainCfg configuration) |
| | | { |
| | | isolationpolicy = configuration.getIsolationPolicy(); |
| | | logChangeNumber = configuration.isLogChangenumber(); |
| | | |
| | | changeConfig( |
| | | configuration.getReplicationServer(), |