@@ -3204,16 +3204,17 @@ ReorderBufferAddNewTupleCids(ReorderBuffer *rb, TransactionId xid,
32043204}
32053205
32063206/*
3207- *Setup theinvalidation of the toplevel transaction .
3207+ *Accumulate theinvalidations for executing them later .
32083208 *
32093209 * This needs to be called for each XLOG_XACT_INVALIDATIONS message and
3210- * accumulates all the invalidation messages in the toplevel transaction as
3211- * well as in the form of change in reorder buffer. We require to record it in
3212- * form of the change so that we can execute only the required invalidations
3213- * instead of executing all the invalidations on each CommandId increment. We
3214- * also need to accumulate these in the toplevel transaction because in some
3215- * cases we skip processing the transaction (see ReorderBufferForget), we need
3216- * to execute all the invalidations together.
3210+ * accumulates all the invalidation messages in the toplevel transaction, if
3211+ * available, otherwise in the current transaction, as well as in the form of
3212+ * change in reorder buffer. We require to record it in form of the change
3213+ * so that we can execute only the required invalidations instead of executing
3214+ * all the invalidations on each CommandId increment. We also need to
3215+ * accumulate these in the txn buffer because in some cases where we skip
3216+ * processing the transaction (see ReorderBufferForget), we need to execute
3217+ * all the invalidations together.
32173218 */
32183219void
32193220ReorderBufferAddInvalidations (ReorderBuffer * rb ,TransactionId xid ,
@@ -3229,8 +3230,9 @@ ReorderBufferAddInvalidations(ReorderBuffer *rb, TransactionId xid,
32293230oldcontext = MemoryContextSwitchTo (rb -> context );
32303231
32313232/*
3232- * Collect all the invalidations under the top transaction so that we can
3233- * execute them all together. See comment atop this function
3233+ * Collect all the invalidations under the top transaction, if available,
3234+ * so that we can execute them all together. See comments atop this
3235+ * function.
32343236 */
32353237if (txn -> toptxn )
32363238txn = txn -> toptxn ;
