Searched refs:changeNumber (Results 1 - 25 of 241) sorted by relevance

12345678910

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/
H A DFakeOperation.java43 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 DPendingChanges.java88 * @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 DFakeOperation.java43 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 DPendingChanges.java88 * @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 DFakeOperation.java43 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 DPendingChanges.java88 * @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 DDeleteContext.java40 * @param changeNumber The change number of the Delete Operation.
43 public DeleteContext(ChangeNumber changeNumber, String entryUUID) argument
45 super(changeNumber, entryUUID);
H A DModifyContext.java42 * @param changeNumber The change number of the operation.
45 public ModifyContext(ChangeNumber changeNumber, String entryUUID) argument
47 super(changeNumber, entryUUID);
H A DOperationContext.java48 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 DAddContext.java46 * @param changeNumber The change number of the add operation.
50 public AddContext(ChangeNumber changeNumber, String entryUUID, argument
53 super(changeNumber, entryUUID);
H A DModifyDnContext.java43 * @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 DDeleteContext.java40 * @param changeNumber The change number of the Delete Operation.
43 public DeleteContext(ChangeNumber changeNumber, String entryUUID) argument
45 super(changeNumber, entryUUID);
H A DModifyContext.java42 * @param changeNumber The change number of the operation.
45 public ModifyContext(ChangeNumber changeNumber, String entryUUID) argument
47 super(changeNumber, entryUUID);
H A DOperationContext.java48 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 DAddContext.java46 * @param changeNumber The change number of the add operation.
50 public AddContext(ChangeNumber changeNumber, String entryUUID, argument
53 super(changeNumber, entryUUID);
H A DModifyDnContext.java43 * @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 DDeleteContext.java40 * @param changeNumber The change number of the Delete Operation.
43 public DeleteContext(ChangeNumber changeNumber, String entryUUID) argument
45 super(changeNumber, entryUUID);
H A DModifyContext.java42 * @param changeNumber The change number of the operation.
45 public ModifyContext(ChangeNumber changeNumber, String entryUUID) argument
47 super(changeNumber, entryUUID);
H A DOperationContext.java48 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 DChangeNumberIndexRecord.java40 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 DChangeNumberIndexRecord.java40 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 DChangeNumberIndexRecord.java40 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 DDraftCNData.java52 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 DDraftCNData.java52 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 DReplicationKey.java46 * @param changeNumber The changeNumber to use.
48 public ReplicationKey(ChangeNumber changeNumber) argument
52 this.setData(changeNumber.toString().getBytes("UTF-8"));

Completed in 114 milliseconds

12345678910