@@ -478,62 +478,53 @@ typedef void (*ReorderBufferRollbackPreparedCB) (ReorderBuffer *rb,
478478TimestampTz prepare_time );
479479
480480/* start streaming transaction callback signature */
481- typedef void (* ReorderBufferStreamStartCB ) (
482- ReorderBuffer * rb ,
481+ typedef void (* ReorderBufferStreamStartCB ) (ReorderBuffer * rb ,
483482ReorderBufferTXN * txn ,
484483XLogRecPtr first_lsn );
485484
486485/* stop streaming transaction callback signature */
487- typedef void (* ReorderBufferStreamStopCB ) (
488- ReorderBuffer * rb ,
486+ typedef void (* ReorderBufferStreamStopCB ) (ReorderBuffer * rb ,
489487ReorderBufferTXN * txn ,
490488XLogRecPtr last_lsn );
491489
492490/* discard streamed transaction callback signature */
493- typedef void (* ReorderBufferStreamAbortCB ) (
494- ReorderBuffer * rb ,
491+ typedef void (* ReorderBufferStreamAbortCB ) (ReorderBuffer * rb ,
495492ReorderBufferTXN * txn ,
496493XLogRecPtr abort_lsn );
497494
498495/* prepare streamed transaction callback signature */
499- typedef void (* ReorderBufferStreamPrepareCB ) (
500- ReorderBuffer * rb ,
496+ typedef void (* ReorderBufferStreamPrepareCB ) (ReorderBuffer * rb ,
501497ReorderBufferTXN * txn ,
502498XLogRecPtr prepare_lsn );
503499
504500/* commit streamed transaction callback signature */
505- typedef void (* ReorderBufferStreamCommitCB ) (
506- ReorderBuffer * rb ,
501+ typedef void (* ReorderBufferStreamCommitCB ) (ReorderBuffer * rb ,
507502ReorderBufferTXN * txn ,
508503XLogRecPtr commit_lsn );
509504
510505/* stream change callback signature */
511- typedef void (* ReorderBufferStreamChangeCB ) (
512- ReorderBuffer * rb ,
506+ typedef void (* ReorderBufferStreamChangeCB ) (ReorderBuffer * rb ,
513507ReorderBufferTXN * txn ,
514508Relation relation ,
515509ReorderBufferChange * change );
516510
517511/* stream message callback signature */
518- typedef void (* ReorderBufferStreamMessageCB ) (
519- ReorderBuffer * rb ,
512+ typedef void (* ReorderBufferStreamMessageCB ) (ReorderBuffer * rb ,
520513ReorderBufferTXN * txn ,
521514XLogRecPtr message_lsn ,
522515bool transactional ,
523516const char * prefix ,Size sz ,
524517const char * message );
525518
526519/* stream truncate callback signature */
527- typedef void (* ReorderBufferStreamTruncateCB ) (
528- ReorderBuffer * rb ,
520+ typedef void (* ReorderBufferStreamTruncateCB ) (ReorderBuffer * rb ,
529521ReorderBufferTXN * txn ,
530522int nrelations ,
531523Relation relations [],
532524ReorderBufferChange * change );
533525
534526/* update progress txn callback signature */
535- typedef void (* ReorderBufferUpdateProgressTxnCB ) (
536- ReorderBuffer * rb ,
527+ typedef void (* ReorderBufferUpdateProgressTxnCB ) (ReorderBuffer * rb ,
537528ReorderBufferTXN * txn ,
538529XLogRecPtr lsn );
539530