diff options
author | Adam Ierymenko <adam.ierymenko@gmail.com> | 2019-08-06 13:12:45 -0500 |
---|---|---|
committer | Adam Ierymenko <adam.ierymenko@gmail.com> | 2019-08-06 13:12:45 -0500 |
commit | 8898cb342b476bbfc4e09ea07d27309cf9265ab0 (patch) | |
tree | 29919375c3a0f72fcd55a7887e260b61623f0c48 /controller | |
parent | 9cc76d11153c9e8526612519b798c9d1ed3e4150 (diff) | |
download | infinitytier-8898cb342b476bbfc4e09ea07d27309cf9265ab0.tar.gz infinitytier-8898cb342b476bbfc4e09ea07d27309cf9265ab0.zip |
.
Diffstat (limited to 'controller')
-rw-r--r-- | controller/DBMirrorSet.cpp | 14 |
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) |