Searched refs:txn_err (Results 1 – 9 of 9) sorted by relevance
487 my $txn_err = $@;489 $txn_err .= $rollback_ok ? ' (Rollback OK)' : "(Rollback failed: $@)";490 DBIx::RetryOverDisconnects::Exception->new($txn_err)->throw;
119 error = rd_kafka_error_new_fatal(rk->rk_eos.txn_err, in rd_kafka_txn_require_states0()122 error = rd_kafka_error_new(rk->rk_eos.txn_err, in rd_kafka_txn_require_states0()294 rk->rk_eos.txn_err = err; in rd_kafka_txn_set_fatal_error()349 if (rk->rk_eos.txn_err) { in rd_kafka_txn_set_abortable_error0()361 rk->rk_eos.txn_err = err; in rd_kafka_txn_set_abortable_error0()505 rk->rk_eos.txn_err ? in rd_kafka_txn_idemp_state_change()506 rk->rk_eos.txn_err : in rd_kafka_txn_idemp_state_change()1454 rk->rk_eos.txn_err = RD_KAFKA_RESP_ERR_NO_ERROR; in rd_kafka_txn_op_begin_transaction()2180 rk->rk_eos.txn_err, in rd_kafka_txn_handle_EndTxn()2193 rk->rk_eos.txn_err, in rd_kafka_txn_handle_EndTxn()[all …]
493 rd_kafka_resp_err_t txn_err; member
119 error = rd_kafka_error_new_fatal(rk->rk_eos.txn_err,122 error = rd_kafka_error_new(rk->rk_eos.txn_err,294 rk->rk_eos.txn_err = err;349 if (rk->rk_eos.txn_err) {361 rk->rk_eos.txn_err = err;505 rk->rk_eos.txn_err ?506 rk->rk_eos.txn_err :1454 rk->rk_eos.txn_err = RD_KAFKA_RESP_ERR_NO_ERROR;2173 rk->rk_eos.txn_err,2186 rk->rk_eos.txn_err,[all …]
184 goto txn_err;202 goto txn_err;214 txn_err:
183 goto txn_err;201 goto txn_err;213 txn_err: __db_errx(env,
261 rk->rk_eos.txn_err = err; in rd_kafka_txn_set_fatal_error()308 if (rk->rk_eos.txn_err) { in rd_kafka_txn_set_abortable_error()315 rd_kafka_err2name(rk->rk_eos.txn_err)); in rd_kafka_txn_set_abortable_error()320 rk->rk_eos.txn_err = err; in rd_kafka_txn_set_abortable_error()442 rk->rk_eos.txn_err ? in rd_kafka_txn_idemp_state_change()443 rk->rk_eos.txn_err : in rd_kafka_txn_idemp_state_change()1298 rk->rk_eos.txn_err = RD_KAFKA_RESP_ERR_NO_ERROR; in rd_kafka_txn_op_begin_transaction()
479 rd_kafka_resp_err_t txn_err; member