summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAdam Ierymenko <adam.ierymenko@gmail.com>2019-08-06 13:12:45 -0500
committerAdam Ierymenko <adam.ierymenko@gmail.com>2019-08-06 13:12:45 -0500
commit8898cb342b476bbfc4e09ea07d27309cf9265ab0 (patch)
tree29919375c3a0f72fcd55a7887e260b61623f0c48
parent9cc76d11153c9e8526612519b798c9d1ed3e4150 (diff)
downloadinfinitytier-8898cb342b476bbfc4e09ea07d27309cf9265ab0.tar.gz
infinitytier-8898cb342b476bbfc4e09ea07d27309cf9265ab0.zip
.
-rw-r--r--controller/DBMirrorSet.cpp14
1 files changed, 4 insertions, 10 deletions
diff --git a/controller/DBMirrorSet.cpp b/controller/DBMirrorSet.cpp
index 63c0f58b..f435698e 100644
--- a/controller/DBMirrorSet.cpp
+++ b/controller/DBMirrorSet.cpp
@@ -160,32 +160,26 @@ void DBMirrorSet::nodeIsOnline(const uint64_t networkId,const uint64_t memberId,
void DBMirrorSet::onNetworkUpdate(const void *db,uint64_t networkId,const nlohmann::json &network)
{
- bool modified = false;
nlohmann::json record(network);
std::lock_guard<std::mutex> l(_dbs_l);
for(auto d=_dbs.begin();d!=_dbs.end();++d) {
if (d->get() != db) {
- modified |= (*d)->save(record,false);
+ (*d)->save(record,false);
}
}
- if (modified) {
- _listener->onNetworkUpdate(this,networkId,network);
- }
+ _listener->onNetworkUpdate(this,networkId,network);
}
void DBMirrorSet::onNetworkMemberUpdate(const void *db,uint64_t networkId,uint64_t memberId,const nlohmann::json &member)
{
- bool modified = false;
nlohmann::json record(member);
std::lock_guard<std::mutex> l(_dbs_l);
for(auto d=_dbs.begin();d!=_dbs.end();++d) {
if (d->get() != db) {
- modified |= (*d)->save(record,false);
+ (*d)->save(record,false);
}
}
- if (modified) {
- _listener->onNetworkMemberUpdate(this,networkId,memberId,member);
- }
+ _listener->onNetworkMemberUpdate(this,networkId,memberId,member);
}
void DBMirrorSet::onNetworkMemberDeauthorize(const void *db,uint64_t networkId,uint64_t memberId)