@@ -3197,16 +3197,17 @@ ReorderBufferAddNewTupleCids(ReorderBuffer *rb, TransactionId xid,
3197
3197
}
3198
3198
3199
3199
/*
3200
- *Setup theinvalidation of the toplevel transaction .
3200
+ *Accumulate theinvalidations for executing them later .
3201
3201
*
3202
3202
* This needs to be called for each XLOG_XACT_INVALIDATIONS message and
3203
- * accumulates all the invalidation messages in the toplevel transaction as
3204
- * well as in the form of change in reorder buffer. We require to record it in
3205
- * form of the change so that we can execute only the required invalidations
3206
- * instead of executing all the invalidations on each CommandId increment. We
3207
- * also need to accumulate these in the toplevel transaction because in some
3208
- * cases we skip processing the transaction (see ReorderBufferForget), we need
3209
- * to execute all the invalidations together.
3203
+ * accumulates all the invalidation messages in the toplevel transaction, if
3204
+ * available, otherwise in the current transaction, as well as in the form of
3205
+ * change in reorder buffer. We require to record it in form of the change
3206
+ * so that we can execute only the required invalidations instead of executing
3207
+ * all the invalidations on each CommandId increment. We also need to
3208
+ * accumulate these in the txn buffer because in some cases where we skip
3209
+ * processing the transaction (see ReorderBufferForget), we need to execute
3210
+ * all the invalidations together.
3210
3211
*/
3211
3212
void
3212
3213
ReorderBufferAddInvalidations (ReorderBuffer * rb ,TransactionId xid ,
@@ -3222,8 +3223,9 @@ ReorderBufferAddInvalidations(ReorderBuffer *rb, TransactionId xid,
3222
3223
oldcontext = MemoryContextSwitchTo (rb -> context );
3223
3224
3224
3225
/*
3225
- * Collect all the invalidations under the top transaction so that we can
3226
- * execute them all together. See comment atop this function
3226
+ * Collect all the invalidations under the top transaction, if available,
3227
+ * so that we can execute them all together. See comments atop this
3228
+ * function.
3227
3229
*/
3228
3230
if (txn -> toptxn )
3229
3231
txn = txn -> toptxn ;