@@ -478,62 +478,53 @@ typedef void (*ReorderBufferRollbackPreparedCB) (ReorderBuffer *rb,
478
478
TimestampTz prepare_time );
479
479
480
480
/* start streaming transaction callback signature */
481
- typedef void (* ReorderBufferStreamStartCB ) (
482
- ReorderBuffer * rb ,
481
+ typedef void (* ReorderBufferStreamStartCB ) (ReorderBuffer * rb ,
483
482
ReorderBufferTXN * txn ,
484
483
XLogRecPtr first_lsn );
485
484
486
485
/* stop streaming transaction callback signature */
487
- typedef void (* ReorderBufferStreamStopCB ) (
488
- ReorderBuffer * rb ,
486
+ typedef void (* ReorderBufferStreamStopCB ) (ReorderBuffer * rb ,
489
487
ReorderBufferTXN * txn ,
490
488
XLogRecPtr last_lsn );
491
489
492
490
/* discard streamed transaction callback signature */
493
- typedef void (* ReorderBufferStreamAbortCB ) (
494
- ReorderBuffer * rb ,
491
+ typedef void (* ReorderBufferStreamAbortCB ) (ReorderBuffer * rb ,
495
492
ReorderBufferTXN * txn ,
496
493
XLogRecPtr abort_lsn );
497
494
498
495
/* prepare streamed transaction callback signature */
499
- typedef void (* ReorderBufferStreamPrepareCB ) (
500
- ReorderBuffer * rb ,
496
+ typedef void (* ReorderBufferStreamPrepareCB ) (ReorderBuffer * rb ,
501
497
ReorderBufferTXN * txn ,
502
498
XLogRecPtr prepare_lsn );
503
499
504
500
/* commit streamed transaction callback signature */
505
- typedef void (* ReorderBufferStreamCommitCB ) (
506
- ReorderBuffer * rb ,
501
+ typedef void (* ReorderBufferStreamCommitCB ) (ReorderBuffer * rb ,
507
502
ReorderBufferTXN * txn ,
508
503
XLogRecPtr commit_lsn );
509
504
510
505
/* stream change callback signature */
511
- typedef void (* ReorderBufferStreamChangeCB ) (
512
- ReorderBuffer * rb ,
506
+ typedef void (* ReorderBufferStreamChangeCB ) (ReorderBuffer * rb ,
513
507
ReorderBufferTXN * txn ,
514
508
Relation relation ,
515
509
ReorderBufferChange * change );
516
510
517
511
/* stream message callback signature */
518
- typedef void (* ReorderBufferStreamMessageCB ) (
519
- ReorderBuffer * rb ,
512
+ typedef void (* ReorderBufferStreamMessageCB ) (ReorderBuffer * rb ,
520
513
ReorderBufferTXN * txn ,
521
514
XLogRecPtr message_lsn ,
522
515
bool transactional ,
523
516
const char * prefix , Size sz ,
524
517
const char * message );
525
518
526
519
/* stream truncate callback signature */
527
- typedef void (* ReorderBufferStreamTruncateCB ) (
528
- ReorderBuffer * rb ,
520
+ typedef void (* ReorderBufferStreamTruncateCB ) (ReorderBuffer * rb ,
529
521
ReorderBufferTXN * txn ,
530
522
int nrelations ,
531
523
Relation relations [],
532
524
ReorderBufferChange * change );
533
525
534
526
/* update progress txn callback signature */
535
- typedef void (* ReorderBufferUpdateProgressTxnCB ) (
536
- ReorderBuffer * rb ,
527
+ typedef void (* ReorderBufferUpdateProgressTxnCB ) (ReorderBuffer * rb ,
537
528
ReorderBufferTXN * txn ,
538
529
XLogRecPtr lsn );
539
530
0 commit comments