@@ -66,7 +66,7 @@ typedef struct SpockGroupKey
6666/*
6767 * Columns for the UI routine get_apply_group_progress.
6868 */
69- typedef enum
69+ typedef enum GroupProgressTupDescColumns
7070{
7171 GP_DBOID = 0 ,
7272 GP_NODE_ID ,
@@ -115,35 +115,35 @@ typedef enum
115115 */
116116typedef struct SpockApplyProgress
117117{
118- SpockGroupKey key ; /* MUST be first field */
118+ SpockGroupKey key ; /* MUST be first field */
119119
120- TimestampTz remote_commit_ts ; /* committed remote txn ts */
120+ TimestampTz remote_commit_ts ; /* committed remote txn ts */
121121
122122 /*
123123 * Bit of duplication of remote_commit_ts. Serves the same purpose, except
124124 * keep the last updated value
125125 */
126- TimestampTz prev_remote_ts ;
127- XLogRecPtr remote_commit_lsn ; /* LSN of remote commit on origin */
128- XLogRecPtr remote_insert_lsn ; /* origin insert/end LSN reported */
126+ TimestampTz prev_remote_ts ;
127+ XLogRecPtr remote_commit_lsn ; /* LSN of remote commit on origin */
128+ XLogRecPtr remote_insert_lsn ; /* origin insert/end LSN reported */
129129
130130 /*
131131 * The largest received LSN by the group. It is more or equal to the
132132 * remote_commit_lsn.
133133 */
134- XLogRecPtr received_lsn ;
134+ XLogRecPtr received_lsn ;
135135
136- TimestampTz last_updated_ts ; /* when we set this */
137- bool updated_by_decode ; /* set by decode or apply. OBSOLETE. Used
136+ TimestampTz last_updated_ts ; /* when we set this */
137+ bool updated_by_decode ; /* set by decode or apply. OBSOLETE. Used
138138 * in versions <=5.x.x only */
139139} SpockApplyProgress ;
140140
141141/* Hash entry: one per group (stable pointer; not moved by dynahash) */
142142typedef struct SpockGroupEntry
143143{
144- SpockApplyProgress progress ;
145- pg_atomic_uint32 nattached ;
146- ConditionVariable prev_processed_cv ;
144+ SpockApplyProgress progress ;
145+ pg_atomic_uint32 nattached ;
146+ ConditionVariable prev_processed_cv ;
147147} SpockGroupEntry ;
148148
149149/* shmem setup */
0 commit comments