File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -134,7 +134,7 @@ handle_begin(StringInfo s)
134
134
135
135
in_remote_transaction = true;
136
136
137
- pgstat_report_activity (STATE_RUNNING , false );
137
+ pgstat_report_activity (STATE_RUNNING , NULL );
138
138
}
139
139
140
140
/*
Original file line number Diff line number Diff line change @@ -406,7 +406,7 @@ pglogical_worker_shmem_startup(void)
406
406
407
407
if (!found )
408
408
{
409
- PGLogicalCtx -> lock = LWLockAssign () ;
409
+ PGLogicalCtx -> lock = & ( GetNamedLWLockTranche ( "pglogical" )) -> lock ;
410
410
PGLogicalCtx -> supervisor = NULL ;
411
411
PGLogicalCtx -> total_workers = max_worker_processes ;
412
412
memset (PGLogicalCtx -> workers , 0 ,
@@ -430,7 +430,7 @@ pglogical_worker_shmem_init(void)
430
430
* tries to allocate or free blocks from this array at once. There won't
431
431
* be enough contention to make anything fancier worth doing.
432
432
*/
433
- RequestAddinLWLocks ( 1 );
433
+ RequestNamedLWLockTranche ( "pglogical" , 1 );
434
434
435
435
/*
436
436
* Whether this is a first startup or crash recovery, we'll be re-initing
You can’t perform that action at this time.
0 commit comments