PostgreSQL Source Code
git master
|
#include "postgres.h"
#include <unistd.h>
#include <fcntl.h>
#include <sys/file.h>
#include "access/xlogutils.h"
#include "commands/tablespace.h"
#include "common/file_utils.h"
#include "miscadmin.h"
#include "pg_trace.h"
#include "pgstat.h"
#include "storage/bufmgr.h"
#include "storage/fd.h"
#include "storage/md.h"
#include "storage/relfilelocator.h"
#include "storage/smgr.h"
#include "storage/sync.h"
#include "utils/memutils.h"
Go to the source code of this file.
Data Structures | |
struct | _MdfdVec |
Macros | |
#define | INIT_MD_FILETAG(a, xx_rlocator, xx_forknum, xx_segno) |
#define | EXTENSION_FAIL (1 << 0) |
#define | EXTENSION_RETURN_NULL (1 << 1) |
#define | EXTENSION_CREATE (1 << 2) |
#define | EXTENSION_CREATE_RECOVERY (1 << 3) |
#define | EXTENSION_DONT_CHECK_SIZE (1 << 4) |
#define | EXTENSION_DONT_OPEN (1 << 5) |
Typedefs | |
typedef struct _MdfdVec | MdfdVec |
Functions | |
static void | mdunlinkfork (RelFileLocatorBackend rlocator, ForkNumber forknum, bool isRedo) |
static MdfdVec * | mdopenfork (SMgrRelation reln, ForkNumber forknum, int behavior) |
static void | register_dirty_segment (SMgrRelation reln, ForkNumber forknum, MdfdVec *seg) |
static void | register_unlink_segment (RelFileLocatorBackend rlocator, ForkNumber forknum, BlockNumber segno) |
static void | register_forget_request (RelFileLocatorBackend rlocator, ForkNumber forknum, BlockNumber segno) |
static void | _fdvec_resize (SMgrRelation reln, ForkNumber forknum, int nseg) |
static char * | _mdfd_segpath (SMgrRelation reln, ForkNumber forknum, BlockNumber segno) |
static MdfdVec * | _mdfd_openseg (SMgrRelation reln, ForkNumber forknum, BlockNumber segno, int oflags) |
static MdfdVec * | _mdfd_getseg (SMgrRelation reln, ForkNumber forknum, BlockNumber blkno, bool skipFsync, int behavior) |
static BlockNumber | _mdnblocks (SMgrRelation reln, ForkNumber forknum, MdfdVec *seg) |
static int | _mdfd_open_flags (void) |
void | mdinit (void) |
bool | mdexists (SMgrRelation reln, ForkNumber forknum) |
void | mdcreate (SMgrRelation reln, ForkNumber forknum, bool isRedo) |
void | mdunlink (RelFileLocatorBackend rlocator, ForkNumber forknum, bool isRedo) |
static int | do_truncate (const char *path) |
void | mdextend (SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum, const void *buffer, bool skipFsync) |
void | mdzeroextend (SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum, int nblocks, bool skipFsync) |
void | mdopen (SMgrRelation reln) |
void | mdclose (SMgrRelation reln, ForkNumber forknum) |
bool | mdprefetch (SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum, int nblocks) |
static int | buffers_to_iovec (struct iovec *iov, void **buffers, int nblocks) |
uint32 | mdmaxcombine (SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum) |
void | mdreadv (SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum, void **buffers, BlockNumber nblocks) |
void | mdwritev (SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum, const void **buffers, BlockNumber nblocks, bool skipFsync) |
void | mdwriteback (SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum, BlockNumber nblocks) |
BlockNumber | mdnblocks (SMgrRelation reln, ForkNumber forknum) |
void | mdtruncate (SMgrRelation reln, ForkNumber forknum, BlockNumber nblocks) |
void | mdregistersync (SMgrRelation reln, ForkNumber forknum) |
void | mdimmedsync (SMgrRelation reln, ForkNumber forknum) |
void | ForgetDatabaseSyncRequests (Oid dbid) |
void | DropRelationFiles (RelFileLocator *delrels, int ndelrels, bool isRedo) |
int | mdsyncfiletag (const FileTag *ftag, char *path) |
int | mdunlinkfiletag (const FileTag *ftag, char *path) |
bool | mdfiletagmatches (const FileTag *ftag, const FileTag *candidate) |
Variables | |
static MemoryContext | MdCxt |
#define INIT_MD_FILETAG | ( | a, | |
xx_rlocator, | |||
xx_forknum, | |||
xx_segno | |||
) |
|
static |
Definition at line 1499 of file md.c.
References SMgrRelationData::md_num_open_segs, SMgrRelationData::md_seg_fds, MdCxt, MemoryContextAlloc(), pfree(), and repalloc().
Referenced by _mdfd_openseg(), mdclose(), mdcreate(), mdimmedsync(), mdopenfork(), mdregistersync(), and mdtruncate().
|
static |
Definition at line 1605 of file md.c.
References _mdfd_openseg(), _mdfd_segpath(), _mdnblocks(), Assert, elog, ereport, errcode_for_file_access(), errmsg(), ERROR, EXTENSION_CREATE, EXTENSION_CREATE_RECOVERY, EXTENSION_DONT_CHECK_SIZE, EXTENSION_DONT_OPEN, EXTENSION_FAIL, EXTENSION_RETURN_NULL, FATAL, FILE_POSSIBLY_DELETED, InRecovery, MCXT_ALLOC_ZERO, SMgrRelationData::md_num_open_segs, SMgrRelationData::md_seg_fds, mdextend(), _MdfdVec::mdfd_segno, mdopenfork(), palloc_aligned(), pfree(), and PG_IO_ALIGN_SIZE.
Referenced by mdextend(), mdprefetch(), mdreadv(), mdwriteback(), mdwritev(), and mdzeroextend().
|
inlinestatic |
Definition at line 144 of file md.c.
References IO_DIRECT_DATA, io_direct_flags, PG_BINARY, and PG_O_DIRECT.
Referenced by _mdfd_openseg(), mdcreate(), mdopenfork(), and mdsyncfiletag().
|
static |
Definition at line 1560 of file md.c.
References _fdvec_resize(), _mdfd_open_flags(), _mdfd_segpath(), _mdnblocks(), Assert, fd(), SMgrRelationData::md_num_open_segs, SMgrRelationData::md_seg_fds, _MdfdVec::mdfd_segno, _MdfdVec::mdfd_vfd, PathNameOpenFile(), and pfree().
Referenced by _mdfd_getseg(), mdimmedsync(), mdnblocks(), and mdregistersync().
|
static |
Definition at line 1537 of file md.c.
References pfree(), psprintf(), relpath, and SMgrRelationData::smgr_rlocator.
Referenced by _mdfd_getseg(), _mdfd_openseg(), and mdsyncfiletag().
|
static |
Definition at line 1736 of file md.c.
References ereport, errcode_for_file_access(), errmsg(), ERROR, FilePathName(), FileSize(), len, and _MdfdVec::mdfd_vfd.
Referenced by _mdfd_getseg(), _mdfd_openseg(), mdextend(), mdnblocks(), mdopenfork(), and mdzeroextend().
|
static |
Definition at line 762 of file md.c.
References Assert, i, PG_IO_ALIGN_SIZE, PG_O_DIRECT, and TYPEALIGN.
Referenced by mdreadv(), and mdwritev().
|
static |
Definition at line 323 of file md.c.
References ereport, errcode_for_file_access(), errmsg(), pg_truncate(), and WARNING.
Referenced by mdunlinkfork().
void DropRelationFiles | ( | RelFileLocator * | delrels, |
int | ndelrels, | ||
bool | isRedo | ||
) |
Definition at line 1467 of file md.c.
References i, INVALID_PROC_NUMBER, MAX_FORKNUM, palloc(), pfree(), smgrclose(), smgrdounlinkall(), smgropen(), and XLogDropRelation().
Referenced by FinishPreparedTransaction(), xact_redo_abort(), and xact_redo_commit().
void ForgetDatabaseSyncRequests | ( | Oid | dbid | ) |
Definition at line 1449 of file md.c.
References RelFileLocator::dbOid, INIT_MD_FILETAG, InvalidBlockNumber, InvalidForkNumber, RegisterSyncRequest(), RelFileLocator::relNumber, RelFileLocator::spcOid, and SYNC_FILTER_REQUEST.
Referenced by createdb_failure_callback(), dbase_redo(), and dropdb().
void mdclose | ( | SMgrRelation | reln, |
ForkNumber | forknum | ||
) |
Definition at line 691 of file md.c.
References _fdvec_resize(), FileClose(), SMgrRelationData::md_num_open_segs, SMgrRelationData::md_seg_fds, and _MdfdVec::mdfd_vfd.
Referenced by mdexists().
void mdcreate | ( | SMgrRelation | reln, |
ForkNumber | forknum, | ||
bool | isRedo | ||
) |
Definition at line 190 of file md.c.
References _fdvec_resize(), _mdfd_open_flags(), Assert, RelFileLocator::dbOid, ereport, errcode_for_file_access(), errmsg(), ERROR, fd(), RelFileLocatorBackend::locator, SMgrRelationData::md_num_open_segs, SMgrRelationData::md_seg_fds, _MdfdVec::mdfd_segno, _MdfdVec::mdfd_vfd, PathNameOpenFile(), pfree(), register_dirty_segment(), relpath, SMgrRelationData::smgr_rlocator, SmgrIsTemp, RelFileLocator::spcOid, and TablespaceCreateDbspace().
bool mdexists | ( | SMgrRelation | reln, |
ForkNumber | forknum | ||
) |
Definition at line 171 of file md.c.
References EXTENSION_RETURN_NULL, InRecovery, mdclose(), and mdopenfork().
void mdextend | ( | SMgrRelation | reln, |
ForkNumber | forknum, | ||
BlockNumber | blocknum, | ||
const void * | buffer, | ||
bool | skipFsync | ||
) |
Definition at line 460 of file md.c.
References _mdfd_getseg(), _mdnblocks(), Assert, ereport, errcode(), errcode_for_file_access(), errhint(), errmsg(), ERROR, EXTENSION_CREATE, FilePathName(), FileWrite(), InvalidBlockNumber, _MdfdVec::mdfd_vfd, mdnblocks(), PG_IO_ALIGN_SIZE, PG_O_DIRECT, register_dirty_segment(), relpath, SMgrRelationData::smgr_rlocator, SmgrIsTemp, and TYPEALIGN.
Referenced by _mdfd_getseg().
void mdimmedsync | ( | SMgrRelation | reln, |
ForkNumber | forknum | ||
) |
Definition at line 1312 of file md.c.
References _fdvec_resize(), _mdfd_openseg(), data_sync_elevel(), ereport, errcode_for_file_access(), errmsg(), ERROR, FileClose(), FilePathName(), FileSync(), SMgrRelationData::md_num_open_segs, SMgrRelationData::md_seg_fds, _MdfdVec::mdfd_vfd, and mdnblocks().
void mdinit | ( | void | ) |
Definition at line 158 of file md.c.
References ALLOCSET_DEFAULT_SIZES, AllocSetContextCreate, MdCxt, and TopMemoryContext.
uint32 mdmaxcombine | ( | SMgrRelation | reln, |
ForkNumber | forknum, | ||
BlockNumber | blocknum | ||
) |
BlockNumber mdnblocks | ( | SMgrRelation | reln, |
ForkNumber | forknum | ||
) |
Definition at line 1110 of file md.c.
References _mdfd_openseg(), _mdnblocks(), Assert, elog, EXTENSION_FAIL, FATAL, SMgrRelationData::md_num_open_segs, SMgrRelationData::md_seg_fds, and mdopenfork().
Referenced by mdextend(), mdimmedsync(), mdregistersync(), mdtruncate(), mdwritev(), and mdzeroextend().
void mdopen | ( | SMgrRelation | reln | ) |
Definition at line 680 of file md.c.
References MAX_FORKNUM, and SMgrRelationData::md_num_open_segs.
|
static |
Definition at line 637 of file md.c.
References _fdvec_resize(), _mdfd_open_flags(), _mdnblocks(), Assert, ereport, errcode_for_file_access(), errmsg(), ERROR, EXTENSION_RETURN_NULL, fd(), FILE_POSSIBLY_DELETED, SMgrRelationData::md_num_open_segs, SMgrRelationData::md_seg_fds, _MdfdVec::mdfd_segno, _MdfdVec::mdfd_vfd, PathNameOpenFile(), pfree(), relpath, and SMgrRelationData::smgr_rlocator.
Referenced by _mdfd_getseg(), mdexists(), and mdnblocks().
bool mdprefetch | ( | SMgrRelation | reln, |
ForkNumber | forknum, | ||
BlockNumber | blocknum, | ||
int | nblocks | ||
) |
Definition at line 714 of file md.c.
References _mdfd_getseg(), Assert, EXTENSION_FAIL, EXTENSION_RETURN_NULL, FilePrefetch(), InRecovery, IO_DIRECT_DATA, io_direct_flags, MaxBlockNumber, _MdfdVec::mdfd_vfd, and Min.
void mdreadv | ( | SMgrRelation | reln, |
ForkNumber | forknum, | ||
BlockNumber | blocknum, | ||
void ** | buffers, | ||
BlockNumber | nblocks | ||
) |
Definition at line 825 of file md.c.
References _mdfd_getseg(), Assert, RelFileLocatorBackend::backend, buffers_to_iovec(), compute_remaining_iovec(), RelFileLocator::dbOid, elog, ereport, errcode(), ERRCODE_DATA_CORRUPTED, errcode_for_file_access(), errmsg(), ERROR, EXTENSION_CREATE_RECOVERY, EXTENSION_FAIL, FilePathName(), FileReadV(), i, InRecovery, lengthof, RelFileLocatorBackend::locator, _MdfdVec::mdfd_vfd, Min, PG_IOV_MAX, RelFileLocator::relNumber, SMgrRelationData::smgr_rlocator, RelFileLocator::spcOid, and zero_damaged_pages.
void mdregistersync | ( | SMgrRelation | reln, |
ForkNumber | forknum | ||
) |
Definition at line 1261 of file md.c.
References _fdvec_resize(), _mdfd_openseg(), FileClose(), SMgrRelationData::md_num_open_segs, SMgrRelationData::md_seg_fds, _MdfdVec::mdfd_vfd, mdnblocks(), and register_dirty_segment().
int mdsyncfiletag | ( | const FileTag * | ftag, |
char * | path | ||
) |
Definition at line 1757 of file md.c.
References _mdfd_open_flags(), _mdfd_segpath(), FileClose(), FilePathName(), FileSync(), FileTag::forknum, INVALID_PROC_NUMBER, IOCONTEXT_NORMAL, IOOBJECT_RELATION, IOOP_FSYNC, MAXPGPATH, SMgrRelationData::md_num_open_segs, SMgrRelationData::md_seg_fds, _MdfdVec::mdfd_vfd, PathNameOpenFile(), pfree(), pgstat_count_io_op_time(), pgstat_prepare_io_time(), FileTag::rlocator, FileTag::segno, smgropen(), strlcpy(), and track_io_timing.
void mdtruncate | ( | SMgrRelation | reln, |
ForkNumber | forknum, | ||
BlockNumber | nblocks | ||
) |
Definition at line 1167 of file md.c.
References _fdvec_resize(), Assert, ereport, errcode_for_file_access(), errmsg(), ERROR, FileClose(), FilePathName(), FileTruncate(), InRecovery, SMgrRelationData::md_num_open_segs, SMgrRelationData::md_seg_fds, _MdfdVec::mdfd_vfd, mdnblocks(), register_dirty_segment(), relpath, SMgrRelationData::smgr_rlocator, and SmgrIsTemp.
void mdunlink | ( | RelFileLocatorBackend | rlocator, |
ForkNumber | forknum, | ||
bool | isRedo | ||
) |
Definition at line 307 of file md.c.
References InvalidForkNumber, MAX_FORKNUM, and mdunlinkfork().
int mdunlinkfiletag | ( | const FileTag * | ftag, |
char * | path | ||
) |
Definition at line 1810 of file md.c.
References MAIN_FORKNUM, MAXPGPATH, pfree(), relpathperm, FileTag::rlocator, and strlcpy().
|
static |
Definition at line 344 of file md.c.
References do_truncate(), ereport, errcode_for_file_access(), errmsg(), IsBinaryUpgrade, MAIN_FORKNUM, palloc(), pfree(), register_forget_request(), register_unlink_segment(), RelFileLocatorBackendIsTemp, relpath, sprintf, and WARNING.
Referenced by mdunlink().
void mdwriteback | ( | SMgrRelation | reln, |
ForkNumber | forknum, | ||
BlockNumber | blocknum, | ||
BlockNumber | nblocks | ||
) |
Definition at line 1051 of file md.c.
References _mdfd_getseg(), Assert, EXTENSION_DONT_OPEN, FileWriteback(), IO_DIRECT_DATA, io_direct_flags, and _MdfdVec::mdfd_vfd.
void mdwritev | ( | SMgrRelation | reln, |
ForkNumber | forknum, | ||
BlockNumber | blocknum, | ||
const void ** | buffers, | ||
BlockNumber | nblocks, | ||
bool | skipFsync | ||
) |
Definition at line 946 of file md.c.
References _mdfd_getseg(), Assert, RelFileLocatorBackend::backend, buffers_to_iovec(), compute_remaining_iovec(), RelFileLocator::dbOid, elog, ereport, errcode_for_file_access(), errhint(), errmsg(), ERROR, EXTENSION_CREATE_RECOVERY, EXTENSION_FAIL, FilePathName(), FileWriteV(), lengthof, RelFileLocatorBackend::locator, _MdfdVec::mdfd_vfd, mdnblocks(), Min, PG_IOV_MAX, register_dirty_segment(), RelFileLocator::relNumber, SMgrRelationData::smgr_rlocator, SmgrIsTemp, and RelFileLocator::spcOid.
void mdzeroextend | ( | SMgrRelation | reln, |
ForkNumber | forknum, | ||
BlockNumber | blocknum, | ||
int | nblocks, | ||
bool | skipFsync | ||
) |
Definition at line 525 of file md.c.
References _mdfd_getseg(), _mdnblocks(), Assert, ereport, errcode(), errcode_for_file_access(), errhint(), errmsg(), ERROR, EXTENSION_CREATE, FileFallocate(), FilePathName(), FileZero(), InvalidBlockNumber, _MdfdVec::mdfd_vfd, mdnblocks(), register_dirty_segment(), relpath, SMgrRelationData::smgr_rlocator, and SmgrIsTemp.
|
static |
Definition at line 1374 of file md.c.
References Assert, data_sync_elevel(), DEBUG1, ereport, errcode_for_file_access(), errmsg(), errmsg_internal(), ERROR, FilePathName(), FileSync(), INIT_MD_FILETAG, IOCONTEXT_NORMAL, IOOBJECT_RELATION, IOOP_FSYNC, RelFileLocatorBackend::locator, _MdfdVec::mdfd_segno, _MdfdVec::mdfd_vfd, pgstat_count_io_op_time(), pgstat_prepare_io_time(), RegisterSyncRequest(), SMgrRelationData::smgr_rlocator, SmgrIsTemp, SYNC_REQUEST, and track_io_timing.
Referenced by mdcreate(), mdextend(), mdregistersync(), mdtruncate(), mdwritev(), and mdzeroextend().
|
static |
Definition at line 1435 of file md.c.
References INIT_MD_FILETAG, RelFileLocatorBackend::locator, RegisterSyncRequest(), and SYNC_FORGET_REQUEST.
Referenced by mdunlinkfork().
|
static |
Definition at line 1418 of file md.c.
References Assert, INIT_MD_FILETAG, RelFileLocatorBackend::locator, RegisterSyncRequest(), RelFileLocatorBackendIsTemp, and SYNC_UNLINK_REQUEST.
Referenced by mdunlinkfork().
|
static |
Definition at line 86 of file md.c.
Referenced by _fdvec_resize(), and mdinit().