Commit6cf00c3

Vladimir Ershov

committed

reread guc in db_role

1 parentca2dc0f commit6cf00c3Copy full SHA for 6cf00c3

File tree

+16

-2

lines changed

+16

-2

lines changed

Lines changed: 10 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -21,13 +21,15 @@`
`21`	`21`	`#include"utils/snapmgr.h"`
`22`	`22`	`#include"utils/datetime.h"`
`23`	`23`	`#include"catalog/pg_db_role_setting.h"`
	`24`	`+#include"commands/dbcommands.h"`
`24`	`25`
`25`	`26`	`#include"char_array.h"`
`26`	`27`	`#include"sched_manager_poll.h"`
`27`	`28`	`#include"cron_string.h"`
`28`	`29`	`#include"pgpro_scheduler.h"`
`29`	`30`	`#include"scheduler_manager.h"`
`30`	`31`	`#include"memutils.h"`
	`32`	`+#include"scheduler_spi_utils.h"`
`31`	`33`
`32`	`34`
`33`	`35`	`#ifdefPG_MODULE_MAGIC`
`@@ -69,16 +71,23 @@ worker_spi_sigterm(SIGNAL_ARGS)`
`69`	`71`
`70`	`72`	`/ Some utils /`
`71`	`73`
`72`		`-voidreload_db_role_config(Oiddatabaseid)`
	`74`	`+voidreload_db_role_config(char*dbname)`
`73`	`75`	`{`
`74`	`76`	`Relationrelsetting;`
`75`	`77`	`Snapshotsnapshot;`
	`78`	`+Oiddatabaseid;`
`76`	`79`
	`80`	`+StartTransactionCommand();`
	`81`	`+databaseid=get_database_oid(dbname, false);`
	`82`	`+`
	`83`	`+elog(LOG,"start read");`
`77`	`84`	`relsetting=heap_open(DbRoleSettingRelationId,AccessShareLock);`
`78`	`85`	`snapshot=RegisterSnapshot(GetCatalogSnapshot(DbRoleSettingRelationId));`
`79`	`86`	`ApplySetting(snapshot,databaseid,InvalidOid,relsetting,PGC_S_DATABASE);`
`80`	`87`	`UnregisterSnapshot(snapshot);`
`81`	`88`	`heap_close(relsetting,AccessShareLock);`
	`89`	`+CommitTransactionCommand();`
	`90`	`+elog(LOG,"got read");`
`82`	`91`	`}`
`83`	`92`
`84`	`93`	`TimestampTztimestamp_add_seconds(TimestampTzto,intadd)`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,7 @@ int checkSchedulerNamespace(void);`
`34`	`34`	`voidmanager_worker_main(Datumarg);`
`35`	`35`	`pid_tregisterManagerWorker(schd_manager_t*man);`
`36`	`36`
`37`		`-voidreload_db_role_config(Oiddatabaseid);`
	`37`	`+voidreload_db_role_config(char*dbname);`
`38`	`38`	`TimestampTztimestamp_add_seconds(TimestampTzto,intadd);`
`39`	`39`	`char*make_date_from_timestamp(TimestampTzts);`
`40`	`40`	`intget_integer_from_string(char*s,intstart,intlen);`

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1323,8 +1323,12 @@ void manager_worker_main(Datum arg)`
`1323`	`1323`	`if(rc&WL_POSTMASTER_DEATH)proc_exit(1);`
`1324`	`1324`	`if(got_sighup)`
`1325`	`1325`	`{`
	`1326`	`+elog(LOG,"manager got sighup");`
`1326`	`1327`	`got_sighup= false;`
`1327`	`1328`	`ProcessConfigFile(PGC_SIGHUP);`
	`1329`	`+elog(LOG,"DONE CONFIG");`
	`1330`	`+reload_db_role_config(database);`
	`1331`	`+elog(LOG,"DONE role");`
`1328`	`1332`	`refresh_scheduler_manager_context(ctx);`
`1329`	`1333`	`set_slots_stat_report(ctx);`
`1330`	`1334`	`}`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -240,3 +240,4 @@ int execute_spi(const char sql, char *error)`
`240`	`240`	`returnexecute_spi_sql_with_args(sql,0,NULL,NULL,NULL,error);`
`241`	`241`	`}`
`242`	`242`
	`243`	`+`

Comments

(0)