Kaladaran/briar
0
0
Fork 0
mirror of https://code.briarproject.org/briar/briar.git synced 2026-02-17 13:19:52 +01:00
Code Issues Projects Releases Wiki Activity

Add some logging to ClientVersioningManagerImpl

Browse Source
This commit is contained in:
Sebastian Kürten
2023-07-24 16:09:24 +02:00
parent 952ee42ad1
commit 411ace13aa
1 changed files with 46 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
bramble-core/src/main/java/org/briarproject/bramble/versioning/ClientVersioningManagerImpl.java
View File

@@ -30,6 +30,9 @@ import org.briarproject.bramble.api.versioning.ClientVersioningManager;
import org.briarproject.bramble.api.versioning.event.ClientVersionUpdatedEvent; import org.briarproject.bramble.api.versioning.event.ClientVersionUpdatedEvent;
import org.briarproject.nullsafety.NotNullByDefault; import org.briarproject.nullsafety.NotNullByDefault;
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collection; import java.util.Collection;
import java.util.Collections; import java.util.Collections;
@@ -128,12 +131,55 @@ class ClientVersioningManagerImpl implements ClientVersioningManager,
@Override @Override
public void onDatabaseOpened(Transaction txn) throws DbException { public void onDatabaseOpened(Transaction txn) throws DbException {
System.out.println("onDatabaseOpened " + localGroup.getId());
for (Contact c : db.getContacts(txn)) {
try {
System.out.println(
"find latest updates for " + c.getId().getInt());
LatestUpdates latestUpdates = findLatestUpdates(txn, c.getId());
if (latestUpdates == null) {
System.out.println("none found");
} else {
if (latestUpdates.local != null) {
System.out.printf("local: %s; %d%n",
latestUpdates.local.messageId,
latestUpdates.local.updateVersion);
Update update =
loadUpdate(txn, latestUpdates.local.messageId);
printUpdate(update);
}
if (latestUpdates.remote != null) {
System.out.printf("remote: %s; %d%n",
latestUpdates.remote.messageId,
latestUpdates.remote.updateVersion);
Update update =
loadUpdate(txn, latestUpdates.remote.messageId);
printUpdate(update);
}
}
} catch (FormatException e) {
throw new RuntimeException(e);
}
}
if (db.containsGroup(txn, localGroup.getId())) return; if (db.containsGroup(txn, localGroup.getId())) return;
db.addGroup(txn, localGroup); db.addGroup(txn, localGroup);
// Set things up for any pre-existing contacts // Set things up for any pre-existing contacts
for (Contact c : db.getContacts(txn)) addingContact(txn, c); for (Contact c : db.getContacts(txn)) addingContact(txn, c);
} }
private void printUpdate(Update update) {
System.out.printf("update version: %d%n",
update.updateVersion);
for (ClientState state : update.states) {
System.out.printf("id: %s, major: %d, minor: %d, active: %b, %n",
state.clientVersion.getClientId().getString(),
state.clientVersion.getClientMajorVersion()
.getMajorVersion(),
state.clientVersion.getMinorVersion(),
state.active);
}
}
@Override @Override
public void startService() throws ServiceException { public void startService() throws ServiceException {
List<ClientVersion> versions = new ArrayList<>(clients); List<ClientVersion> versions = new ArrayList<>(clients);