File tree Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Expand file tree Collapse file tree 2 files changed +5
-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 @@ -407,7 +407,8 @@ pglogical_worker_shmem_startup(void)
407
407
408
408
if (!found )
409
409
{
410
- PGLogicalCtx -> lock = LWLockAssign ();
410
+ // PGLogicalCtx->lock = LWLockAssign();
411
+ PGLogicalCtx -> lock = & (GetNamedLWLockTranche ("pglogical" ))-> lock ;
411
412
PGLogicalCtx -> supervisor = NULL ;
412
413
PGLogicalCtx -> total_workers = max_worker_processes ;
413
414
memset (PGLogicalCtx -> workers , 0 ,
@@ -431,7 +432,8 @@ pglogical_worker_shmem_init(void)
431
432
* tries to allocate or free blocks from this array at once. There won't
432
433
* be enough contention to make anything fancier worth doing.
433
434
*/
434
- RequestAddinLWLocks (1 );
435
+ // RequestAddinLWLocks(1);
436
+ RequestNamedLWLockTranche ("pglogical" , 1 );
435
437
436
438
/*
437
439
* 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