replace deprecated compare_and_swap() with compare_exchange() (#1080)

launchbadge · Mar 3, 2021 · edcc91c · edcc91c
1 parent d5f9f08
commit edcc91c
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/sqlx-core/src/pool/inner.rs b/sqlx-core/src/pool/inner.rs
@@ -113,13 +113,13 @@ impl<DB: Database> SharedPool<DB> {
         let mut size = self.size();
 
         while size < self.options.max_connections {
-            let new_size = self.size.compare_and_swap(size, size + 1, Ordering::AcqRel);
-
-            if new_size == size {
-                return Some(DecrementSizeGuard::new(self));
+            match self
+                .size
+                .compare_exchange(size, size + 1, Ordering::AcqRel, Ordering::Acquire)
+            {
+                Ok(_) => return Some(DecrementSizeGuard::new(self)),
+                Err(new_size) => size = new_size,
             }
-
-            size = new_size;
         }
 
         None