db/mp/mp_bh.c

43 	DB_MPOOLFILE *dbmfp;
60 	for (dbmfp = TAILQ_FIRST(&dbmp->dbmfq);
61 	    dbmfp != NULL; dbmfp = TAILQ_NEXT(dbmfp, q))
62 		if (dbmfp->mfp == mfp) {
63 			if (F_ISSET(dbmfp, MP_READONLY) &&
64 			    __memp_upgrade(dbmp, dbmfp, mfp)) {
73 			++dbmfp->ref;
78 	if (dbmfp != NULL)
126 	    0, 0, mfp->stat.st_pagesize, 0, NULL, &dbmfp) != 0)
129 found:	ret = __memp_pgwrite(dbmfp, bhp, restartp, wrotep);
133 		--dbmfp->ref;
147 __memp_pgread(dbmfp, bhp, can_create)
148 	DB_MPOOLFILE *dbmfp;
159 	dbmp = dbmfp->dbmp;
160 	mfp = dbmfp->mfp;
172 	if (dbmfp->fd == -1)
180 		db_io.fd_io = dbmfp->fd;
183 		    F_ISSET(dbmp, MP_LOCKHANDLE) ? dbmfp->mutexp : NULL;
201 			    __memp_fn(dbmfp), (u_long)bhp->pgno);
223 	ret = mfp->ftype == 0 ? 0 : __memp_pg(dbmfp, bhp, 1);
257 __memp_pgwrite(dbmfp, bhp, restartp, wrotep)
258 	DB_MPOOLFILE *dbmfp;
273 	dbmp = dbmfp->dbmp;
276 	mfp = dbmfp->mfp;
333 		if ((ret = __memp_pg(dbmfp, bhp, 0)) != 0)
338 	if (dbmfp->fd == -1) {
339 		LOCKHANDLE(dbmp, dbmfp->mutexp);
340 		if (dbmfp->fd == -1 && ((ret = __db_appname(dbenv,
342 		    &dbmfp->fd, NULL)) != 0 || dbmfp->fd == -1)) {
343 			UNLOCKHANDLE(dbmp, dbmfp->mutexp);
348 		UNLOCKHANDLE(dbmp, dbmfp->mutexp);
352 	db_io.fd_io = dbmfp->fd;
354 	db_io.mutexp = F_ISSET(dbmp, MP_LOCKHANDLE) ? dbmfp->mutexp : NULL;
425 		syncfail = __os_fsync(dbmfp->fd) != 0;
434 	    __memp_fn(dbmfp), fail, (u_long)bhp->pgno);
460 __memp_pg(dbmfp, bhp, is_pgin)
461 	DB_MPOOLFILE *dbmfp;
471 	dbmp = dbmfp->dbmp;
472 	mfp = dbmfp->mfp;
508 	    __memp_fn(dbmfp), is_pgin ? "pgin" : "pgout", (u_long)bhp->pgno);
549 __memp_upgrade(dbmp, dbmfp, mfp)
551 	DB_MPOOLFILE *dbmfp;
563 	if (F_ISSET(dbmfp, MP_UPGRADE))
567 	if (F_ISSET(dbmfp, MP_UPGRADE_FAIL))
579 		F_SET(dbmfp, MP_UPGRADE_FAIL);
583 		(void)__os_close(dbmfp->fd);
584 		dbmfp->fd = fd;
585 		F_SET(dbmfp, MP_UPGRADE);