The_Great_Archive/libretroshare
1
0
Fork 0
mirror of https://github.com/RetroShare/libretroshare.git synced 2026-09-12 19:50:03 +05:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #301 from jolavillette/fix/email-unconditional-save

Browse Source 
fix(mail): avoid unconditional periodic saves of email database
This commit is contained in:
csoler 2026-05-24 16:17:39 +02:00 committed by GitHub
commit 357cf730ff
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/services/p3msgservice.cc
View File

@ -395,6 +395,7 @@ void p3MsgService::checkSizeAndSendMessage(RsMsgItem *msg,const RsPeerId& destin
int p3MsgService::checkOutgoingMessages()
{
bool changed = false;
auto pEvent = std::make_shared<RsMailStatusEvent>();
pEvent->mMailStatusEventCode = RsMailStatusEventCode::MESSAGE_SENT;
@ -421,6 +422,7 @@ int p3MsgService::checkOutgoingMessages()
++tmp;
msgOutgoing.erase(mit);
mit = tmp;
changed = true;
continue;
}
@ -454,6 +456,7 @@ int p3MsgService::checkOutgoingMessages()
++tmp;
mit->second.erase(fit);
fit = tmp;
changed = true;
continue;
}
@ -470,6 +473,7 @@ int p3MsgService::checkOutgoingMessages()
{
minfo.flags |= RS_MSG_FLAGS_ROUTED;
minfo.flags |= RS_MSG_FLAGS_DISTANT;
changed = true;
#ifdef DEBUG_DISTANT_MSG
RsDbg() << "Message id " << mit->first << " is distant: kept in outgoing, and marked as ROUTED" << std::endl;
@ -491,6 +495,7 @@ int p3MsgService::checkOutgoingMessages()
++tmp;
mit->second.erase(fit);
fit = tmp;
changed = true;
continue;
}
else
@ -509,6 +514,7 @@ int p3MsgService::checkOutgoingMessages()
++tmp;
msgOutgoing.erase(mit);
mit=tmp;
changed = true;
}
else
++mit;
@ -518,7 +524,11 @@ int p3MsgService::checkOutgoingMessages()
if(rsEvents && !pEvent->mChangedMsgIds.empty())
rsEvents->postEvent(pEvent);
IndicateConfigChanged(RsConfigMgr::CheckPriority::SAVE_NOW);
if(changed)
{
// RsDbg() << "MAIL: checkOutgoingMessages() triggering IndicateConfigChanged(SAVE_NOW)" << std::endl;
IndicateConfigChanged(RsConfigMgr::CheckPriority::SAVE_NOW);
}
return 0;
}