external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Rename GUC

pull/7254/head
EmelSimsek 2023-10-17 16:28:28 +03:00 committed by Emel Şimşek
parent 995cb0619a
commit d076b43000
3 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/backend/distributed/shared_library_init.c
View File

@ -481,7 +481,7 @@ _PG_init(void)
#endif #endif
InitializeMaintenanceDaemon(); InitializeMaintenanceDaemon();
InitializeMaintenanceDaemonForAdminDB(); InitializeMaintenanceDaemonForMainDb();
/* initialize coordinated transaction management */ /* initialize coordinated transaction management */
InitializeTransactionManagement(); InitializeTransactionManagement();
@ -1024,10 +1024,10 @@ RegisterCitusConfigVariables(void)
NULL, NULL, NULL); NULL, NULL, NULL);
DefineCustomStringVariable( DefineCustomStringVariable(
"citus.controldb_name", "citus.main_db",
gettext_noop("Which database is designated as the controldb"), gettext_noop("Which database is designated as the controldb"),
NULL, NULL,
&ControlDbName, &MainDb,
"", "",
PGC_POSTMASTER, PGC_POSTMASTER,
GUC_STANDARD, GUC_STANDARD,

12
src/backend/distributed/utils/maintenanced.c
View File

@ -99,7 +99,7 @@ int Recover2PCInterval = 60000;
int DeferShardDeleteInterval = 15000; int DeferShardDeleteInterval = 15000;
int BackgroundTaskQueueCheckInterval = 5000; int BackgroundTaskQueueCheckInterval = 5000;
int MaxBackgroundTaskExecutors = 4; int MaxBackgroundTaskExecutors = 4;
char *ControlDbName = ""; char *MainDb = "";
/* config variables for metadata sync timeout */ /* config variables for metadata sync timeout */
int MetadataSyncInterval = 60000; int MetadataSyncInterval = 60000;
@ -141,15 +141,15 @@ InitializeMaintenanceDaemon(void)
/* /*
* InitializeMaintenanceDaemonForAdminDB is called in _PG_Init * InitializeMaintenanceDaemonForMainDb is called in _PG_Init
* at which stage we are not in a transaction or have databaseOid * at which stage we are not in a transaction or have databaseOid
*/ */
void void
InitializeMaintenanceDaemonForAdminDB(void) InitializeMaintenanceDaemonForMainDb(void)
{ {
if (strcmp(ControlDbName, "") == 0) if (strcmp(MainDb, "") == 0)
{ {
elog(LOG, "There is no designated control database."); elog(LOG, "There is no designated main database.");
return; return;
} }
@ -341,7 +341,7 @@ CitusMaintenanceDaemonMain(Datum main_arg)
if (databaseOid == 0) if (databaseOid == 0)
{ {
char *databaseName = ControlDbName; char *databaseName = MainDb;
BackgroundWorkerInitializeConnection(databaseName, NULL, 0); BackgroundWorkerInitializeConnection(databaseName, NULL, 0);

4
src/include/distributed/maintenanced.h
View File

@ -20,7 +20,7 @@
/* config variable for */ /* config variable for */
extern double DistributedDeadlockDetectionTimeoutFactor; extern double DistributedDeadlockDetectionTimeoutFactor;
extern char *ControlDbName; extern char *MainDb;
extern void StopMaintenanceDaemon(Oid databaseId); extern void StopMaintenanceDaemon(Oid databaseId);
extern void TriggerNodeMetadataSync(Oid databaseId); extern void TriggerNodeMetadataSync(Oid databaseId);
@ -28,7 +28,7 @@ extern void InitializeMaintenanceDaemon(void);
extern size_t MaintenanceDaemonShmemSize(void); extern size_t MaintenanceDaemonShmemSize(void);
extern void MaintenanceDaemonShmemInit(void); extern void MaintenanceDaemonShmemInit(void);
extern void InitializeMaintenanceDaemonBackend(void); extern void InitializeMaintenanceDaemonBackend(void);
extern void InitializeMaintenanceDaemonForAdminDB(void); extern void InitializeMaintenanceDaemonForMainDb(void);
extern bool LockCitusExtension(void); extern bool LockCitusExtension(void);
extern PGDLLEXPORT void CitusMaintenanceDaemonMain(Datum main_arg); extern PGDLLEXPORT void CitusMaintenanceDaemonMain(Datum main_arg);