|
|
|
@ -800,7 +800,7 @@ startup_cb_wrapper(LogicalDecodingContext *ctx, OutputPluginOptions *opt, bool i |
|
|
|
state.callback_name = "startup"; |
|
|
|
state.callback_name = "startup"; |
|
|
|
state.report_location = InvalidXLogRecPtr; |
|
|
|
state.report_location = InvalidXLogRecPtr; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -828,7 +828,7 @@ shutdown_cb_wrapper(LogicalDecodingContext *ctx) |
|
|
|
state.callback_name = "shutdown"; |
|
|
|
state.callback_name = "shutdown"; |
|
|
|
state.report_location = InvalidXLogRecPtr; |
|
|
|
state.report_location = InvalidXLogRecPtr; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -862,7 +862,7 @@ begin_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn) |
|
|
|
state.callback_name = "begin"; |
|
|
|
state.callback_name = "begin"; |
|
|
|
state.report_location = txn->first_lsn; |
|
|
|
state.report_location = txn->first_lsn; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -894,7 +894,7 @@ commit_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "commit"; |
|
|
|
state.callback_name = "commit"; |
|
|
|
state.report_location = txn->final_lsn; /* beginning of commit record */ |
|
|
|
state.report_location = txn->final_lsn; /* beginning of commit record */ |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -935,7 +935,7 @@ begin_prepare_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn) |
|
|
|
state.callback_name = "begin_prepare"; |
|
|
|
state.callback_name = "begin_prepare"; |
|
|
|
state.report_location = txn->first_lsn; |
|
|
|
state.report_location = txn->first_lsn; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -980,7 +980,7 @@ prepare_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "prepare"; |
|
|
|
state.callback_name = "prepare"; |
|
|
|
state.report_location = txn->final_lsn; /* beginning of prepare record */ |
|
|
|
state.report_location = txn->final_lsn; /* beginning of prepare record */ |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1025,7 +1025,7 @@ commit_prepared_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "commit_prepared"; |
|
|
|
state.callback_name = "commit_prepared"; |
|
|
|
state.report_location = txn->final_lsn; /* beginning of commit record */ |
|
|
|
state.report_location = txn->final_lsn; /* beginning of commit record */ |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1071,7 +1071,7 @@ rollback_prepared_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "rollback_prepared"; |
|
|
|
state.callback_name = "rollback_prepared"; |
|
|
|
state.report_location = txn->final_lsn; /* beginning of commit record */ |
|
|
|
state.report_location = txn->final_lsn; /* beginning of commit record */ |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1114,7 +1114,7 @@ change_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "change"; |
|
|
|
state.callback_name = "change"; |
|
|
|
state.report_location = change->lsn; |
|
|
|
state.report_location = change->lsn; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1156,7 +1156,7 @@ truncate_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "truncate"; |
|
|
|
state.callback_name = "truncate"; |
|
|
|
state.report_location = change->lsn; |
|
|
|
state.report_location = change->lsn; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1195,7 +1195,7 @@ filter_prepare_cb_wrapper(LogicalDecodingContext *ctx, TransactionId xid, |
|
|
|
state.callback_name = "filter_prepare"; |
|
|
|
state.callback_name = "filter_prepare"; |
|
|
|
state.report_location = InvalidXLogRecPtr; |
|
|
|
state.report_location = InvalidXLogRecPtr; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1226,7 +1226,7 @@ filter_by_origin_cb_wrapper(LogicalDecodingContext *ctx, RepOriginId origin_id) |
|
|
|
state.callback_name = "filter_by_origin"; |
|
|
|
state.callback_name = "filter_by_origin"; |
|
|
|
state.report_location = InvalidXLogRecPtr; |
|
|
|
state.report_location = InvalidXLogRecPtr; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1262,7 +1262,7 @@ message_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "message"; |
|
|
|
state.callback_name = "message"; |
|
|
|
state.report_location = message_lsn; |
|
|
|
state.report_location = message_lsn; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1298,7 +1298,7 @@ stream_start_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "stream_start"; |
|
|
|
state.callback_name = "stream_start"; |
|
|
|
state.report_location = first_lsn; |
|
|
|
state.report_location = first_lsn; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1347,7 +1347,7 @@ stream_stop_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "stream_stop"; |
|
|
|
state.callback_name = "stream_stop"; |
|
|
|
state.report_location = last_lsn; |
|
|
|
state.report_location = last_lsn; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1396,7 +1396,7 @@ stream_abort_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "stream_abort"; |
|
|
|
state.callback_name = "stream_abort"; |
|
|
|
state.report_location = abort_lsn; |
|
|
|
state.report_location = abort_lsn; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1441,7 +1441,7 @@ stream_prepare_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "stream_prepare"; |
|
|
|
state.callback_name = "stream_prepare"; |
|
|
|
state.report_location = txn->final_lsn; |
|
|
|
state.report_location = txn->final_lsn; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1482,7 +1482,7 @@ stream_commit_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "stream_commit"; |
|
|
|
state.callback_name = "stream_commit"; |
|
|
|
state.report_location = txn->final_lsn; |
|
|
|
state.report_location = txn->final_lsn; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1523,7 +1523,7 @@ stream_change_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "stream_change"; |
|
|
|
state.callback_name = "stream_change"; |
|
|
|
state.report_location = change->lsn; |
|
|
|
state.report_location = change->lsn; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1577,7 +1577,7 @@ stream_message_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "stream_message"; |
|
|
|
state.callback_name = "stream_message"; |
|
|
|
state.report_location = message_lsn; |
|
|
|
state.report_location = message_lsn; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1618,7 +1618,7 @@ stream_truncate_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "stream_truncate"; |
|
|
|
state.callback_name = "stream_truncate"; |
|
|
|
state.report_location = change->lsn; |
|
|
|
state.report_location = change->lsn; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
@ -1657,7 +1657,7 @@ update_progress_txn_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn, |
|
|
|
state.callback_name = "update_progress_txn"; |
|
|
|
state.callback_name = "update_progress_txn"; |
|
|
|
state.report_location = lsn; |
|
|
|
state.report_location = lsn; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.callback = output_plugin_error_callback; |
|
|
|
errcallback.arg = (void *) &state; |
|
|
|
errcallback.arg = &state; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
errcallback.previous = error_context_stack; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
error_context_stack = &errcallback; |
|
|
|
|
|
|
|
|
|
|
|
|