Skip to content

Commit 9595315

Browse files
committed
init cancel bomb berfore query exec
1 parent fc178de commit 9595315

1 file changed

Lines changed: 5 additions & 4 deletions

File tree

libsql-server/src/connection/libsql.rs

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -413,14 +413,15 @@ where
413413
cancelled
414414
};
415415

416+
PROGRAM_EXEC_COUNT.increment(1);
417+
418+
check_program_auth(&ctx, &pgm, &self.inner.lock().config_store.get())?;
419+
420+
// create the bomb right before spawning the blocking task.
416421
let mut bomb = Bomb {
417422
canceled,
418423
defused: false,
419424
};
420-
421-
PROGRAM_EXEC_COUNT.increment(1);
422-
423-
check_program_auth(&ctx, &pgm, &self.inner.lock().config_store.get())?;
424425
let conn = self.inner.clone();
425426
let ret = BLOCKING_RT
426427
.spawn_blocking(move || Connection::run(conn, pgm, builder))

0 commit comments

Comments
 (0)