txndata->xact_wrote_changes = false;
txn->output_plugin_private = txndata;
+ /*
+ * If asked to skip empty transactions, we'll emit BEGIN at the point where
+ * the first operation is received for this transaction.
+ */
if (data->skip_empty_xacts)
return;
txndata->xact_wrote_changes = false;
txn->output_plugin_private = txndata;
+ /*
+ * If asked to skip empty transactions, we'll emit BEGIN at the point where
+ * the first operation is received for this transaction.
+ */
if (data->skip_empty_xacts)
return;
TestDecodingData *data = ctx->output_plugin_private;
TestDecodingTxnData *txndata = txn->output_plugin_private;
+ /*
+ * If asked to skip empty transactions, we'll emit PREPARE at the point
+ * where the first operation is received for this transaction.
+ */
if (data->skip_empty_xacts && !txndata->xact_wrote_changes)
return;