Skip to content

Commit 12878dd

Browse files
committed
Add a debug_assert to ensure we don't try to use broken transaction managers
1 parent 7c6f301 commit 12878dd

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/transaction_manager.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -182,6 +182,10 @@ impl AnsiTransactionManager {
182182
where
183183
F: std::future::Future,
184184
{
185+
debug_assert!(
186+
!is_broken.load(Ordering::Relaxed),
187+
"Tried to execute a transaction SQL on transaction manager that was previously cancled"
188+
);
185189
is_broken.store(true, Ordering::Relaxed);
186190
let res = f.await;
187191
is_broken.store(false, Ordering::Relaxed);

0 commit comments

Comments
 (0)