| 780 | } |
| 781 | |
| 782 | static void |
| 783 | pg_decode_stream_stop(LogicalDecodingContext *ctx, |
| 784 | ReorderBufferTXN *txn) |
| 785 | { |
| 786 | TestDecodingData *data = ctx->output_plugin_private; |
| 787 | TestDecodingTxnData *txndata = txn->output_plugin_private; |
| 788 | |
| 789 | if (data->skip_empty_xacts && !txndata->stream_wrote_changes) |
| 790 | return; |
| 791 | |
| 792 | OutputPluginPrepareWrite(ctx, true); |
| 793 | if (data->include_xids) |
| 794 | appendStringInfo(ctx->out, "closing a streamed block for transaction TXN %u", txn->xid); |
| 795 | else |
| 796 | appendStringInfoString(ctx->out, "closing a streamed block for transaction"); |
| 797 | OutputPluginWrite(ctx, true); |
| 798 | } |
| 799 | |
| 800 | static void |
| 801 | pg_decode_stream_abort(LogicalDecodingContext *ctx, |
nothing calls this directly
no test coverage detected