Signal/Signal-Server
1
0
Fork 0
mirror of https://github.com/signalapp/Signal-Server synced 2026-09-01 22:40:52 +01:00
Code Issues Packages Projects Releases Wiki Activity

Log exceptions when fetching end-of-queue keys

Browse Source
This commit is contained in:
Jon Chambers
2026-07-10 14:29:44 -07:00
committed by GitHub
parent 25fdc95843
commit 688d3a2212
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
service/src/main/java/org/whispersystems/textsecuregcm/storage/foundationdb/FoundationDbMessageStream.java
+10 -1
View File
@@ -18,6 +18,8 @@ import java.util.UUID;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Flow;
import java.util.concurrent.ScheduledExecutorService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.whispersystems.textsecuregcm.entities.MessageProtos;
import org.whispersystems.textsecuregcm.identity.AciServiceIdentifier;
import org.whispersystems.textsecuregcm.storage.MessageStream;
@@ -62,6 +64,8 @@ public class FoundationDbMessageStream implements MessageStream {
private static final Comparator<FoundationDbMessageStreamEntry.Message> STREAM_ENTRY_TIMESTAMP_COMPARATOR =
Comparator.comparingLong(streamEntry -> streamEntry.partialEnvelope().getServerTimestamp());
private static final Logger logger = LoggerFactory.getLogger(FoundationDbMessageStream.class);
FoundationDbMessageStream(final FoundationDbMessageStore foundationDbMessageStore,
final AciServiceIdentifier aciServiceIdentifier,
final byte deviceId,
@@ -240,12 +244,17 @@ public class FoundationDbMessageStream implements MessageStream {
private CompletableFuture<Optional<KeySelector>> getEndOfQueueKeyExclusive(final Database database) {
return database.runAsync(transaction ->
transaction.getRange(deviceQueueSubspace.range(), 1, true, StreamingMode.EXACT).asList())
.thenApply(items -> {
.<Optional<KeySelector>>thenApply(items -> {
if (items.isEmpty()) {
return Optional.empty();
}
assert items.size() == 1;
return Optional.of(KeySelector.firstGreaterThan(items.getFirst().getKey()));
})
.whenComplete((_, throwable) -> {
if (throwable != null) {
logger.warn("Failed to fetch end-of-queue key", throwable);
}
});
}