|
|
@ -3410,15 +3410,16 @@ mdb_page_flush(MDB_txn *txn, int keep) |
|
|
|
MDB_ID2L dl = txn->mt_u.dirty_list; |
|
|
|
MDB_ID2L dl = txn->mt_u.dirty_list; |
|
|
|
unsigned psize = env->me_psize, j; |
|
|
|
unsigned psize = env->me_psize, j; |
|
|
|
int i, pagecount = dl[0].mid, rc; |
|
|
|
int i, pagecount = dl[0].mid, rc; |
|
|
|
size_t size = 0, pos = 0; |
|
|
|
size_t size = 0; |
|
|
|
|
|
|
|
off_t pos = 0; |
|
|
|
pgno_t pgno = 0; |
|
|
|
pgno_t pgno = 0; |
|
|
|
MDB_page *dp = NULL; |
|
|
|
MDB_page *dp = NULL; |
|
|
|
#ifdef _WIN32 |
|
|
|
#ifdef _WIN32 |
|
|
|
OVERLAPPED ov; |
|
|
|
OVERLAPPED ov; |
|
|
|
#else |
|
|
|
#else |
|
|
|
struct iovec iov[MDB_COMMIT_PAGES]; |
|
|
|
struct iovec iov[MDB_COMMIT_PAGES]; |
|
|
|
ssize_t wpos = 0, wsize = 0, wres; |
|
|
|
ssize_t wsize = 0, wres; |
|
|
|
size_t next_pos = 1; /* impossible pos, so pos != next_pos */ |
|
|
|
off_t wpos = 0, next_pos = 1; /* impossible pos, so pos != next_pos */ |
|
|
|
int n = 0; |
|
|
|
int n = 0; |
|
|
|
#endif |
|
|
|
#endif |
|
|
|
|
|
|
|
|
|
|
|