Lines Matching refs:dbmfp
30 __memp_fopen_pp(dbmfp, path, flags, mode, pagesize)
31 DB_MPOOLFILE *dbmfp;
41 env = dbmfp->env;
58 if (dbmfp->clear_len > pagesize) {
79 (__memp_fopen(dbmfp, NULL, path, flags, mode, pagesize)), 0, ret);
92 __memp_fopen(dbmfp, mfp, path, flags, mode, pgsize)
93 DB_MPOOLFILE *dbmfp;
114 if (F_ISSET(dbmfp, MP_OPEN_CALLED))
117 env = dbmfp->env;
167 if (FLD_ISSET(dbmfp->config_flags, DB_MPOOL_NOFILE))
170 bucket = FNBUCKET(dbmfp->fileid, DB_FILE_ID_LEN);
178 if (F_ISSET(dbmfp, MP_FILEID_SET)) {
181 __memp_mpf_find(env, dbmfp, hp, path, flags,&mfp);
215 if (!FLD_ISSET(dbmfp->config_flags, DB_MPOOL_NOFILE)) {
223 F_SET(dbmfp, MP_READONLY);
255 (u_int32_t)pagesize, oflags, mode, &dbmfp->fhp);
266 dbmfp->fhp->ref = 1;
268 DB_MUTEX_PROCESS_ONLY, &dbmfp->fhp->mtx_fh)) != 0)
284 env, rpath, dbmfp->fhp, &mbytes, &bytes, NULL)) != 0) {
317 if (mfp == NULL && !F_ISSET(dbmfp, MP_FILEID_SET)) {
319 __os_fileid(env, rpath, 0, dbmfp->fileid)) != 0)
321 F_SET(dbmfp, MP_FILEID_SET);
337 if ((ret = __memp_mpf_find(env, dbmfp, hp, path, flags, &mfp) != 0))
360 if ((dbmfp->clear_len != DB_CLEARLEN_NOTSET &&
362 dbmfp->clear_len != mfp->clear_len) ||
364 (dbmfp->lsn_offset != DB_LSN_OFF_NOTSET &&
366 dbmfp->lsn_offset != mfp->lsn_off)) {
388 if (FLD_ISSET(dbmfp->config_flags, DB_MPOOL_NOFILE) &&
400 !FLD_ISSET(dbmfp->config_flags, DB_MPOOL_NOFILE) &&
401 !F_ISSET(dbmfp, MP_FILEID_SET) && (ret =
402 __os_fileid(env, rpath, 0, dbmfp->fileid)) != 0)
406 dbmfp, path, pagesize, flags, &alloc_mfp)) != 0)
459 F_SET(dbmfp, MP_MULTIVERSION);
466 dbmfp->mfp = mfp;
494 FLD_ISSET(dbmfp->config_flags, DB_MPOOL_NOFILE))
496 else if (!F_ISSET(dbmfp, MP_READONLY))
498 else if (dbmfp->ftype != 0)
513 dbmfp->addr = NULL;
515 dbmfp->len = (size_t)mbytes * MEGABYTE + bytes;
517 dbmfp->fhp, dbmfp->len, 1, &dbmfp->addr) != 0) {
518 dbmfp->addr = NULL;
524 F_SET(dbmfp, MP_OPEN_CALLED);
533 if (dbmfp->fhp != NULL)
535 if (dbmfp->mfp == tmp_dbmfp->mfp &&
536 (F_ISSET(dbmfp, MP_READONLY) ||
538 (void)__mutex_free(env, &dbmfp->fhp->mtx_fh);
539 (void)__os_closehandle(env, dbmfp->fhp);
541 dbmfp->fhp = tmp_dbmfp->fhp;
545 TAILQ_INSERT_TAIL(&dbmp->dbmfq, dbmfp, q);
573 __memp_mpf_find(env, dbmfp, hp, path, flags, mfpp)
575 DB_MPOOLFILE *dbmfp;
596 if (FLD_ISSET(dbmfp->config_flags, DB_MPOOL_NOFILE)) {
605 * it is set in the region, but not in the dbmfp.
607 if (!F_ISSET(dbmfp, MP_FILEID_SET))
608 (void)__memp_set_fileid(dbmfp,
611 if (memcmp(dbmfp->fileid, R_ADDR(dbmp->reginfo,
651 if (dbmfp->ftype != 0)
652 mfp->ftype = dbmfp->ftype;
653 if (dbmfp->clear_len != DB_CLEARLEN_NOTSET)
654 mfp->clear_len = dbmfp->clear_len;
655 if (dbmfp->lsn_offset != -1)
656 mfp->lsn_off = dbmfp->lsn_offset;
666 __memp_mpf_alloc(dbmp, dbmfp, path, pagesize, flags, retmfp)
668 DB_MPOOLFILE *dbmfp;
687 mfp->ftype = dbmfp->ftype;
689 mfp->lsn_off = dbmfp->lsn_offset;
690 mfp->clear_len = dbmfp->clear_len;
691 mfp->priority = dbmfp->priority;
692 if (dbmfp->gbytes != 0 || dbmfp->bytes != 0) {
694 (dbmfp->gbytes * (GIGABYTE / mfp->stat.st_pagesize));
696 ((dbmfp->bytes + mfp->stat.st_pagesize - 1) /
699 if (FLD_ISSET(dbmfp->config_flags, DB_MPOOL_NOFILE))
701 if (FLD_ISSET(dbmfp->config_flags, DB_MPOOL_UNLINK))
722 else if (FLD_ISSET(dbmfp->config_flags, DB_MPOOL_NOFILE))
726 if (F_ISSET(dbmfp, MP_FILEID_SET)) {
730 memcpy(p, dbmfp->fileid, DB_FILE_ID_LEN);
742 if (dbmfp->pgcookie == NULL || dbmfp->pgcookie->size == 0) {
747 NULL, dbmfp->pgcookie->size,
751 dbmfp->pgcookie->data, dbmfp->pgcookie->size);
752 mfp->pgcookie_len = dbmfp->pgcookie->size;
770 __memp_fclose_pp(dbmfp, flags)
771 DB_MPOOLFILE *dbmfp;
778 env = dbmfp->env;
787 REPLICATION_WRAP(env, (__memp_fclose(dbmfp, 0)), 0, ret);
799 __memp_fclose(dbmfp, flags)
800 DB_MPOOLFILE *dbmfp;
810 env = dbmfp->env;
828 DB_ASSERT(env, dbmfp->ref >= 1);
829 if ((ref = --dbmfp->ref) == 0 && F_ISSET(dbmfp, MP_OPEN_CALLED))
830 TAILQ_REMOVE(&dbmp->dbmfq, dbmfp, q);
836 if (ref == 0 && dbmfp->fhp != NULL && --dbmfp->fhp->ref > 0)
837 dbmfp->fhp = NULL;
843 if (dbmfp->pinref != 0) {
845 __memp_fn(dbmfp), (u_long)dbmfp->pinref);
850 if (dbmfp->addr != NULL &&
851 (ret = __os_unmapfile(env, dbmfp->addr, dbmfp->len)) != 0)
852 __db_err(env, ret, "%s", __memp_fn(dbmfp));
858 if (dbmfp->fhp != NULL) {
860 __mutex_free(env, &dbmfp->fhp->mtx_fh)) != 0 && ret == 0)
862 if ((t_ret = __os_closehandle(env, dbmfp->fhp)) != 0) {
863 __db_err(env, t_ret, "%s", __memp_fn(dbmfp));
867 dbmfp->fhp = NULL;
876 mfp = dbmfp->mfp;
878 (F_ISSET(dbmfp, MP_OPEN_CALLED) && mfp != NULL) ||
879 (!F_ISSET(dbmfp, MP_OPEN_CALLED) && mfp == NULL));
880 if (!F_ISSET(dbmfp, MP_OPEN_CALLED))
893 if (F_ISSET(dbmfp, MP_MULTIVERSION))
929 if (dbmfp->pgcookie != NULL) {
930 __os_free(env, dbmfp->pgcookie->data);
931 __os_free(env, dbmfp->pgcookie);
933 __os_free(env, dbmfp);