Skip to content

Commit 8791c89

Browse files
author
Antonin Houska
committed
Renamed function.
1 parent 4681f0a commit 8791c89

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

worker.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -156,7 +156,7 @@ static int squeezeWorkerSlotCount = 0;
156156
#define REPL_PLUGIN_NAME "pg_squeeze"
157157

158158
static void interrupt_worker(WorkerTask *task);
159-
static void initialize_task(WorkerTask *task);
159+
static void clear_task(WorkerTask *task);
160160
static void release_task(WorkerTask *task);
161161
static void squeeze_handle_error_app(ErrorData *edata, WorkerTask *task);
162162

@@ -257,7 +257,7 @@ squeeze_worker_shmem_startup(void)
257257
task = &workerData->tasks[i];
258258
SpinLockInit(&task->mutex);
259259

260-
initialize_task(task);
260+
clear_task(task);
261261
}
262262

263263
workerData->lock = &locks->lock;
@@ -629,7 +629,7 @@ get_unused_task(Oid dbid, char *relschema, char *relname, int *task_idx,
629629
* drop_replication_slots(). (The "standalone" worker should not
630630
* have set it.)
631631
*/
632-
initialize_task(task);
632+
clear_task(task);
633633
}
634634

635635
/*
@@ -2260,7 +2260,7 @@ interrupt_worker(WorkerTask *task)
22602260
}
22612261

22622262
static void
2263-
initialize_task(WorkerTask *task)
2263+
clear_task(WorkerTask *task)
22642264
{
22652265
task->worker_state = WTS_UNUSED;
22662266
task->exit_requested = false;

0 commit comments

Comments
 (0)