Lines Matching refs:mfp
117 MPOOLFILE *mfp;
134 mfp = dbmfp->mfp;
135 mvcc = mfp->multiversion;
136 mf_offset = R_OFFSET(dbmp->reginfo, mfp);
186 MUTEX_LOCK(env, mfp->mutex);
187 *pgnoaddr = mfp->last_pgno;
188 MUTEX_UNLOCK(env, mfp->mutex);
225 F_ISSET(mfp, MP_CAN_MMAP) && *pgnoaddr <= mfp->orig_last_pgno) {
227 (*pgnoaddr * mfp->stat.st_pagesize);
228 STAT(++mfp->stat.st_map);
237 MP_GET_BUCKET(env, mfp, *pgnoaddr, &infop, hp, ret);
340 __memp_free(infop, mfp, alloc_bhp);
368 ++mfp->stat.st_cache_hit;
447 __memp_fns(dbmp, mfp), (u_long)*pgnoaddr);
456 MUTEX_LOCK(env, mfp->mutex);
457 if (*pgnoaddr > mfp->last_pgno)
458 mfp->last_pgno = *pgnoaddr;
459 MUTEX_UNLOCK(env, mfp->mutex);
533 MUTEX_LOCK(env, mfp->mutex);
537 if (mfp->maxpgno != 0 &&
538 mfp->last_pgno >= mfp->maxpgno) {
541 __memp_fn(dbmfp), (u_long)mfp->maxpgno);
544 *pgnoaddr = mfp->last_pgno + 1;
547 if (mfp->maxpgno != 0 && *pgnoaddr > mfp->maxpgno) {
550 __memp_fn(dbmfp), (u_long)mfp->maxpgno);
553 extending = *pgnoaddr > mfp->last_pgno;
556 ret = *pgnoaddr > mfp->last_pgno ? DB_PAGE_NOTFOUND : 0;
559 MUTEX_UNLOCK(env, mfp->mutex);
575 __memp_alloc(dbmp, infop, mfp, 0, NULL, &alloc_bhp)) != 0)
586 * If we are extending the file, we'll need the mfp lock
590 MUTEX_LOCK(env, mfp->mutex);
617 if (flags == DB_MPOOL_NEW && *pgnoaddr != mfp->last_pgno + 1) {
618 *pgnoaddr = mfp->last_pgno + 1;
625 * and we're holding the mfp locked.
627 MUTEX_UNLOCK(env, mfp->mutex);
630 __memp_free(infop, mfp, alloc_bhp);
640 * We released the mfp lock, so another thread might have
645 if (*pgnoaddr > mfp->last_pgno)
646 mfp->last_pgno = *pgnoaddr;
648 MUTEX_UNLOCK(env, mfp->mutex);
690 __memp_free(infop, mfp, alloc_bhp);
768 MVCC_MPROTECT(bhp->buf, mfp->stat.st_pagesize,
770 if (mfp->clear_len == DB_CLEARLEN_NOTSET)
771 memset(bhp->buf, 0, mfp->stat.st_pagesize);
773 memset(bhp->buf, 0, mfp->clear_len);
775 memset(bhp->buf + mfp->clear_len, CLEAR_BYTE,
776 mfp->stat.st_pagesize - mfp->clear_len);
780 if (flags == DB_MPOOL_CREATE && mfp->ftype != 0)
783 STAT(++mfp->stat.st_page_create);
786 STAT(++mfp->stat.st_cache_miss);
790 MUTEX_LOCK(env, mfp->mutex);
791 ++mfp->block_cnt;
792 MUTEX_UNLOCK(env, mfp->mutex);
853 MVCC_MPROTECT(bhp->buf, mfp->stat.st_pagesize,
868 MVCC_MPROTECT(bhp->buf, mfp->stat.st_pagesize,
880 (ret = __memp_bh_settxn(dbmp, mfp, alloc_bhp, td)) != 0)
883 memset(alloc_bhp->buf, 0, mfp->stat.st_pagesize);
886 memcpy(alloc_bhp->buf, bhp->buf, mfp->stat.st_pagesize);
894 MVCC_MPROTECT(bhp->buf, mfp->stat.st_pagesize, 0);
899 MUTEX_LOCK(env, mfp->mutex);
900 ++mfp->block_cnt;
901 MUTEX_UNLOCK(env, mfp->mutex);
906 (ret = __memp_bh_settxn(dbmp, mfp, bhp, td)) != 0)
932 MVCC_MPROTECT(bhp->buf, mfp->stat.st_pagesize, PROT_READ |
940 DB_ASSERT(env, !mfp->multiversion ||
1027 __memp_free(infop, mfp, alloc_bhp);