From 6c116dd47d53a293ed90cb19fa535bf988de3934 Mon Sep 17 00:00:00 2001 From: Andres Freund Date: Wed, 12 Mar 2014 18:26:10 +0100 Subject: [PATCH] bdr: adjustments for changed output plugin API --- contrib/bdr/bdr_output.c | 17 +++++++++++------ 1 file changed, 11 insertions(+), 6 deletions(-) diff --git a/contrib/bdr/bdr_output.c b/contrib/bdr/bdr_output.c index 9fb160c1cb..67f09cda82 100644 --- a/contrib/bdr/bdr_output.c +++ b/contrib/bdr/bdr_output.c @@ -159,28 +159,33 @@ pg_decode_change(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, case REORDER_BUFFER_CHANGE_INSERT: appendStringInfoChar(ctx->out, 'I'); /* action INSERT */ appendStringInfoChar(ctx->out, 'N'); /* new tuple follows */ - write_tuple(ctx->out, relation, &change->tp.newtuple->tuple); + write_tuple(ctx->out, relation, &change->data.tp.newtuple->tuple); break; case REORDER_BUFFER_CHANGE_UPDATE: appendStringInfoChar(ctx->out, 'U'); /* action UPDATE */ - if (change->tp.oldtuple != NULL) + if (change->data.tp.oldtuple != NULL) { appendStringInfoChar(ctx->out, 'K'); /* old key follows */ - write_tuple(ctx->out, relation, &change->tp.oldtuple->tuple); + write_tuple(ctx->out, relation, + &change->data.tp.oldtuple->tuple); } appendStringInfoChar(ctx->out, 'N'); /* new tuple follows */ - write_tuple(ctx->out, relation, &change->tp.newtuple->tuple); + write_tuple(ctx->out, relation, + &change->data.tp.newtuple->tuple); break; case REORDER_BUFFER_CHANGE_DELETE: appendStringInfoChar(ctx->out, 'D'); /* action DELETE */ - if (change->tp.oldtuple != NULL) + if (change->data.tp.oldtuple != NULL) { appendStringInfoChar(ctx->out, 'K'); /* old key follows */ - write_tuple(ctx->out, relation, &change->tp.oldtuple->tuple); + write_tuple(ctx->out, relation, + &change->data.tp.oldtuple->tuple); } else appendStringInfoChar(ctx->out, 'E'); /* empty */ break; + default: + Assert(false); } OutputPluginWrite(ctx, true); -- 2.39.5