Function handle_begin

nodedb/src/control/server/native/dispatch/transaction.rs:18–27

(ctx: &DispatchCtx<'_>, seq: u64)

use super::{DispatchCtx, error_to_native};

pub(crate) fn handle_begin(ctx: &DispatchCtx<'_>, seq: u64) -> NativeResponse {
    let snapshot_lsn = {
        let next = ctx.state.wal.next_lsn();
        crate::types::Lsn::new(next.as_u64().saturating_sub(1))
    };
    match ctx.sessions.begin(ctx.peer_addr, snapshot_lsn) {
        Ok(()) => NativeResponse::status_row(seq, "BEGIN"),
        Err(msg) => NativeResponse::error(seq, "25P02", msg),
    }
}

pub(crate) async fn handle_commit(ctx: &DispatchCtx<'_>, seq: u64) -> NativeResponse {
    // Snapshot isolation conflict check.