File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change 4444#include "utils/builtins.h"
4545#include "utils/timestamp.h"
4646#include "storage/shm_toc.h"
47+ #include "postmaster/autovacuum.h"
4748#include "postmaster/interrupt.h"
49+ #include "replication/walsender.h"
4850#include "storage/shm_mq.h"
4951#include "storage/ipc.h"
5052#include "tcop/tcopprot.h"
@@ -362,9 +364,13 @@ static Size
362364dmq_shmem_size (void )
363365{
364366 Size size = 0 ;
367+ int maxbackends = 0 ;
368+
369+ maxbackends = MaxConnections + autovacuum_max_workers +
370+ max_worker_processes + max_wal_senders + 1 ;
365371
366372 size = add_size (size , sizeof (struct DmqSharedState ));
367- size = add_size (size , hash_estimate_size (DMQ_MAX_SUBS_PER_BACKEND * MaxBackends ,
373+ size = add_size (size , hash_estimate_size (DMQ_MAX_SUBS_PER_BACKEND * maxbackends ,
368374 sizeof (DmqStreamSubscription )));
369375 return MAXALIGN (size );
370376}
You can’t perform that action at this time.
0 commit comments