Skip to content

G
Gpdb

Greenplum / Gpdb

通知 7
Star 1
Fork 0
G
Gpdb

体验新版 GitCode，发现更多精彩内容 >>

提交 306b189d 编写于 作者: H Heikki Linnakangas
浏览文件
操作

Move some GPDB-specific code out of smgr.c and md.c. 

For clarity, and to make merging easier.

The code to manage the hash table of "pending resync EOFs" for append-only
tables is moved to smgr_ao.c. One notable change here is that the
pendingDeletesPerformed flag is removed. It was used to track whether there
are any pending deletes, or any pending AO table resyncs, but we might as
well check the pending delete list and the pending syncs hash table
directly, it's hardly any slower than checking a separate boolean.

There are still plenty of GPDB changes in smgr.c, but this is a good step
forward.
上级 cc6b462b
展开全部 隐藏空白更改
内联 并排
Showing with 1896 addition and 1808 deletion
src/backend/access/transam/persistentendxactrec.c
浏览文件 @ 306b189d
......@@ -17,6 +17,7 @@
#include "miscadmin.h"
#include "access/persistentendxactrec.h"
#include "storage/smgr.h"
#include "storage/smgr_ao.h"
#include "utils/guc.h"
#include "cdb/cdbpersistentstore.h"
#include "cdb/cdbpersistentfilesysobj.h"
......
src/backend/cdb/cdbmirroredappendonly.c
浏览文件 @ 306b189d
......@@ -28,6 +28,7 @@
#include "cdb/cdbpersistenttablespace.h"
#include "cdb/cdbfilerepprimary.h"
#include "storage/smgr.h"
#include "storage/smgr_ao.h"
#include "storage/lwlock.h"
#include "utils/guc.h"
#include "cdb/cdbpersistentfilesysobj.h"
......
src/backend/storage/smgr/Makefile
浏览文件 @ 306b189d
......@@ -13,5 +13,6 @@ top_builddir = ../../../..
include $(top_builddir)/src/Makefile.global
OBJS = md.o smgr.o smgrtype.o
OBJS += md_gp.o smgr_ao.o
include $(top_srcdir)/src/backend/common.mk
src/backend/storage/smgr/md.c
浏览文件 @ 306b189d
......@@ -210,507 +210,6 @@ mdinit(void)
}
}
static int errdetail_nonexistent_relation(
int error,
RelFileNode *relFileNode)
{
#define MAX_MSG_LEN MAXPGPATH + 100
char *buffer;
int snprintfResult;
char *primaryFilespaceLocation = NULL;
char *mirrorFilespaceLocation = NULL;
struct stat fst;
if (!FILE_POSSIBLY_DELETED(error))
{
/*
* No call to errdetail.
*/
return 0;
}
buffer = (char*)palloc(MAX_MSG_LEN);
if (IsBuiltinTablespace(relFileNode->spcNode))
{
/*
* Assume filespace and tablespace exists.
*/
}
else
{
char *tablespacePath;
/*
* Investigate whether the containing directories exist to give more detail.
*/
PersistentTablespace_GetPrimaryAndMirrorFilespaces(
relFileNode->spcNode,
&primaryFilespaceLocation,
&mirrorFilespaceLocation);
if (primaryFilespaceLocation == NULL ||
strlen(primaryFilespaceLocation) == 0)
{
elog(ERROR, "Empty primary filespace directory location");
}
if (mirrorFilespaceLocation != NULL)
{
pfree(mirrorFilespaceLocation);
mirrorFilespaceLocation = NULL;
}
/*
* Does the filespace directory exist?
*/
if (stat(primaryFilespaceLocation, &fst) < 0)
{
int saved_err;
saved_err = errno;
if (FILE_POSSIBLY_DELETED(saved_err))
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Filespace directory \"%s\" does not exist",
primaryFilespaceLocation);
}
else
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Filespace directory \"%s\" existence check: %s",
primaryFilespaceLocation,
strerror(saved_err));
}
Assert(snprintfResult >= 0);
Assert(snprintfResult < MAX_MSG_LEN);
/*
* Give DETAIL on the filespace directory!
*/
errdetail("%s", buffer);
pfree(buffer);
pfree(primaryFilespaceLocation);
return 0;
}
else
{
if (Debug_persistent_recovery_print)
{
/*
* Since we are being invoked inside an elog, we don't want to
* recurse. So, use errdetail instead!
*/
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Filespace directory \"%s\" does exist",
primaryFilespaceLocation);
Assert(snprintfResult >= 0);
Assert(snprintfResult < MAX_MSG_LEN);
errdetail("%s",buffer);
}
}
tablespacePath = (char*)palloc(MAXPGPATH + 1);
FormTablespacePath(
tablespacePath,
primaryFilespaceLocation,
relFileNode->spcNode);
/*
* Does the tablespace directory exist?
*/
if (stat(tablespacePath, &fst) < 0)
{
int saved_err;
saved_err = errno;
if (FILE_POSSIBLY_DELETED(saved_err))
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Tablespace directory \"%s\" does not exist",
tablespacePath);
}
else
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Tablespace directory \"%s\" existence check: %s",
tablespacePath,
strerror(saved_err));
}
Assert(snprintfResult >= 0);
Assert(snprintfResult < MAX_MSG_LEN);
/*
* Give DETAIL on the tablespace directory!
*/
errdetail("%s", buffer);
pfree(buffer);
if (primaryFilespaceLocation != NULL)
pfree(primaryFilespaceLocation);
pfree(tablespacePath);
return 0;
}
else
{
if (Debug_persistent_recovery_print)
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Tablespace directory \"%s\" does exist",
tablespacePath);
Assert(snprintfResult >= 0);
Assert(snprintfResult < MAX_MSG_LEN);
errdetail("%s", buffer);
}
}
pfree(tablespacePath);
}
if (relFileNode->spcNode != GLOBALTABLESPACE_OID)
{
char *dbPath;
dbPath = (char*)palloc(MAXPGPATH + 1);
FormDatabasePath(
dbPath,
primaryFilespaceLocation,
relFileNode->spcNode,
relFileNode->dbNode);
/*
* Does the database directory exist?
*/
if (stat(dbPath, &fst) < 0)
{
int saved_err;
saved_err = errno;
if (FILE_POSSIBLY_DELETED(saved_err))
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Database directory \"%s\" does not exist",
dbPath);
}
else
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Database directory \"%s\" existence check: %s",
dbPath,
strerror(saved_err));
}
Assert(snprintfResult >= 0);
Assert(snprintfResult < MAX_MSG_LEN);
/*
* Give DETAIL on the database directory!
*/
errdetail("%s", buffer);
pfree(buffer);
if (primaryFilespaceLocation != NULL)
pfree(primaryFilespaceLocation);
pfree(dbPath);
return 0;
}
else
{
if (Debug_persistent_recovery_print)
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Database directory \"%s\" does exist",
dbPath);
Assert(snprintfResult >= 0);
Assert(snprintfResult < MAX_MSG_LEN);
errdetail("%s", buffer);
}
}
pfree(dbPath);
}
pfree(buffer);
if (primaryFilespaceLocation != NULL)
pfree(primaryFilespaceLocation);
/*
* No (normal) call to errdetail.
*/
return 0;
}
/*
* mdcreatefilespacedir() -- Create a new filespace directory on magnetic disk.
*
* If isRedo is true, it's okay for the filespace directory to exist already.
*/
void
mdcreatefilespacedir(
Oid filespaceOid,
char *primaryFilespaceLocation,
/*
* The primary filespace directory path. NOT Blank padded.
* Just a NULL terminated string.
*/
char *mirrorFilespaceLocation,
StorageManagerMirrorMode mirrorMode,
bool ignoreAlreadyExists,
int *primaryError,
bool *mirrorDataLossOccurred)
{
int mirrorStatus = FileRepStatusSuccess;
*primaryError = 0;
*mirrorDataLossOccurred = false;
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
mirrorStatus = FileRepPrimary_MirrorCreate(
FileRep_GetDirFilespaceIdentifier(
mirrorFilespaceLocation),
FileRepRelationTypeDir,
ignoreAlreadyExists);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (StorageManagerMirrorMode_DoPrimaryWork(mirrorMode))
{
if (mkdir(primaryFilespaceLocation, 0700) < 0)
*primaryError = errno;
}
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_IsOperationCompleted(
FileRep_GetDirFilespaceIdentifier(
mirrorFilespaceLocation),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
if (! *mirrorDataLossOccurred)
{
mirrorStatus = FileRepPrimary_GetMirrorStatus();
if (mirrorStatus != FileRepStatusSuccess)
{
ereport(ERROR,
(errcode(ERRCODE_GP_COMMAND_ERROR),
errmsg("could not create dbdir on mirror '%s' ",
FileRepStatusToString[mirrorStatus])));
}
}
}
}
/*
* mdcreatetablespacedir() -- Create a new tablespace directory on magnetic disk.
*
* If isRedo is true, it's okay for the tablespace directory to exist already.
*/
void
mdcreatetablespacedir(
Oid tablespaceOid,
StorageManagerMirrorMode mirrorMode,
bool ignoreAlreadyExists,
int *primaryError,
bool *mirrorDataLossOccurred)
{
char *primaryFilespaceLocation;
char *mirrorFilespaceLocation;
char tablespacePath[MAXPGPATH];
*primaryError = 0;
*mirrorDataLossOccurred = false;
PersistentTablespace_GetPrimaryAndMirrorFilespaces(
tablespaceOid,
&primaryFilespaceLocation,
&mirrorFilespaceLocation);
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_MirrorCreate(
FileRep_GetDirTablespaceIdentifier(
mirrorFilespaceLocation,
tablespaceOid),
FileRepRelationTypeDir,
TRUE);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (StorageManagerMirrorMode_DoPrimaryWork(mirrorMode))
{
FormTablespacePath(
tablespacePath,
primaryFilespaceLocation,
tablespaceOid);
if (mkdir(tablespacePath, 0700) < 0)
*primaryError = errno;
}
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_IsOperationCompleted(
FileRep_GetDirTablespaceIdentifier(
mirrorFilespaceLocation,
tablespaceOid),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (primaryFilespaceLocation)
pfree(primaryFilespaceLocation);
if (mirrorFilespaceLocation)
pfree(mirrorFilespaceLocation);
}
/*
* mdcreatedbdir() -- Create a new database directory on magnetic disk.
*
* If isRedo is true, it's okay for the database directory to exist already.
*/
void
mdcreatedbdir(
DbDirNode *dbDirNode,
StorageManagerMirrorMode mirrorMode,
bool ignoreAlreadyExists,
int *primaryError,
bool *mirrorDataLossOccurred)
{
char *primaryFilespaceLocation;
char *mirrorFilespaceLocation;
char dbPath[MAXPGPATH];
*primaryError = 0;
*mirrorDataLossOccurred = false;
PersistentTablespace_GetPrimaryAndMirrorFilespaces(
dbDirNode->tablespace,
&primaryFilespaceLocation,
&mirrorFilespaceLocation);
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_MirrorCreate(
FileRep_GetDirDatabaseIdentifier(
mirrorFilespaceLocation,
*dbDirNode),
FileRepRelationTypeDir,
TRUE);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (StorageManagerMirrorMode_DoPrimaryWork(mirrorMode))
{
FormDatabasePath(
dbPath,
primaryFilespaceLocation,
dbDirNode->tablespace,
dbDirNode->database);
if (mkdir(dbPath, 0700) < 0)
{
if (ignoreAlreadyExists && (errno == EEXIST))
{
elog(LOG, "Directory already exists %s", dbPath);
}
else
{
*primaryError = errno;
}
}
}
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_IsOperationCompleted(
FileRep_GetDirDatabaseIdentifier(
mirrorFilespaceLocation,
*dbDirNode),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (primaryFilespaceLocation)
pfree(primaryFilespaceLocation);
if (mirrorFilespaceLocation)
pfree(mirrorFilespaceLocation);
}
/*
* mdcreate() -- Create a new relation on magnetic disk.
......@@ -963,323 +462,6 @@ mdunlink(
#endif
}
static void mdsetupdropobjmirroraccess(
bool primaryOnly,
bool mirrorOnly,
StorageManagerMirrorMode *mirrorMode,
bool *mirrorDataLossOccurred)
{
MirrorDataLossTrackingState mirrorDataLossTrackingState;
int64 mirrorDataLossTrackingSessionNum;
*mirrorMode = StorageManagerMirrorMode_None;
*mirrorDataLossOccurred = false; // Assume.
mirrorDataLossTrackingState =
FileRepPrimary_GetMirrorDataLossTrackingSessionNum(
&mirrorDataLossTrackingSessionNum);
if (gp_initdb_mirrored)
{
/* Kludge for initdb */
*mirrorMode = StorageManagerMirrorMode_Both;
}
else
{
switch (mirrorDataLossTrackingState)
{
case MirrorDataLossTrackingState_MirrorNotConfigured:
if (mirrorOnly)
elog(ERROR, "No mirror configured for mirror only");
*mirrorMode = StorageManagerMirrorMode_PrimaryOnly;
break;
case MirrorDataLossTrackingState_MirrorCurrentlyUpInSync:
if (primaryOnly)
*mirrorMode = StorageManagerMirrorMode_PrimaryOnly;
else if (!mirrorOnly)
*mirrorMode = StorageManagerMirrorMode_Both;
else
*mirrorMode = StorageManagerMirrorMode_MirrorOnly;
break;
case MirrorDataLossTrackingState_MirrorCurrentlyUpInResync:
if (primaryOnly)
*mirrorMode = StorageManagerMirrorMode_PrimaryOnly;
else if (!mirrorOnly)
*mirrorMode = StorageManagerMirrorMode_Both;
else
*mirrorMode = StorageManagerMirrorMode_MirrorOnly;
break;
case MirrorDataLossTrackingState_MirrorDown:
if (!mirrorOnly)
*mirrorMode = StorageManagerMirrorMode_PrimaryOnly;
else
*mirrorMode = StorageManagerMirrorMode_MirrorOnly; // Mirror only operations fails from the outset.
*mirrorDataLossOccurred = true; // Mirror communication is down.
break;
default:
elog(ERROR, "Unexpected mirror data loss tracking state: %d",
mirrorDataLossTrackingState);
*mirrorMode = StorageManagerMirrorMode_None; // A happy optimizer is the sound of one hand clapping.
}
}
}
/*
* mdrmfilespacedir() -- Remove a filespace directory on magnetic disk.
*
* If isRedo is true, it's okay for the filespace directory to exist already.
*/
bool
mdrmfilespacedir(
Oid filespaceOid,
char *primaryFilespaceLocation,
/*
* The primary filespace directory path. NOT Blank padded.
* Just a NULL terminated string.
*/
char *mirrorFilespaceLocation,
bool primaryOnly,
bool mirrorOnly,
bool ignoreNonExistence,
bool *mirrorDataLossOccurred)
{
StorageManagerMirrorMode mirrorMode;
bool result;
*mirrorDataLossOccurred = false;
mdsetupdropobjmirroraccess(
primaryOnly,
mirrorOnly,
&mirrorMode,
mirrorDataLossOccurred);
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_MirrorDrop(
FileRep_GetDirFilespaceIdentifier(
mirrorFilespaceLocation),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (StorageManagerMirrorMode_DoPrimaryWork(mirrorMode))
{
// The rmtree routine unfortunately emits errors, so there is not errno available...
// Just a bool.
result = rmtree(primaryFilespaceLocation, true);
}
else
result = true;
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_IsOperationCompleted(
FileRep_GetDirFilespaceIdentifier(
mirrorFilespaceLocation),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
return result;
}
/*
* mdrmtablespacedir() -- Remove a tablespace directory on magnetic disk.
*
* If isRedo is true, it's okay for the tablespace directory to exist already.
*/
bool
mdrmtablespacedir(
Oid tablespaceOid,
bool primaryOnly,
bool mirrorOnly,
bool ignoreNonExistence,
bool *mirrorDataLossOccurred)
{
StorageManagerMirrorMode mirrorMode;
char *primaryFilespaceLocation;
char *mirrorFilespaceLocation;
char tablespacePath[MAXPGPATH];
bool result;
*mirrorDataLossOccurred = false;
mdsetupdropobjmirroraccess(
primaryOnly,
mirrorOnly,
&mirrorMode,
mirrorDataLossOccurred);
PersistentTablespace_GetPrimaryAndMirrorFilespaces(
tablespaceOid,
&primaryFilespaceLocation,
&mirrorFilespaceLocation);
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_MirrorDrop(
FileRep_GetDirTablespaceIdentifier(
mirrorFilespaceLocation,
tablespaceOid),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (StorageManagerMirrorMode_DoPrimaryWork(mirrorMode))
{
/*
* We've removed all relations, so all that is left are PG* files and work files.
*/
FormTablespacePath(
tablespacePath,
primaryFilespaceLocation,
tablespaceOid);
// The rmtree routine unfortunately emits errors, so there is not errno available...
// Just a bool.
result = rmtree(tablespacePath, true);
}
else
result = true;
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_IsOperationCompleted(
FileRep_GetDirTablespaceIdentifier(
mirrorFilespaceLocation,
tablespaceOid),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (primaryFilespaceLocation != NULL)
pfree(primaryFilespaceLocation);
if (mirrorFilespaceLocation != NULL)
pfree(mirrorFilespaceLocation);
return result;
}
/*
* mdrmbdir() -- Remove a database directory on magnetic disk.
*
* If isRedo is true, it's okay for the database directory to exist already.
*/
bool
mdrmdbdir(
DbDirNode *dbDirNode,
bool primaryOnly,
bool mirrorOnly,
bool ignoreNonExistence,
bool *mirrorDataLossOccurred)
{
StorageManagerMirrorMode mirrorMode;
char *primaryFilespaceLocation;
char *mirrorFilespaceLocation;
char dbPath[MAXPGPATH];
bool result;
*mirrorDataLossOccurred = false;
mdsetupdropobjmirroraccess(
primaryOnly,
mirrorOnly,
&mirrorMode,
mirrorDataLossOccurred);
PersistentTablespace_GetPrimaryAndMirrorFilespaces(
dbDirNode->tablespace,
&primaryFilespaceLocation,
&mirrorFilespaceLocation);
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_MirrorDrop(
FileRep_GetDirDatabaseIdentifier(
mirrorFilespaceLocation,
*dbDirNode),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (StorageManagerMirrorMode_DoPrimaryWork(mirrorMode))
{
/*
* We've removed all relations, so all that is left are PG* files and work files.
*/
FormDatabasePath(
dbPath,
primaryFilespaceLocation,
dbDirNode->tablespace,
dbDirNode->database);
// The rmtree routine unfortunately emits errors, so there is not errno available...
// Just a bool.
result = rmtree(dbPath, true);
}
else
result = true;
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_IsOperationCompleted(
FileRep_GetDirDatabaseIdentifier(
mirrorFilespaceLocation,
*dbDirNode),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (primaryFilespaceLocation != NULL)
pfree(primaryFilespaceLocation);
if (mirrorFilespaceLocation != NULL)
pfree(mirrorFilespaceLocation);
return result;
}
/*
......
src/backend/storage/smgr/md_gp.c 0 → 100644
浏览文件 @ 306b189d
/*-------------------------------------------------------------------------
*
* md_gp.c
* GPDB extensions to md.c
*
* Portions Copyright (c) 1996-2009, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
*
* IDENTIFICATION
* src/backend/storage/smgr/md_gp.c
*
*-------------------------------------------------------------------------
*/
#include "postgres.h"
#include <unistd.h>
#include <fcntl.h>
#include <sys/file.h>
#include <sys/types.h>
#include <sys/stat.h>
#include "storage/fd.h"
#include "storage/smgr.h"
#include "cdb/cdbmirroredbufferpool.h"
#include "cdb/cdbpersistenttablespace.h"
/* copied from md.c */
#ifndef WIN32
#define FILE_POSSIBLY_DELETED(err) ((err) == ENOENT)
#else
#define FILE_POSSIBLY_DELETED(err) ((err) == ENOENT || (err) == EACCES)
#endif
int
errdetail_nonexistent_relation(int error, RelFileNode *relFileNode)
{
#define MAX_MSG_LEN MAXPGPATH + 100
char *buffer;
int snprintfResult;
char *primaryFilespaceLocation = NULL;
char *mirrorFilespaceLocation = NULL;
struct stat fst;
if (!FILE_POSSIBLY_DELETED(error))
{
/*
* No call to errdetail.
*/
return 0;
}
buffer = (char*)palloc(MAX_MSG_LEN);
if (IsBuiltinTablespace(relFileNode->spcNode))
{
/*
* Assume filespace and tablespace exists.
*/
}
else
{
char *tablespacePath;
/*
* Investigate whether the containing directories exist to give more detail.
*/
PersistentTablespace_GetPrimaryAndMirrorFilespaces(
relFileNode->spcNode,
&primaryFilespaceLocation,
&mirrorFilespaceLocation);
if (primaryFilespaceLocation == NULL ||
strlen(primaryFilespaceLocation) == 0)
{
elog(ERROR, "Empty primary filespace directory location");
}
if (mirrorFilespaceLocation != NULL)
{
pfree(mirrorFilespaceLocation);
mirrorFilespaceLocation = NULL;
}
/*
* Does the filespace directory exist?
*/
if (stat(primaryFilespaceLocation, &fst) < 0)
{
int saved_err;
saved_err = errno;
if (FILE_POSSIBLY_DELETED(saved_err))
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Filespace directory \"%s\" does not exist",
primaryFilespaceLocation);
}
else
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Filespace directory \"%s\" existence check: %s",
primaryFilespaceLocation,
strerror(saved_err));
}
Assert(snprintfResult >= 0);
Assert(snprintfResult < MAX_MSG_LEN);
/*
* Give DETAIL on the filespace directory!
*/
errdetail("%s", buffer);
pfree(buffer);
pfree(primaryFilespaceLocation);
return 0;
}
else
{
if (Debug_persistent_recovery_print)
{
/*
* Since we are being invoked inside an elog, we don't want to
* recurse. So, use errdetail instead!
*/
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Filespace directory \"%s\" does exist",
primaryFilespaceLocation);
Assert(snprintfResult >= 0);
Assert(snprintfResult < MAX_MSG_LEN);
errdetail("%s",buffer);
}
}
tablespacePath = (char*)palloc(MAXPGPATH + 1);
FormTablespacePath(
tablespacePath,
primaryFilespaceLocation,
relFileNode->spcNode);
/*
* Does the tablespace directory exist?
*/
if (stat(tablespacePath, &fst) < 0)
{
int saved_err;
saved_err = errno;
if (FILE_POSSIBLY_DELETED(saved_err))
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Tablespace directory \"%s\" does not exist",
tablespacePath);
}
else
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Tablespace directory \"%s\" existence check: %s",
tablespacePath,
strerror(saved_err));
}
Assert(snprintfResult >= 0);
Assert(snprintfResult < MAX_MSG_LEN);
/*
* Give DETAIL on the tablespace directory!
*/
errdetail("%s", buffer);
pfree(buffer);
if (primaryFilespaceLocation != NULL)
pfree(primaryFilespaceLocation);
pfree(tablespacePath);
return 0;
}
else
{
if (Debug_persistent_recovery_print)
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Tablespace directory \"%s\" does exist",
tablespacePath);
Assert(snprintfResult >= 0);
Assert(snprintfResult < MAX_MSG_LEN);
errdetail("%s", buffer);
}
}
pfree(tablespacePath);
}
if (relFileNode->spcNode != GLOBALTABLESPACE_OID)
{
char *dbPath;
dbPath = (char*)palloc(MAXPGPATH + 1);
FormDatabasePath(
dbPath,
primaryFilespaceLocation,
relFileNode->spcNode,
relFileNode->dbNode);
/*
* Does the database directory exist?
*/
if (stat(dbPath, &fst) < 0)
{
int saved_err;
saved_err = errno;
if (FILE_POSSIBLY_DELETED(saved_err))
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Database directory \"%s\" does not exist",
dbPath);
}
else
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Database directory \"%s\" existence check: %s",
dbPath,
strerror(saved_err));
}
Assert(snprintfResult >= 0);
Assert(snprintfResult < MAX_MSG_LEN);
/*
* Give DETAIL on the database directory!
*/
errdetail("%s", buffer);
pfree(buffer);
if (primaryFilespaceLocation != NULL)
pfree(primaryFilespaceLocation);
pfree(dbPath);
return 0;
}
else
{
if (Debug_persistent_recovery_print)
{
snprintfResult =
snprintf(
buffer,
MAX_MSG_LEN,
"Database directory \"%s\" does exist",
dbPath);
Assert(snprintfResult >= 0);
Assert(snprintfResult < MAX_MSG_LEN);
errdetail("%s", buffer);
}
}
pfree(dbPath);
}
pfree(buffer);
if (primaryFilespaceLocation != NULL)
pfree(primaryFilespaceLocation);
/*
* No (normal) call to errdetail.
*/
return 0;
}
/*
* mdcreatefilespacedir() -- Create a new filespace directory on magnetic disk.
*
* If isRedo is true, it's okay for the filespace directory to exist already.
*/
void
mdcreatefilespacedir(
Oid filespaceOid,
char *primaryFilespaceLocation,
/*
* The primary filespace directory path. NOT Blank padded.
* Just a NULL terminated string.
*/
char *mirrorFilespaceLocation,
StorageManagerMirrorMode mirrorMode,
bool ignoreAlreadyExists,
int *primaryError,
bool *mirrorDataLossOccurred)
{
int mirrorStatus = FileRepStatusSuccess;
*primaryError = 0;
*mirrorDataLossOccurred = false;
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
mirrorStatus = FileRepPrimary_MirrorCreate(
FileRep_GetDirFilespaceIdentifier(
mirrorFilespaceLocation),
FileRepRelationTypeDir,
ignoreAlreadyExists);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (StorageManagerMirrorMode_DoPrimaryWork(mirrorMode))
{
if (mkdir(primaryFilespaceLocation, 0700) < 0)
*primaryError = errno;
}
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_IsOperationCompleted(
FileRep_GetDirFilespaceIdentifier(
mirrorFilespaceLocation),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
if (! *mirrorDataLossOccurred)
{
mirrorStatus = FileRepPrimary_GetMirrorStatus();
if (mirrorStatus != FileRepStatusSuccess)
{
ereport(ERROR,
(errcode(ERRCODE_GP_COMMAND_ERROR),
errmsg("could not create dbdir on mirror '%s' ",
FileRepStatusToString[mirrorStatus])));
}
}
}
}
/*
* mdcreatetablespacedir() -- Create a new tablespace directory on magnetic disk.
*
* If isRedo is true, it's okay for the tablespace directory to exist already.
*/
void
mdcreatetablespacedir(
Oid tablespaceOid,
StorageManagerMirrorMode mirrorMode,
bool ignoreAlreadyExists,
int *primaryError,
bool *mirrorDataLossOccurred)
{
char *primaryFilespaceLocation;
char *mirrorFilespaceLocation;
char tablespacePath[MAXPGPATH];
*primaryError = 0;
*mirrorDataLossOccurred = false;
PersistentTablespace_GetPrimaryAndMirrorFilespaces(
tablespaceOid,
&primaryFilespaceLocation,
&mirrorFilespaceLocation);
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_MirrorCreate(
FileRep_GetDirTablespaceIdentifier(
mirrorFilespaceLocation,
tablespaceOid),
FileRepRelationTypeDir,
TRUE);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (StorageManagerMirrorMode_DoPrimaryWork(mirrorMode))
{
FormTablespacePath(
tablespacePath,
primaryFilespaceLocation,
tablespaceOid);
if (mkdir(tablespacePath, 0700) < 0)
*primaryError = errno;
}
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_IsOperationCompleted(
FileRep_GetDirTablespaceIdentifier(
mirrorFilespaceLocation,
tablespaceOid),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (primaryFilespaceLocation)
pfree(primaryFilespaceLocation);
if (mirrorFilespaceLocation)
pfree(mirrorFilespaceLocation);
}
/*
* mdcreatedbdir() -- Create a new database directory on magnetic disk.
*
* If isRedo is true, it's okay for the database directory to exist already.
*/
void
mdcreatedbdir(
DbDirNode *dbDirNode,
StorageManagerMirrorMode mirrorMode,
bool ignoreAlreadyExists,
int *primaryError,
bool *mirrorDataLossOccurred)
{
char *primaryFilespaceLocation;
char *mirrorFilespaceLocation;
char dbPath[MAXPGPATH];
*primaryError = 0;
*mirrorDataLossOccurred = false;
PersistentTablespace_GetPrimaryAndMirrorFilespaces(
dbDirNode->tablespace,
&primaryFilespaceLocation,
&mirrorFilespaceLocation);
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_MirrorCreate(
FileRep_GetDirDatabaseIdentifier(
mirrorFilespaceLocation,
*dbDirNode),
FileRepRelationTypeDir,
TRUE);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (StorageManagerMirrorMode_DoPrimaryWork(mirrorMode))
{
FormDatabasePath(
dbPath,
primaryFilespaceLocation,
dbDirNode->tablespace,
dbDirNode->database);
if (mkdir(dbPath, 0700) < 0)
{
if (ignoreAlreadyExists && (errno == EEXIST))
{
elog(LOG, "Directory already exists %s", dbPath);
}
else
{
*primaryError = errno;
}
}
}
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_IsOperationCompleted(
FileRep_GetDirDatabaseIdentifier(
mirrorFilespaceLocation,
*dbDirNode),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (primaryFilespaceLocation)
pfree(primaryFilespaceLocation);
if (mirrorFilespaceLocation)
pfree(mirrorFilespaceLocation);
}
static void mdsetupdropobjmirroraccess(
bool primaryOnly,
bool mirrorOnly,
StorageManagerMirrorMode *mirrorMode,
bool *mirrorDataLossOccurred)
{
MirrorDataLossTrackingState mirrorDataLossTrackingState;
int64 mirrorDataLossTrackingSessionNum;
*mirrorMode = StorageManagerMirrorMode_None;
*mirrorDataLossOccurred = false; // Assume.
mirrorDataLossTrackingState =
FileRepPrimary_GetMirrorDataLossTrackingSessionNum(
&mirrorDataLossTrackingSessionNum);
if (gp_initdb_mirrored)
{
/* Kludge for initdb */
*mirrorMode = StorageManagerMirrorMode_Both;
}
else
{
switch (mirrorDataLossTrackingState)
{
case MirrorDataLossTrackingState_MirrorNotConfigured:
if (mirrorOnly)
elog(ERROR, "No mirror configured for mirror only");
*mirrorMode = StorageManagerMirrorMode_PrimaryOnly;
break;
case MirrorDataLossTrackingState_MirrorCurrentlyUpInSync:
if (primaryOnly)
*mirrorMode = StorageManagerMirrorMode_PrimaryOnly;
else if (!mirrorOnly)
*mirrorMode = StorageManagerMirrorMode_Both;
else
*mirrorMode = StorageManagerMirrorMode_MirrorOnly;
break;
case MirrorDataLossTrackingState_MirrorCurrentlyUpInResync:
if (primaryOnly)
*mirrorMode = StorageManagerMirrorMode_PrimaryOnly;
else if (!mirrorOnly)
*mirrorMode = StorageManagerMirrorMode_Both;
else
*mirrorMode = StorageManagerMirrorMode_MirrorOnly;
break;
case MirrorDataLossTrackingState_MirrorDown:
if (!mirrorOnly)
*mirrorMode = StorageManagerMirrorMode_PrimaryOnly;
else
*mirrorMode = StorageManagerMirrorMode_MirrorOnly; // Mirror only operations fails from the outset.
*mirrorDataLossOccurred = true; // Mirror communication is down.
break;
default:
elog(ERROR, "Unexpected mirror data loss tracking state: %d",
mirrorDataLossTrackingState);
*mirrorMode = StorageManagerMirrorMode_None; // A happy optimizer is the sound of one hand clapping.
}
}
}
/*
* mdrmfilespacedir() -- Remove a filespace directory on magnetic disk.
*
* If isRedo is true, it's okay for the filespace directory to exist already.
*/
bool
mdrmfilespacedir(
Oid filespaceOid,
char *primaryFilespaceLocation,
/*
* The primary filespace directory path. NOT Blank padded.
* Just a NULL terminated string.
*/
char *mirrorFilespaceLocation,
bool primaryOnly,
bool mirrorOnly,
bool ignoreNonExistence,
bool *mirrorDataLossOccurred)
{
StorageManagerMirrorMode mirrorMode;
bool result;
*mirrorDataLossOccurred = false;
mdsetupdropobjmirroraccess(
primaryOnly,
mirrorOnly,
&mirrorMode,
mirrorDataLossOccurred);
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_MirrorDrop(
FileRep_GetDirFilespaceIdentifier(
mirrorFilespaceLocation),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (StorageManagerMirrorMode_DoPrimaryWork(mirrorMode))
{
// The rmtree routine unfortunately emits errors, so there is not errno available...
// Just a bool.
result = rmtree(primaryFilespaceLocation, true);
}
else
result = true;
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_IsOperationCompleted(
FileRep_GetDirFilespaceIdentifier(
mirrorFilespaceLocation),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
return result;
}
/*
* mdrmtablespacedir() -- Remove a tablespace directory on magnetic disk.
*
* If isRedo is true, it's okay for the tablespace directory to exist already.
*/
bool
mdrmtablespacedir(
Oid tablespaceOid,
bool primaryOnly,
bool mirrorOnly,
bool ignoreNonExistence,
bool *mirrorDataLossOccurred)
{
StorageManagerMirrorMode mirrorMode;
char *primaryFilespaceLocation;
char *mirrorFilespaceLocation;
char tablespacePath[MAXPGPATH];
bool result;
*mirrorDataLossOccurred = false;
mdsetupdropobjmirroraccess(
primaryOnly,
mirrorOnly,
&mirrorMode,
mirrorDataLossOccurred);
PersistentTablespace_GetPrimaryAndMirrorFilespaces(
tablespaceOid,
&primaryFilespaceLocation,
&mirrorFilespaceLocation);
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_MirrorDrop(
FileRep_GetDirTablespaceIdentifier(
mirrorFilespaceLocation,
tablespaceOid),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (StorageManagerMirrorMode_DoPrimaryWork(mirrorMode))
{
/*
* We've removed all relations, so all that is left are PG* files and work files.
*/
FormTablespacePath(
tablespacePath,
primaryFilespaceLocation,
tablespaceOid);
// The rmtree routine unfortunately emits errors, so there is not errno available...
// Just a bool.
result = rmtree(tablespacePath, true);
}
else
result = true;
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_IsOperationCompleted(
FileRep_GetDirTablespaceIdentifier(
mirrorFilespaceLocation,
tablespaceOid),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (primaryFilespaceLocation != NULL)
pfree(primaryFilespaceLocation);
if (mirrorFilespaceLocation != NULL)
pfree(mirrorFilespaceLocation);
return result;
}
/*
* mdrmbdir() -- Remove a database directory on magnetic disk.
*
* If isRedo is true, it's okay for the database directory to exist already.
*/
bool
mdrmdbdir(
DbDirNode *dbDirNode,
bool primaryOnly,
bool mirrorOnly,
bool ignoreNonExistence,
bool *mirrorDataLossOccurred)
{
StorageManagerMirrorMode mirrorMode;
char *primaryFilespaceLocation;
char *mirrorFilespaceLocation;
char dbPath[MAXPGPATH];
bool result;
*mirrorDataLossOccurred = false;
mdsetupdropobjmirroraccess(
primaryOnly,
mirrorOnly,
&mirrorMode,
mirrorDataLossOccurred);
PersistentTablespace_GetPrimaryAndMirrorFilespaces(
dbDirNode->tablespace,
&primaryFilespaceLocation,
&mirrorFilespaceLocation);
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_MirrorDrop(
FileRep_GetDirDatabaseIdentifier(
mirrorFilespaceLocation,
*dbDirNode),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (StorageManagerMirrorMode_DoPrimaryWork(mirrorMode))
{
/*
* We've removed all relations, so all that is left are PG* files and work files.
*/
FormDatabasePath(
dbPath,
primaryFilespaceLocation,
dbDirNode->tablespace,
dbDirNode->database);
// The rmtree routine unfortunately emits errors, so there is not errno available...
// Just a bool.
result = rmtree(dbPath, true);
}
else
result = true;
if (StorageManagerMirrorMode_SendToMirror(mirrorMode) &&
!*mirrorDataLossOccurred)
{
FileRepPrimary_IsOperationCompleted(
FileRep_GetDirDatabaseIdentifier(
mirrorFilespaceLocation,
*dbDirNode),
FileRepRelationTypeDir);
*mirrorDataLossOccurred = FileRepPrimary_IsMirrorDataLossOccurred();
}
if (primaryFilespaceLocation != NULL)
pfree(primaryFilespaceLocation);
if (mirrorFilespaceLocation != NULL)
pfree(mirrorFilespaceLocation);
return result;
}
src/backend/storage/smgr/smgr.c
浏览文件 @ 306b189d
此差异已折叠。
src/backend/storage/smgr/smgr_ao.c 0 → 100644
浏览文件 @ 306b189d
此差异已折叠。
src/include/storage/smgr.h
浏览文件 @ 306b189d
......@@ -340,46 +340,10 @@ extern bool smgrgetpersistentinfo(
int64 *persistentSerialNum);
extern void smgrimmedsync(SMgrRelation reln);
extern void smgrappendonlymirrorresynceofs(
RelFileNode *relFileNode,
int32 segmentFileNum,
char *relationName,
ItemPointer persistentTid,
int64 persistentSerialNum,
bool mirrorCatchupRequired,
MirrorDataLossTrackingState mirrorDataLossTrackingState,
int64 mirrorDataLossTrackingSessionNum,
int64 mirrorNewEof);
extern bool smgrgetappendonlyinfo(
RelFileNode *relFileNode,
int32 segmentFileNum,
char *relationName,
bool *mirrorCatchupRequired,
MirrorDataLossTrackingState *mirrorDataLossTrackingState,
int64 *mirrorDataLossTrackingSessionNum);
extern int smgrGetPendingFileSysWork(EndXactRecKind endXactRecKind,
PersistentEndXactFileSysActionInfo **ptr);
extern int smgrGetAppendOnlyMirrorResyncEofs(
EndXactRecKind endXactRecKind,
PersistentEndXactAppendOnlyMirrorResyncEofs **ptr);
extern bool smgrIsPendingFileSysWork(
EndXactRecKind endXactRecKind);
extern bool smgrIsAppendOnlyMirrorResyncEofs(
EndXactRecKind endXactRecKind);
extern void AtSubCommit_smgr(void);
extern void AtSubAbort_smgr(void);
extern void AtEOXact_smgr(bool forCommit);
......@@ -399,6 +363,47 @@ extern void smgr_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record);
/* in md.c */
extern void mdinit(void);
extern void mdclose(SMgrRelation reln);
extern void mdcreate(
SMgrRelation reln,
char *relationName,
/* For tracing only. Can be NULL in some execution paths. */
MirrorDataLossTrackingState mirrorDataLossTrackingState,
int64 mirrorDataLossTrackingSessionNum,
bool ignoreAlreadyExists,
bool *mirrorDataLossOccurred);
extern void mdunlink(
RelFileNode rnode,
char *relationName,
/* For tracing only. Can be NULL in some execution paths. */
bool primaryOnly,
bool isRedo,
bool ignoreNonExistence,
bool *mirrorDataLossOccurred);
extern void mdextend(SMgrRelation reln, BlockNumber blocknum, char *buffer,
bool isTemp);
extern void mdread(SMgrRelation reln, BlockNumber blocknum, char *buffer);
extern void mdwrite(SMgrRelation reln, BlockNumber blocknum, char *buffer,
bool isTemp);
extern BlockNumber mdnblocks(SMgrRelation reln);
extern void mdtruncate(SMgrRelation reln, BlockNumber nblocks,
bool isTemp, bool allowedNotFound);
extern void mdimmedsync(SMgrRelation reln);
extern void mdpreckpt(void);
extern void mdsync(void);
extern void mdpostckpt(void);
/* md_gp.c */
extern int errdetail_nonexistent_relation(int error, RelFileNode *relFileNode);
extern void mdcreatefilespacedir(
Oid filespaceOid,
......@@ -436,32 +441,6 @@ extern void mdcreatedbdir(
int *primaryError,
bool *mirrorDataLossOccurred);
extern void mdcreate(
SMgrRelation reln,
char *relationName,
/* For tracing only. Can be NULL in some execution paths. */
MirrorDataLossTrackingState mirrorDataLossTrackingState,
int64 mirrorDataLossTrackingSessionNum,
bool ignoreAlreadyExists,
bool *mirrorDataLossOccurred);
extern void mdunlink(
RelFileNode rnode,
char *relationName,
/* For tracing only. Can be NULL in some execution paths. */
bool primaryOnly,
bool isRedo,
bool ignoreNonExistence,
bool *mirrorDataLossOccurred);
extern bool mdrmfilespacedir(
Oid filespaceOid,
......@@ -501,18 +480,7 @@ extern bool mdrmdbdir(
bool ignoreNonExistence,
bool *mirrorDataLossOccurred);
extern void mdextend(SMgrRelation reln, BlockNumber blocknum, char *buffer,
bool isTemp);
extern void mdread(SMgrRelation reln, BlockNumber blocknum, char *buffer);
extern void mdwrite(SMgrRelation reln, BlockNumber blocknum, char *buffer,
bool isTemp);
extern BlockNumber mdnblocks(SMgrRelation reln);
extern void mdtruncate(SMgrRelation reln, BlockNumber nblocks,
bool isTemp, bool allowedNotFound);
extern void mdimmedsync(SMgrRelation reln);
extern void mdpreckpt(void);
extern void mdsync(void);
extern void mdpostckpt(void);
/*
* MPP-18228 - to make addition to pending delete list atomic with adding
......
src/include/storage/smgr_ao.h 0 → 100644
浏览文件 @ 306b189d
/*-------------------------------------------------------------------------
*
* smgr_ao.h
* Tracking which AO tables need to be fsync'd at end of transaction.
*
*
* Portions Copyright (c) 2006-2008, Greenplum inc
* Portions Copyright (c) 2012-Present Pivotal Software, Inc.
* Portions Copyright (c) 1996-2008, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
* src/include/storage/sgmr_gp.h
*
*-------------------------------------------------------------------------
*/
#ifndef SMGR_AO_H
#define SMGR_AO_H
#include "storage/relfilenode.h"
#include "storage/dbdirnode.h"
#include "access/persistentendxactrec.h"
#include "access/filerepdefs.h"
/* prototypes for functions in smgr_ao.c */
extern bool smgrgetappendonlyinfo(
RelFileNode *relFileNode,
int32 segmentFileNum,
char *relationName,
bool *mirrorCatchupRequired,
MirrorDataLossTrackingState *mirrorDataLossTrackingState,
int64 *mirrorDataLossTrackingSessionNum);
extern void smgrappendonlymirrorresynceofs(
RelFileNode *relFileNode,
int32 segmentFileNum,
char *relationName,
ItemPointer persistentTid,
int64 persistentSerialNum,
bool mirrorCatchupRequired,
MirrorDataLossTrackingState mirrorDataLossTrackingState,
int64 mirrorDataLossTrackingSessionNum,
int64 mirrorNewEof);
extern int smgrGetAppendOnlyMirrorResyncEofs(
EndXactRecKind endXactRecKind,
PersistentEndXactAppendOnlyMirrorResyncEofs **ptr);
extern bool smgrIsAppendOnlyMirrorResyncEofs(
EndXactRecKind endXactRecKind);
extern void AppendOnlyMirrorResyncEofs_HashTableInit(void);
extern void AppendOnlyMirrorResyncEofs_Merge(
RelFileNode *relFileNode,
int32 segmentFileNum,
int nestLevel, /* Transaction nesting level. */
char *relationName,
ItemPointer persistentTid,
int64 persistentSerialNum,
bool mirrorCatchupRequired,
MirrorDataLossTrackingState mirrorDataLossTrackingState,
int64 mirrorDataLossTrackingSessionNum,
int64 mirrorNewEof);
extern void AppendOnlyMirrorResyncEofs_RemoveForDrop(
RelFileNode *relFileNode,
int32 segmentFileNum,
int nestLevel); /* Transaction nesting level. */
extern void AppendOnlyMirrorResyncEofs_HashTableRemove(char *procName);
extern void smgrDoAppendOnlyResyncEofs(bool forCommit);
extern void smgrAppendOnlySubTransAbort(void);
extern void AtSubCommit_smgr_appendonly(void);
#endif /* SMGR_GP_H */
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或