From 464dcf87426614672ff9be1e0b10f0e8b2552ba5 Mon Sep 17 00:00:00 2001 From: Torsten Grote Date: Thu, 20 Jun 2019 12:18:43 -0300 Subject: [PATCH] send attachments one after the other with delay --- .../briar/messaging/MessagingManagerImpl.java | 22 ++++++++++--------- 1 file changed, 12 insertions(+), 10 deletions(-) diff --git a/briar-core/src/main/java/org/briarproject/briar/messaging/MessagingManagerImpl.java b/briar-core/src/main/java/org/briarproject/briar/messaging/MessagingManagerImpl.java index 5b42cfb2d..304c1e47d 100644 --- a/briar-core/src/main/java/org/briarproject/briar/messaging/MessagingManagerImpl.java +++ b/briar-core/src/main/java/org/briarproject/briar/messaging/MessagingManagerImpl.java @@ -253,18 +253,20 @@ class MessagingManagerImpl implements MessagingManager, IncomingMessageHook, } // Mark attachments as shared and permanent now we're ready to send // FIXME: Revert - scheduler.schedule(() -> { - try { - db.transaction(false, txn1 -> { - for (AttachmentHeader a : m.getAttachmentHeaders()) { + int i = 15; + for (AttachmentHeader a : m.getAttachmentHeaders()) { + scheduler.schedule(() -> { + try { + db.transaction(false, txn1 -> { db.setMessageShared(txn1, a.getMessageId()); db.setMessagePermanent(txn1, a.getMessageId()); - } - }); - } catch (DbException e) { - logException(LOG, WARNING, e); - } - }, 30, SECONDS); + }); + } catch (DbException e) { + logException(LOG, WARNING, e); + } + }, i, SECONDS); + i *= 2; + } clientHelper.addLocalMessage(txn, m.getMessage(), meta, true, false); messageTracker.trackOutgoingMessage(txn, m.getMessage());