Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-16 21:36:30 +03:00
Code Issues Packages Projects Releases Wiki Activity

context: hide ongoing process internals from public API

Browse Source 
Also hide derive_blobdir and derive_walfile.
This commit is contained in:
link2xt
2022-01-07 04:36:49 +00:00
parent 652d67a20f
commit 27eb82c556
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/context.rs
View File

@@ -84,7 +84,7 @@ pub struct InnerContext {
#[derive(Debug)] #[derive(Debug)]
pub struct RunningState { pub struct RunningState {
pub ongoing_running: bool, ongoing_running: bool,
shall_stop_ongoing: bool, shall_stop_ongoing: bool,
cancel_sender: Option<Sender<()>>, cancel_sender: Option<Sender<()>>,
} }
@@ -224,7 +224,7 @@ impl Context {
// Ongoing process allocation/free/check // Ongoing process allocation/free/check
pub async fn alloc_ongoing(&self) -> Result<Receiver<()>> { pub(crate) async fn alloc_ongoing(&self) -> Result<Receiver<()>> {
if self.has_ongoing().await { if self.has_ongoing().await {
bail!("There is already another ongoing process running."); bail!("There is already another ongoing process running.");
} }
@@ -240,7 +240,7 @@ impl Context {
Ok(receiver) Ok(receiver)
} }
pub async fn free_ongoing(&self) { pub(crate) async fn free_ongoing(&self) {
let s_a = &self.running_state; let s_a = &self.running_state;
let mut s = s_a.write().await; let mut s = s_a.write().await;
@@ -249,7 +249,7 @@ impl Context {
s.cancel_sender.take(); s.cancel_sender.take();
} }
pub async fn has_ongoing(&self) -> bool { pub(crate) async fn has_ongoing(&self) -> bool {
let s_a = &self.running_state; let s_a = &self.running_state;
let s = s_a.read().await; let s = s_a.read().await;
@@ -274,7 +274,7 @@ impl Context {
}; };
} }
pub async fn shall_stop_ongoing(&self) -> bool { pub(crate) async fn shall_stop_ongoing(&self) -> bool {
self.running_state.read().await.shall_stop_ongoing self.running_state.read().await.shall_stop_ongoing
} }
@@ -574,14 +574,14 @@ impl Context {
Ok(spam.as_deref() == Some(folder_name)) Ok(spam.as_deref() == Some(folder_name))
} }
pub fn derive_blobdir(dbfile: &PathBuf) -> PathBuf { pub(crate) fn derive_blobdir(dbfile: &PathBuf) -> PathBuf {
let mut blob_fname = OsString::new(); let mut blob_fname = OsString::new();
blob_fname.push(dbfile.file_name().unwrap_or_default()); blob_fname.push(dbfile.file_name().unwrap_or_default());
blob_fname.push("-blobs"); blob_fname.push("-blobs");
dbfile.with_file_name(blob_fname) dbfile.with_file_name(blob_fname)
} }
pub fn derive_walfile(dbfile: &PathBuf) -> PathBuf { pub(crate) fn derive_walfile(dbfile: &PathBuf) -> PathBuf {
let mut wal_fname = OsString::new(); let mut wal_fname = OsString::new();
wal_fname.push(dbfile.file_name().unwrap_or_default()); wal_fname.push(dbfile.file_name().unwrap_or_default());
wal_fname.push("-wal"); wal_fname.push("-wal");