Save freelist using proper mdb_cursor_put().

(Restructuring for upcoming mdb_page_spill work.)
mdb_freelist_save() can't just Get() the destination, since
mdb_page_spill() may have put the destination in the read-only map.

TODO: Can this new put() modify the freelist, which would break it? The
final iteration's put() can shorten the node, the rest uses MDB_CURRENT.

We could set P_KEEP on dirty freeDB leaves and ovpages, since they are
all about to be modified.  But the code in this commit must stay anyway,
if mdb should support dropping a 256G DB. I.e. too big for dirty_list.
vmware
Hallvard Furuseth 12 years ago committed by Howard Chu
parent 08373439a6
commit 6741f9c0ef
  1. 27
      libraries/liblmdb/mdb.c

@ -2171,25 +2171,32 @@ mdb_freelist_save(MDB_txn *txn)
total_room += head_room; total_room += head_room;
} }
/* Fill in the reserved, touched me_pghead records. Avoid write ops /* Fill in the reserved, touched me_pghead records */
* so they cannot rearrange anything, just read the destinations.
*/
rc = MDB_SUCCESS; rc = MDB_SUCCESS;
if (mop_len) { if (mop_len) {
MDB_val key, data; MDB_val key, data;
mop += mop_len + 1; mop += mop_len;
rc = mdb_cursor_first(&mc, &key, &data); rc = mdb_cursor_first(&mc, &key, &data);
for (; !rc; rc = mdb_cursor_next(&mc, &key, &data, MDB_NEXT)) { for (; !rc; rc = mdb_cursor_next(&mc, &key, &data, MDB_NEXT)) {
MDB_IDL dest = data.mv_data; unsigned flags = MDB_CURRENT;
txnid_t id = *(txnid_t *)key.mv_data;
ssize_t len = (ssize_t)(data.mv_size / sizeof(MDB_ID)) - 1; ssize_t len = (ssize_t)(data.mv_size / sizeof(MDB_ID)) - 1;
MDB_ID save;
assert(len >= 0 && *(txnid_t*)key.mv_data <= env->me_pglast); assert(len >= 0 && id <= env->me_pglast);
if (len > mop_len) key.mv_data = &id;
if (len > mop_len) {
len = mop_len; len = mop_len;
*dest++ = len; data.mv_size = (len + 1) * sizeof(MDB_ID);
memcpy(dest, mop -= len, len * sizeof(MDB_ID)); flags = 0;
if (! (mop_len -= len)) }
data.mv_data = mop -= len;
save = mop[0];
mop[0] = len;
rc = mdb_cursor_put(&mc, &key, &data, flags);
mop[0] = save;
if (rc || !(mop_len -= len))
break; break;
} }
} }

Loading…
Cancel
Save