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 | |
| 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.
| -rw-r--r-- | controller/RethinkDB.cpp | 2 | ||||
| -rw-r--r-- | controller/RethinkDB.hpp | 2 |
2 files changed, 2 insertions, 2 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(); } diff --git a/controller/RethinkDB.hpp b/controller/RethinkDB.hpp index bce8bdef..ab2611c0 100644 --- a/controller/RethinkDB.hpp +++ b/controller/RethinkDB.hpp @@ -23,7 +23,7 @@ #include "DB.hpp" -#define ZT_CONTROLLER_RETHINKDB_COMMIT_THREADS 2 +#define ZT_CONTROLLER_RETHINKDB_COMMIT_THREADS 8 namespace ZeroTier { |