diff options
author | David Sherret <dsherret@users.noreply.github.com> | 2021-07-06 23:48:01 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-07-06 23:48:01 -0400 |
commit | 7fc0e8ec8cd4b18ba10a04cf0ac2bee48826de3d (patch) | |
tree | 70e078538ae0f3467e8a519b918ae936587ce2d4 /extensions/web/blob.rs | |
parent | 78ac19f51f48984ea16f97a0c574fa507544b8d5 (diff) |
chore: use parking_lot for synchronization primitives to align with tokio (#11289)
parking_lot is already transitively used in tokio via the "full" cargo feature
Diffstat (limited to 'extensions/web/blob.rs')
-rw-r--r-- | extensions/web/blob.rs | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/extensions/web/blob.rs b/extensions/web/blob.rs index 96a982677..bd5284317 100644 --- a/extensions/web/blob.rs +++ b/extensions/web/blob.rs @@ -1,5 +1,6 @@ use async_trait::async_trait; use deno_core::error::type_error; +use deno_core::parking_lot::Mutex; use deno_core::url::Url; use deno_core::ZeroCopyBuf; use serde::Deserialize; @@ -8,7 +9,6 @@ use std::collections::HashMap; use std::fmt::Debug; use std::rc::Rc; use std::sync::Arc; -use std::sync::Mutex; use deno_core::error::AnyError; use uuid::Uuid; @@ -26,7 +26,7 @@ pub struct BlobStore { impl BlobStore { pub fn insert_part(&self, part: Box<dyn BlobPart + Send + Sync>) -> Uuid { let id = Uuid::new_v4(); - let mut parts = self.parts.lock().unwrap(); + let mut parts = self.parts.lock(); parts.insert(id, Arc::new(part)); id } @@ -35,7 +35,7 @@ impl BlobStore { &self, id: &Uuid, ) -> Option<Arc<Box<dyn BlobPart + Send + Sync>>> { - let parts = self.parts.lock().unwrap(); + let parts = self.parts.lock(); let part = parts.get(&id); part.cloned() } @@ -44,7 +44,7 @@ impl BlobStore { &self, id: &Uuid, ) -> Option<Arc<Box<dyn BlobPart + Send + Sync>>> { - let mut parts = self.parts.lock().unwrap(); + let mut parts = self.parts.lock(); parts.remove(&id) } @@ -52,7 +52,7 @@ impl BlobStore { &self, mut url: Url, ) -> Result<Option<Arc<Blob>>, AnyError> { - let blob_store = self.object_urls.lock().unwrap(); + let blob_store = self.object_urls.lock(); url.set_fragment(None); Ok(blob_store.get(&url).cloned()) } @@ -70,14 +70,14 @@ impl BlobStore { let id = Uuid::new_v4(); let url = Url::parse(&format!("blob:{}/{}", origin, id)).unwrap(); - let mut blob_store = self.object_urls.lock().unwrap(); + let mut blob_store = self.object_urls.lock(); blob_store.insert(url.clone(), Arc::new(blob)); url } pub fn remove_object_url(&self, url: &Url) { - let mut blob_store = self.object_urls.lock().unwrap(); + let mut blob_store = self.object_urls.lock(); blob_store.remove(&url); } } |