/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/ |
H A D | FakeOperation.java | 43 private ChangeNumber changeNumber; field in class:FakeOperation 48 * @param changeNumber The ChangeNumber to use to build the FakeOperation. 50 public FakeOperation(ChangeNumber changeNumber) argument 52 this.changeNumber = changeNumber; 58 * @return Returns the changeNumber. 62 return changeNumber;
|
H A D | PendingChanges.java | 88 * @param changeNumber The ChangeNumber of the update to remove. 92 public synchronized LDAPUpdateMsg remove(ChangeNumber changeNumber) argument 94 return pendingChanges.remove(changeNumber).getMsg(); 110 * @param changeNumber The ChangeNumber of the update message that must be 114 public synchronized void commit(ChangeNumber changeNumber, argument 117 _commit(changeNumber, msg); 122 * @param changeNumber The ChangeNumber of the update message that must be 126 public void _commit(ChangeNumber changeNumber, argument 129 PendingChange curChange = pendingChanges.get(changeNumber); 142 * @param changeNumber Th 145 commit(ChangeNumber changeNumber) argument 252 commitAndPushCommittedChanges( ChangeNumber changeNumber, LDAPUpdateMsg msg) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/ |
H A D | FakeOperation.java | 43 private ChangeNumber changeNumber; field in class:FakeOperation 48 * @param changeNumber The ChangeNumber to use to build the FakeOperation. 50 public FakeOperation(ChangeNumber changeNumber) argument 52 this.changeNumber = changeNumber; 58 * @return Returns the changeNumber. 62 return changeNumber;
|
H A D | PendingChanges.java | 88 * @param changeNumber The ChangeNumber of the update to remove. 92 public synchronized LDAPUpdateMsg remove(ChangeNumber changeNumber) argument 94 return pendingChanges.remove(changeNumber).getMsg(); 110 * @param changeNumber The ChangeNumber of the update message that must be 114 public synchronized void commit(ChangeNumber changeNumber, argument 117 _commit(changeNumber, msg); 122 * @param changeNumber The ChangeNumber of the update message that must be 126 public void _commit(ChangeNumber changeNumber, argument 129 PendingChange curChange = pendingChanges.get(changeNumber); 142 * @param changeNumber Th 145 commit(ChangeNumber changeNumber) argument 252 commitAndPushCommittedChanges( ChangeNumber changeNumber, LDAPUpdateMsg msg) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/ |
H A D | FakeOperation.java | 43 private ChangeNumber changeNumber; field in class:FakeOperation 48 * @param changeNumber The ChangeNumber to use to build the FakeOperation. 50 public FakeOperation(ChangeNumber changeNumber) argument 52 this.changeNumber = changeNumber; 58 * @return Returns the changeNumber. 62 return changeNumber;
|
H A D | PendingChanges.java | 88 * @param changeNumber The ChangeNumber of the update to remove. 92 public synchronized LDAPUpdateMsg remove(ChangeNumber changeNumber) argument 94 return pendingChanges.remove(changeNumber).getMsg(); 110 * @param changeNumber The ChangeNumber of the update message that must be 114 public synchronized void commit(ChangeNumber changeNumber, argument 117 _commit(changeNumber, msg); 122 * @param changeNumber The ChangeNumber of the update message that must be 126 public void _commit(ChangeNumber changeNumber, argument 129 PendingChange curChange = pendingChanges.get(changeNumber); 142 * @param changeNumber Th 145 commit(ChangeNumber changeNumber) argument 252 commitAndPushCommittedChanges( ChangeNumber changeNumber, LDAPUpdateMsg msg) argument [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | DeleteContext.java | 40 * @param changeNumber The change number of the Delete Operation. 43 public DeleteContext(ChangeNumber changeNumber, String entryUUID) argument 45 super(changeNumber, entryUUID);
|
H A D | ModifyContext.java | 42 * @param changeNumber The change number of the operation. 45 public ModifyContext(ChangeNumber changeNumber, String entryUUID) argument 47 super(changeNumber, entryUUID);
|
H A D | OperationContext.java | 48 private ChangeNumber changeNumber; field in class:OperationContext 57 * @param changeNumber The change number of the operation. 60 protected OperationContext(ChangeNumber changeNumber, String entryUUID) argument 62 this.changeNumber = changeNumber; 73 return changeNumber; 101 return ctx.changeNumber; 120 return ctx.changeNumber; 132 return ((this.changeNumber.equals(ctx.getChangeNumber()) && 145 return changeNumber [all...] |
H A D | AddContext.java | 46 * @param changeNumber The change number of the add operation. 50 public AddContext(ChangeNumber changeNumber, String entryUUID, argument 53 super(changeNumber, entryUUID);
|
H A D | ModifyDnContext.java | 43 * @param changeNumber The change number of the operation. 49 public ModifyDnContext(ChangeNumber changeNumber, String entryUUID, argument 52 super(changeNumber, entryUUID);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | DeleteContext.java | 40 * @param changeNumber The change number of the Delete Operation. 43 public DeleteContext(ChangeNumber changeNumber, String entryUUID) argument 45 super(changeNumber, entryUUID);
|
H A D | ModifyContext.java | 42 * @param changeNumber The change number of the operation. 45 public ModifyContext(ChangeNumber changeNumber, String entryUUID) argument 47 super(changeNumber, entryUUID);
|
H A D | OperationContext.java | 48 private ChangeNumber changeNumber; field in class:OperationContext 57 * @param changeNumber The change number of the operation. 60 protected OperationContext(ChangeNumber changeNumber, String entryUUID) argument 62 this.changeNumber = changeNumber; 73 return changeNumber; 101 return ctx.changeNumber; 120 return ctx.changeNumber; 132 return ((this.changeNumber.equals(ctx.getChangeNumber()) && 145 return changeNumber [all...] |
H A D | AddContext.java | 46 * @param changeNumber The change number of the add operation. 50 public AddContext(ChangeNumber changeNumber, String entryUUID, argument 53 super(changeNumber, entryUUID);
|
H A D | ModifyDnContext.java | 43 * @param changeNumber The change number of the operation. 49 public ModifyDnContext(ChangeNumber changeNumber, String entryUUID, argument 52 super(changeNumber, entryUUID);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | DeleteContext.java | 40 * @param changeNumber The change number of the Delete Operation. 43 public DeleteContext(ChangeNumber changeNumber, String entryUUID) argument 45 super(changeNumber, entryUUID);
|
H A D | ModifyContext.java | 42 * @param changeNumber The change number of the operation. 45 public ModifyContext(ChangeNumber changeNumber, String entryUUID) argument 47 super(changeNumber, entryUUID);
|
H A D | OperationContext.java | 48 private ChangeNumber changeNumber; field in class:OperationContext 57 * @param changeNumber The change number of the operation. 60 protected OperationContext(ChangeNumber changeNumber, String entryUUID) argument 62 this.changeNumber = changeNumber; 73 return changeNumber; 101 return ctx.changeNumber; 120 return ctx.changeNumber; 132 return ((this.changeNumber.equals(ctx.getChangeNumber()) && 145 return changeNumber [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/api/ |
H A D | ChangeNumberIndexRecord.java | 40 private final long changeNumber; field in class:ChangeNumberIndexRecord 49 * @param changeNumber 56 public ChangeNumberIndexRecord(long changeNumber, DN baseDN, CSN csn) argument 58 this.changeNumber = changeNumber; 64 * Builds an instance of this class, with changeNumber equal to 0. 104 return changeNumber; 111 return "changeNumber=" + changeNumber + " csn=" + csn + " baseDN=" + baseDN;
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/api/ |
H A D | ChangeNumberIndexRecord.java | 40 private final long changeNumber; field in class:ChangeNumberIndexRecord 49 * @param changeNumber 56 public ChangeNumberIndexRecord(long changeNumber, DN baseDN, CSN csn) argument 58 this.changeNumber = changeNumber; 64 * Builds an instance of this class, with changeNumber equal to 0. 104 return changeNumber; 111 return "changeNumber=" + changeNumber + " csn=" + csn + " baseDN=" + baseDN;
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/api/ |
H A D | ChangeNumberIndexRecord.java | 40 private final long changeNumber; field in class:ChangeNumberIndexRecord 49 * @param changeNumber 56 public ChangeNumberIndexRecord(long changeNumber, DN baseDN, CSN csn) argument 58 this.changeNumber = changeNumber; 64 * Builds an instance of this class, with changeNumber equal to 0. 104 return changeNumber; 111 return "changeNumber=" + changeNumber + " csn=" + csn + " baseDN=" + baseDN;
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | DraftCNData.java | 52 private long changeNumber; field in class:DraftCNData 58 * @param changeNumber 65 public DraftCNData(long changeNumber, String baseDN, CSN csn) argument 67 this.changeNumber = changeNumber; 77 * @param changeNumber 84 public DraftCNData(long changeNumber, byte[] data) throws ChangelogException argument 86 this.changeNumber = changeNumber; 87 this.record = decodeData(changeNumber, dat 100 decodeData(long changeNumber, byte[] data) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | DraftCNData.java | 52 private long changeNumber; field in class:DraftCNData 58 * @param changeNumber 65 public DraftCNData(long changeNumber, String baseDN, CSN csn) argument 67 this.changeNumber = changeNumber; 77 * @param changeNumber 84 public DraftCNData(long changeNumber, byte[] data) throws ChangelogException argument 86 this.changeNumber = changeNumber; 87 this.record = decodeData(changeNumber, dat 100 decodeData(long changeNumber, byte[] data) argument [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ReplicationKey.java | 46 * @param changeNumber The changeNumber to use. 48 public ReplicationKey(ChangeNumber changeNumber) argument 52 this.setData(changeNumber.toString().getBytes("UTF-8"));
|