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

return number of confirm messages sent

Browse Source
This commit is contained in:
ameba23
2022-02-24 13:12:03 +01:00
parent f29278b436
commit 5e0f7219c5
1 changed files with 2 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
briar-core/src/main/java/org/briarproject/briar/remotewipe/RemoteWipeManagerImpl.java
View File

@@ -327,33 +327,14 @@ public class RemoteWipeManagerImpl extends ConversationClientImpl
messageTracker.trackOutgoingMessage(txn, m);
}
public void sendConfirmMessages(Transaction txn)
public int sendConfirmMessages(Transaction txn)
throws DbException, FormatException {
List<ContactId> wipers = getWiperContactIds(txn);
for (ContactId c : wipers) {
Contact contact = contactManager.getContact(txn, c);
sendConfirmMessage(txn, contact);
}
// boolean allSent = true;
// do {
// for (MessageId confirmMessage: confirmMessages) {
// if (db.getMessageState(txn, confirmMessage) == PENDING) allSent = false;
// }
// if (!allSent) {
// try {
// Thread.sleep(100);
// } catch (InterruptedException e) {
// allSent = true;
// }
// }
// } while(allSent == false);
}
public void sleep() {
try {
Thread.sleep(5000);
} catch (InterruptedException ignored) {}
return wipers.size();
}
private void sendConfirmMessage(Transaction txn, Contact contact)
@@ -373,17 +354,6 @@ public class RemoteWipeManagerImpl extends ConversationClientImpl
);
clientHelper.addLocalMessage(txn, m, meta, true, false);
messageTracker.trackOutgoingMessage(txn, m);
// Find the id of this message
// List<MessageId> messageIds = (List<MessageId>) db.getMessageIds(txn, g);
// Message newestMsg = null;
// for (MessageId id : messageIds) {
// Message msg = db.getMessage(txn, id);
// if (newestMsg == null || msg.getTimestamp() > newestMsg.getTimestamp()) {
// newestMsg = msg;
// }
// }
// return newestMsg.getId();
}
public void wipe(Transaction txn, Contact contact)