diff options
Diffstat (limited to 'src/include')
| -rw-r--r-- | src/include/replication/walsender_private.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/include/replication/walsender_private.h b/src/include/replication/walsender_private.h index ff25aa70a89..7d919583bd3 100644 --- a/src/include/replication/walsender_private.h +++ b/src/include/replication/walsender_private.h @@ -17,6 +17,7 @@ #include "nodes/nodes.h" #include "nodes/replnodes.h" #include "replication/syncrep.h" +#include "storage/condition_variable.h" #include "storage/latch.h" #include "storage/shmem.h" #include "storage/spin.h" @@ -108,6 +109,10 @@ typedef struct */ bool sync_standbys_defined; + /* used as a registry of physical / logical walsenders to wake */ + ConditionVariable wal_flush_cv; + ConditionVariable wal_replay_cv; + WalSnd walsnds[FLEXIBLE_ARRAY_MEMBER]; } WalSndCtlData; |