|
|
|
@ -467,7 +467,12 @@ void mdb_txn_safe::allow_new_txns()
|
|
|
|
|
creation_gate.clear();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void lmdb_resized(MDB_env *env)
|
|
|
|
|
void mdb_txn_safe::increment_txns(int i)
|
|
|
|
|
{
|
|
|
|
|
num_active_txns += i;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void lmdb_resized(MDB_env *env, int isactive)
|
|
|
|
|
{
|
|
|
|
|
mdb_txn_safe::prevent_new_txns();
|
|
|
|
|
|
|
|
|
@ -478,7 +483,11 @@ void lmdb_resized(MDB_env *env)
|
|
|
|
|
mdb_env_info(env, &mei);
|
|
|
|
|
uint64_t old = mei.me_mapsize;
|
|
|
|
|
|
|
|
|
|
if (isactive)
|
|
|
|
|
mdb_txn_safe::increment_txns(-1);
|
|
|
|
|
mdb_txn_safe::wait_no_active_txns();
|
|
|
|
|
if (isactive)
|
|
|
|
|
mdb_txn_safe::increment_txns(1);
|
|
|
|
|
|
|
|
|
|
int result = mdb_env_set_mapsize(env, 0);
|
|
|
|
|
if (result)
|
|
|
|
@ -496,7 +505,7 @@ inline int lmdb_txn_begin(MDB_env *env, MDB_txn *parent, unsigned int flags, MDB
|
|
|
|
|
{
|
|
|
|
|
int res = mdb_txn_begin(env, parent, flags, txn);
|
|
|
|
|
if (res == MDB_MAP_RESIZED) {
|
|
|
|
|
lmdb_resized(env);
|
|
|
|
|
lmdb_resized(env, 1);
|
|
|
|
|
res = mdb_txn_begin(env, parent, flags, txn);
|
|
|
|
|
}
|
|
|
|
|
return res;
|
|
|
|
@ -506,7 +515,7 @@ inline int lmdb_txn_renew(MDB_txn *txn)
|
|
|
|
|
{
|
|
|
|
|
int res = mdb_txn_renew(txn);
|
|
|
|
|
if (res == MDB_MAP_RESIZED) {
|
|
|
|
|
lmdb_resized(mdb_txn_env(txn));
|
|
|
|
|
lmdb_resized(mdb_txn_env(txn), 0);
|
|
|
|
|
res = mdb_txn_renew(txn);
|
|
|
|
|
}
|
|
|
|
|
return res;
|
|
|
|
|