in encryption/src/main/java/org/apache/solr/encryption/EncryptionUpdateLog.java [135:150]
public synchronized boolean areAllLogsEncryptedWithKeyId(String keyId, Map<String, String> commitUserData)
throws IOException {
List<TransactionLog> allLogs = getAllLogs();
if (!allLogs.isEmpty()) {
for (TransactionLog log : allLogs) {
try (FileChannel logChannel = FileChannel.open(((EncryptionTransactionLog) log).path(), StandardOpenOption.READ)) {
String logKeyRef = readEncryptionHeader(logChannel);
String logKeyId = logKeyRef == null ? null : getKeyIdFromCommit(logKeyRef, commitUserData);
if (!Objects.equals(logKeyId, keyId)) {
return false;
}
}
}
}
return true;
}