Function check_prepare_result

src/jrd/vio.cpp:1893–1947

static bool check_prepare_result(PrepareResult prepare_result, jrd_tra* transaction,
	Request* request, record_param* rpb)
{
/**************************************
 *
 *	c h e c k _ p r e p a r e _ r e s u l t
 *
 **************************************
 *
 * Functional description
 *	Called by VIO_modify and VIO_erase. Raise update conflict error if not in
 *  read consistency transaction or lock error happens or if request is already
 *  in update conflict mode. In latter case set TRA_ex_restart flag to correctly
 *  handle request restart.
 *	If record should be skipped, return false also.
 *
 **************************************/
	if (prepare_result == PrepareResult::SUCCESS)
		return true;

	if ((rpb->rpb_stream_flags & RPB_s_skipLocked) && prepare_result == PrepareResult::SKIP_LOCKED)
		return false;

	fb_assert(prepare_result != PrepareResult::SKIP_LOCKED);

	Request* top_request = request->req_snapshot.m_owner;

	const bool restart_ready = top_request &&
		(top_request->req_flags & req_restart_ready);

	// Second update conflict when request is already in update conflict mode
	// means we have some (indirect) UPDATE\DELETE in WHERE clause of primary
	// cursor. In this case all we can do is restart whole request immediately.
	const bool secondary = top_request &&
		(top_request->req_flags & req_update_conflict) &&
		(prepare_result != PrepareResult::LOCK_ERROR);

	if (!(transaction->tra_flags & TRA_read_consistency) || prepare_result == PrepareResult::LOCK_ERROR ||
		secondary || !restart_ready)
	{
		if (secondary)
			transaction->tra_flags |= TRA_ex_restart;

		ERR_post(Arg::Gds(isc_deadlock) <<
			Arg::Gds(isc_update_conflict) <<
			Arg::Gds(isc_concurrent_transaction) << Arg::Int64(rpb->rpb_transaction_nr));
	}

	if (top_request)
	{
		top_request->req_flags |= req_update_conflict;
		top_request->req_conflict_txn = rpb->rpb_transaction_nr;
	}
	return false;
}


bool VIO_erase(thread_db* tdbb, record_param* rpb, jrd_tra* transaction)