Fix typo lint (#5860)
This commit is contained in:
committed by
GitHub
parent
68fde3ff97
commit
281bf066de
@@ -361,15 +361,15 @@ async fn test_lock_acquire_concurrent() {
|
|||||||
let pool1 = test_env.db.pool.clone();
|
let pool1 = test_env.db.pool.clone();
|
||||||
let pool2 = test_env.db.pool.clone();
|
let pool2 = test_env.db.pool.clone();
|
||||||
let barrier = Arc::new(Barrier::new(2));
|
let barrier = Arc::new(Barrier::new(2));
|
||||||
let ba = barrier.clone();
|
let barrier_a = barrier.clone();
|
||||||
let bb = barrier.clone();
|
let barrier_b = barrier.clone();
|
||||||
|
|
||||||
let h1 = tokio::spawn(async move {
|
let h1 = tokio::spawn(async move {
|
||||||
ba.wait().await;
|
barrier_a.wait().await;
|
||||||
DBModerationLock::acquire(project_id, mod1, &pool1).await
|
DBModerationLock::acquire(project_id, mod1, &pool1).await
|
||||||
});
|
});
|
||||||
let h2 = tokio::spawn(async move {
|
let h2 = tokio::spawn(async move {
|
||||||
bb.wait().await;
|
barrier_b.wait().await;
|
||||||
DBModerationLock::acquire(project_id, mod2, &pool2).await
|
DBModerationLock::acquire(project_id, mod2, &pool2).await
|
||||||
});
|
});
|
||||||
let (o1, o2) = tokio::join!(h1, h2);
|
let (o1, o2) = tokio::join!(h1, h2);
|
||||||
|
|||||||
Reference in New Issue
Block a user