dn724/dncurrency
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions 1

Clean up database environment size resizing code.

Browse source
This commit is contained in:
clemahieu 2017-04-09 18:58:38 -05:00
commit eae2e6d073
1 changed files with 6 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

11
rai/utility.cpp
View file

@ -113,9 +113,11 @@ void rai::mdb_env::handle_environment_sizing ()
mdb_env_stat (environment, &stats); mdb_env_stat (environment, &stats);
MDB_envinfo info; MDB_envinfo info;
mdb_env_info (environment, &info); mdb_env_info (environment, &info);
size_t load (info.me_last_pgno * stats.ms_psize); double used_space (info.me_last_pgno * stats.ms_psize);
auto slack (info.me_mapsize - load); double needed_space (used_space * 1.25);
if (slack < (rai::database_size_increment / 4)) size_t increments_needed ((needed_space / database_size_increment) + 1);
size_t environment_size (increments_needed * database_size_increment);
if (info.me_mapsize < environment_size)
{ {
if (!resizing.exchange (true)) if (!resizing.exchange (true))
{ {
@ -124,8 +126,7 @@ void rai::mdb_env::handle_environment_sizing ()
{ {
open_notify.wait (lock_l); open_notify.wait (lock_l);
} }
auto next_size (((info.me_mapsize / database_size_increment) + 1) * database_size_increment); mdb_env_set_mapsize (environment, environment_size);
mdb_env_set_mapsize (environment, next_size);
resizing = false; resizing = false;
resize_notify.notify_all (); resize_notify.notify_all ();
} }