/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ReplicaCursor.java | 52 private UpdateMsg currentRecord; field in class:ReplicaCursor 98 return currentRecord; 116 if (isReplicaOfflineMsgOutdated(offlineMsg1, currentRecord)) 127 currentRecord = cursor.getRecord(); 136 currentRecord = null; 139 currentRecord = offlineMsg2; 140 return currentRecord != null; 166 + " currentRecord=" + currentRecord
|
H A D | DraftCNDB.java | 523 public ChangeNumberIndexRecord currentRecord() method in class:DraftCNDB.DraftCNDBCursor 590 return getClass().getSimpleName() + " currentRecord=" + record;
|
H A D | ReplicationDB.java | 499 private UpdateMsg currentRecord; field in class:ReplicationDB.ReplServerDBCursor 689 currentRecord = null; 744 currentRecord = null; 768 currentRecord = null; 769 while (currentRecord == null) 784 return currentRecord != null; 797 currentRecord = toRecord(data.getData()); 827 return currentRecord;
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ReplicaCursor.java | 52 private UpdateMsg currentRecord; field in class:ReplicaCursor 98 return currentRecord; 116 if (isReplicaOfflineMsgOutdated(offlineMsg1, currentRecord)) 127 currentRecord = cursor.getRecord(); 136 currentRecord = null; 139 currentRecord = offlineMsg2; 140 return currentRecord != null; 166 + " currentRecord=" + currentRecord
|
H A D | DraftCNDB.java | 523 public ChangeNumberIndexRecord currentRecord() method in class:DraftCNDB.DraftCNDBCursor 590 return getClass().getSimpleName() + " currentRecord=" + record;
|
H A D | ReplicationDB.java | 499 private UpdateMsg currentRecord; field in class:ReplicationDB.ReplServerDBCursor 689 currentRecord = null; 744 currentRecord = null; 768 currentRecord = null; 769 while (currentRecord == null) 784 return currentRecord != null; 797 currentRecord = toRecord(data.getData()); 827 return currentRecord;
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
H A D | ReplicaCursor.java | 49 private UpdateMsg currentRecord; field in class:ReplicaCursor 94 return currentRecord; 112 if (isReplicaOfflineMsgOutdated(offlineMsg1, currentRecord)) 123 currentRecord = cursor.getRecord(); 132 currentRecord = null; 135 currentRecord = offlineMsg2; 136 return currentRecord != null; 162 + " currentRecord=" + currentRecord
|
H A D | BlockLogReader.java | 499 PositionStrategy positionStrategy, int keysComparison, Record<K, V> currentRecord, Record<K, V> previousRecord, 502 Record<K, V> record = currentRecord; 498 getMatchingRecord(KeyMatchingStrategy matchStrategy, PositionStrategy positionStrategy, int keysComparison, Record<K, V> currentRecord, Record<K, V> previousRecord, long previousPosition) argument
|
H A D | LogFile.java | 534 private Record<K,V> currentRecord; field in class:LogFile.LogFileCursor 567 this.currentRecord = record; 586 currentRecord = initialRecord; 593 currentRecord = reader.readRecord(); 599 return currentRecord != null; 606 return currentRecord; 659 return String.format("Cursor on log file: %s, current record: %s", logFile.logfile, currentRecord);
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | BlockLogReader.java | 505 Record<K, V> currentRecord, Record<K, V> previousRecord, long previousPosition) 508 Record<K, V> record = currentRecord; 503 getMatchingRecord(KeyMatchingStrategy matchStrategy, PositionStrategy positionStrategy, int keysComparison, boolean matchKeyIsLowerThanAnyRecord, Record<K, V> currentRecord, Record<K, V> previousRecord, long previousPosition) argument
|
H A D | LogFile.java | 516 private Record<K,V> currentRecord; field in class:LogFile.LogFileCursor 549 this.currentRecord = record; 560 currentRecord = initialRecord; 564 currentRecord = reader.readRecord(); 565 return currentRecord != null; 572 return currentRecord; 607 return String.format("Cursor on log file: %s, current record: %s", logFile.logfile, currentRecord);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | BlockLogReader.java | 505 Record<K, V> currentRecord, Record<K, V> previousRecord, long previousPosition) 508 Record<K, V> record = currentRecord; 503 getMatchingRecord(KeyMatchingStrategy matchStrategy, PositionStrategy positionStrategy, int keysComparison, boolean matchKeyIsLowerThanAnyRecord, Record<K, V> currentRecord, Record<K, V> previousRecord, long previousPosition) argument
|
H A D | LogFile.java | 516 private Record<K,V> currentRecord; field in class:LogFile.LogFileCursor 549 this.currentRecord = record; 560 currentRecord = initialRecord; 564 currentRecord = reader.readRecord(); 565 return currentRecord != null; 572 return currentRecord; 607 return String.format("Cursor on log file: %s, current record: %s", logFile.logfile, currentRecord);
|
/forgerock/openam-v13/openam-core-rest/src/main/java/org/forgerock/openam/core/rest/record/ |
H A D | DefaultDebugRecorder.java | 88 private volatile Record currentRecord; field in class:DefaultDebugRecorder 121 debug.message("Issue '{}' was recording, we stop it.", currentRecord); 132 currentRecord = record; 133 currentRecord.startRecord(); 158 return currentRecord; 166 if (currentRecord == null) { 171 debug.message("Stop recording Issue '{}'.", currentRecord); 177 currentRecord.stopRecord(); 190 archiveRecord(currentRecord); 193 debug.warning("Can't archive the issue '{}'", currentRecord, 498 private Record currentRecord; field in class:DefaultDebugRecorder.ThreadsDumpRunnable 502 ThreadsDumpRunnable(Record currentRecord) argument 538 private Record currentRecord; field in class:DefaultDebugRecorder.AutoStopFileSizeRecord 540 AutoStopFileSizeRecord(Record currentRecord) argument [all...] |
/forgerock/openam/openam-core-rest/src/main/java/org/forgerock/openam/core/rest/record/ |
H A D | DefaultDebugRecorder.java | 91 private volatile Record currentRecord; field in class:DefaultDebugRecorder 124 debug.message("Issue '{}' was recording, we stop it.", currentRecord); 135 currentRecord = record; 136 currentRecord.startRecord(); 161 return currentRecord; 169 if (currentRecord == null) { 174 debug.message("Stop recording Issue '{}'.", currentRecord); 180 currentRecord.stopRecord(); 193 archiveRecord(currentRecord); 196 debug.warning("Can't archive the issue '{}'", currentRecord, 501 private Record currentRecord; field in class:DefaultDebugRecorder.ThreadsDumpRunnable 505 ThreadsDumpRunnable(Record currentRecord) argument 541 private Record currentRecord; field in class:DefaultDebugRecorder.AutoStopFileSizeRecord 543 AutoStopFileSizeRecord(Record currentRecord) argument [all...] |