Searched defs:currentRecord (Results 1 - 15 of 15) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/
H A DReplicaCursor.java52 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 DDraftCNDB.java523 public ChangeNumberIndexRecord currentRecord() method in class:DraftCNDB.DraftCNDBCursor
590 return getClass().getSimpleName() + " currentRecord=" + record;
H A DReplicationDB.java499 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 DReplicaCursor.java52 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 DDraftCNDB.java523 public ChangeNumberIndexRecord currentRecord() method in class:DraftCNDB.DraftCNDBCursor
590 return getClass().getSimpleName() + " currentRecord=" + record;
H A DReplicationDB.java499 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 DReplicaCursor.java49 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 DBlockLogReader.java499 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 DLogFile.java534 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 DBlockLogReader.java505 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 DLogFile.java516 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 DBlockLogReader.java505 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 DLogFile.java516 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 DDefaultDebugRecorder.java88 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 DDefaultDebugRecorder.java91 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...]

Completed in 143 milliseconds