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

/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...]
H A DRecordResource.java106 Record currentRecord = debugRecorder.getCurrentRecord();
108 if (currentRecord != null) {
110 jsonValue.put(RECORD_LABEL, currentRecord.exportJson().asMap());
/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...]
H A DRecordResource.java117 Record currentRecord = debugRecorder.getCurrentRecord();
119 if (currentRecord != null) {
121 jsonValue.put(RECORD_LABEL, currentRecord.exportJson().asMap());
/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 DJEChangeNumberIndexDBCursor.java76 return isInitialized ? draftCNDbCursor.currentRecord() : null;
94 return draftCNDbCursor.currentRecord() != null;
H A DJEReplicaDBCursor.java136 final UpdateMsg currentRecord = cursor.getRecord();
137 if (currentRecord != null)
139 lastNonNullCurrentCSN = currentRecord.getCSN();
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;
H A DJEChangeNumberIndexDB.java226 final ChangeNumberIndexRecord record = cursor.currentRecord();
281 final ChangeNumberIndexRecord record = cursor.currentRecord();
H A DDraftCNDB.java523 public ChangeNumberIndexRecord currentRecord() method in class:DraftCNDB.DraftCNDBCursor
590 return getClass().getSimpleName() + " currentRecord=" + record;
/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 DJEChangeNumberIndexDBCursor.java76 return isInitialized ? draftCNDbCursor.currentRecord() : null;
94 return draftCNDbCursor.currentRecord() != null;
H A DJEReplicaDBCursor.java136 final UpdateMsg currentRecord = cursor.getRecord();
137 if (currentRecord != null)
139 lastNonNullCurrentCSN = currentRecord.getCSN();
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;
H A DJEChangeNumberIndexDB.java226 final ChangeNumberIndexRecord record = cursor.currentRecord();
281 final ChangeNumberIndexRecord record = cursor.currentRecord();
H A DDraftCNDB.java523 public ChangeNumberIndexRecord currentRecord() method in class:DraftCNDB.DraftCNDBCursor
590 return getClass().getSimpleName() + " currentRecord=" + record;
/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 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);
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
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
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);
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
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/
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);
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
/forgerock/openam-v13/openam-core-rest/src/test/java/org/forgerock/openam/core/rest/record/
H A DDefaultDebugRecorderTest.java232 Record currentRecord = recordDebugController.getCurrentRecord();
236 String threadDumpFolder = currentRecord.getFolderPath() + File.separator +
/forgerock/openam/openam-core-rest/src/test/java/org/forgerock/openam/core/rest/record/
H A DDefaultDebugRecorderTest.java234 Record currentRecord = recordDebugController.getCurrentRecord();
238 String threadDumpFolder = currentRecord.getFolderPath() + File.separator +

Completed in 126 milliseconds