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