Git-Mirrors/RetroShare
1
0
Fork 0
mirror of https://github.com/RetroShare/RetroShare.git synced 2025-01-12 07:59:29 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Request pull from peers when GXS message is created

Browse Source
This commit is contained in:
Gioacchino Mazzurco 2021-03-14 17:15:00 +01:00
parent b42323013e
commit 6295e91304
No known key found for this signature in database
GPG Key ID: A1FBCA3872E87051
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
libretroshare/src/gxs/rsgenexchange.cc
View File

@ -2286,8 +2286,9 @@ bool RsGenExchange::processGrpMask(const RsGxsGroupId& grpId, ContentValue &grpC
void RsGenExchange::publishMsgs() void RsGenExchange::publishMsgs()
{ {
bool atLeastOneMessageCreatedSuccessfully = false;
RS_STACK_MUTEX(mGenMtx) ; RS_STACK_MUTEX(mGenMtx);
rstime_t now = time(NULL); rstime_t now = time(NULL);
@ -2464,6 +2465,8 @@ void RsGenExchange::publishMsgs()
// add to published to allow acknowledgement // add to published to allow acknowledgement
mMsgNotify.insert(std::make_pair(mit->first, std::make_pair(grpId, msgId))); mMsgNotify.insert(std::make_pair(mit->first, std::make_pair(grpId, msgId)));
mDataAccess->updatePublicRequestStatus(mit->first, RsTokenService::COMPLETE); mDataAccess->updatePublicRequestStatus(mit->first, RsTokenService::COMPLETE);
atLeastOneMessageCreatedSuccessfully = true;
} }
else else
{ {
@ -2497,6 +2500,8 @@ void RsGenExchange::publishMsgs()
mNotifications.push_back(ch); mNotifications.push_back(ch);
} }
if(atLeastOneMessageCreatedSuccessfully) mNetService->requestPull();
} }
RsGenExchange::ServiceCreate_Return RsGenExchange::service_CreateGroup(RsGxsGrpItem* /* grpItem */, RsGenExchange::ServiceCreate_Return RsGenExchange::service_CreateGroup(RsGxsGrpItem* /* grpItem */,