shmem

RekGRpth · Nov 25, 2023 · 0452f11 · 0452f11
1 parent 293c26f
commit 0452f11
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/conf.c b/conf.c
@@ -38,7 +38,7 @@ static void conf_free(Work *w) {
     pfree(w);
 }
 
-static void conf_proc_exit(int code, Datum arg) {
+static void conf_shmem_exit(int code, Datum arg) {
     elog(DEBUG1, "code = %i", code);
 }
 
@@ -125,7 +125,7 @@ void conf_main(Datum arg) {
     dlist_mutable_iter iter;
     Portal portal;
     StringInfoData src;
-    on_proc_exit(conf_proc_exit, (Datum)NULL);
+    on_shmem_exit(conf_shmem_exit, (Datum)NULL);
     BackgroundWorkerUnblockSignals();
     BackgroundWorkerInitializeConnectionMy("postgres", NULL);
     MemoryContextSwitchTo(TopMemoryContext);

diff --git a/task.c b/task.c
@@ -304,7 +304,7 @@ static void task_execute(void) {
     if (IsTransactionState()) ereport(ERROR, (errcode(ERRCODE_ACTIVE_SQL_TRANSACTION), errmsg("still active sql transaction")));
 }
 
-static void task_proc_exit(int code, Datum arg) {
+static void task_shmem_exit(int code, Datum arg) {
     elog(DEBUG1, "code = %i", code);
     LWLockAcquire(BackgroundWorkerLock, LW_EXCLUSIVE);
     MemSet(&taskshared[DatumGetInt32(arg)], 0, sizeof(*taskshared));
@@ -375,7 +375,7 @@ void task_main(Datum arg) {
     elog(DEBUG1, "arg = %i", DatumGetInt32(arg));
     task.shared = &taskshared[DatumGetInt32(arg)];
     work.shared = &workshared[task.shared->slot];
-    on_proc_exit(task_proc_exit, arg);
+    on_shmem_exit(task_shmem_exit, arg);
     BackgroundWorkerUnblockSignals();
     work.data = quote_identifier(work.shared->data);
     work.schema = quote_identifier(work.shared->schema);

diff --git a/work.c b/work.c
@@ -417,7 +417,7 @@ static void work_connect(Task *t) {
     }
 }
 
-static void work_proc_exit(int code, Datum arg) {
+static void work_shmem_exit(int code, Datum arg) {
     dlist_mutable_iter iter;
     elog(DEBUG1, "code = %i", code);
     if (!code) {
@@ -859,7 +859,7 @@ void work_main(Datum arg) {
     Gp_session_role = GP_ROLE_DISPATCH;
 #endif
 #endif
-    on_proc_exit(work_proc_exit, arg);
+    on_shmem_exit(work_shmem_exit, arg);
     pqsignal(SIGHUP, SignalHandlerForConfigReload);
     pqsignal(SIGINT, work_idle);
     BackgroundWorkerUnblockSignals();