diff options
| author | Adam Ierymenko <adam.ierymenko@gmail.com> | 2018-01-12 09:18:27 -0800 |
|---|---|---|
| committer | Adam Ierymenko <adam.ierymenko@gmail.com> | 2018-01-12 09:18:27 -0800 |
| commit | cd2a4b709c583f99b21a971b15831ddea2b95e18 (patch) | |
| tree | 2997b6b127b648c8e703603a30118386ad82871c /controller/RethinkDB.cpp | |
| parent | d96aeac335e9f27d9aa1d7a447b99f500f8247ab (diff) | |
| download | infinitytier-cd2a4b709c583f99b21a971b15831ddea2b95e18.tar.gz infinitytier-cd2a4b709c583f99b21a971b15831ddea2b95e18.zip | |
Reduce maximum batcn size for status updates but increase the number of whole record commit threads.
Diffstat (limited to 'controller/RethinkDB.cpp')
| -rw-r--r-- | controller/RethinkDB.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/controller/RethinkDB.cpp b/controller/RethinkDB.cpp index b7d04571..3f730efc 100644 --- a/controller/RethinkDB.cpp +++ b/controller/RethinkDB.cpp @@ -280,7 +280,7 @@ RethinkDB::RethinkDB(EmbeddedNetworkController *const nc,const Identity &myId,co tmpobj["ts"] = i->second.first; tmpobj["phy"] = i->second.second.toIpString(tmp2); batch.emplace_back(tmpobj); - if (batch.size() >= 1024) { + if (batch.size() >= 256) { R::db(this->_db).table("MemberStatus",R::optargs("read_mode","outdated")).insert(batch,R::optargs("conflict","update")).run(*rdb); batch.clear(); } |