chatmail-core/src/dc_jobthread.rs

use std::sync::{Arc, Condvar, Mutex};

use crate::context::Context;
use crate::dc_configure::*;
use crate::imap::Imap;
use crate::x::*;

#[repr(C)]
pub struct dc_jobthread_t {
    pub name: &'static str,
    pub folder_config_name: &'static str,
    pub imap: Imap,
    pub state: Arc<(Mutex<JobState>, Condvar)>,
}

pub fn dc_jobthread_init(
    name: &'static str,
    folder_config_name: &'static str,
    imap: Imap,
) -> dc_jobthread_t {
    dc_jobthread_t {
        name,
        folder_config_name,
        imap,
        state: Arc::new((Mutex::new(Default::default()), Condvar::new())),
    }
}

#[derive(Debug, Default)]
pub struct JobState {
    idle: bool,
    jobs_needed: i32,
    suspended: i32,
    using_handle: i32,
}

pub unsafe fn dc_jobthread_suspend(
    context: &Context,
    jobthread: &dc_jobthread_t,
    suspend: libc::c_int,
) {
    if 0 != suspend {
        info!(context, 0, "Suspending {}-thread.", jobthread.name,);
        {
            jobthread.state.0.lock().unwrap().suspended = 1;
        }
        dc_jobthread_interrupt_idle(context, jobthread);
        loop {
            let using_handle = jobthread.state.0.lock().unwrap().using_handle;
            if using_handle == 0 {
                return;
            }
            std::thread::sleep(std::time::Duration::from_micros(300 * 1000));
        }
    } else {
        info!(context, 0, "Unsuspending {}-thread.", jobthread.name);

        let &(ref lock, ref cvar) = &*jobthread.state.clone();
        let mut state = lock.lock().unwrap();

        state.suspended = 0;
        state.idle = true;
        cvar.notify_one();
    }
}

pub unsafe fn dc_jobthread_interrupt_idle(context: &Context, jobthread: &dc_jobthread_t) {
    {
        jobthread.state.0.lock().unwrap().jobs_needed = 1;
    }

    info!(context, 0, "Interrupting {}-IDLE...", jobthread.name);

    jobthread.imap.interrupt_idle();

    let &(ref lock, ref cvar) = &*jobthread.state.clone();
    let mut state = lock.lock().unwrap();

    state.idle = true;
    cvar.notify_one();
}

pub unsafe fn dc_jobthread_fetch(
    context: &Context,
    jobthread: &mut dc_jobthread_t,
    use_network: libc::c_int,
) {
    let start;

    {
        let &(ref lock, _) = &*jobthread.state.clone();
        let mut state = lock.lock().unwrap();

        if 0 != state.suspended {
            return;
        }

        state.using_handle = 1;
    }

    if 0 != use_network {
        start = clock();
        if !(0 == connect_to_imap(context, jobthread)) {
            info!(context, 0, "{}-fetch started...", jobthread.name);
            jobthread.imap.fetch(context);

            if jobthread.imap.should_reconnect() {
                info!(
                    context,
                    0, "{}-fetch aborted, starting over...", jobthread.name,
                );
                jobthread.imap.fetch(context);
            }
            info!(
                context,
                0,
                "{}-fetch done in {:.3} ms.",
                jobthread.name,
                clock().wrapping_sub(start) as f64 / 1000.0,
            );
        }
    }

    jobthread.state.0.lock().unwrap().using_handle = 0;
}

/* ******************************************************************************
 * the typical fetch, idle, interrupt-idle
 ******************************************************************************/

unsafe fn connect_to_imap(context: &Context, jobthread: &dc_jobthread_t) -> libc::c_int {
    if jobthread.imap.is_connected() {
        return 1;
    }

    let mut ret_connected = dc_connect_to_configured_imap(context, &jobthread.imap);

    if !(0 == ret_connected) {
        if context
            .sql
            .get_config_int(context, "folders_configured")
            .unwrap_or_default()
            < 3
        {
            jobthread.imap.configure_folders(context, 0x1);
        }

        if let Some(mvbox_name) = context
            .sql
            .get_config(context, jobthread.folder_config_name)
        {
            jobthread.imap.set_watch_folder(mvbox_name);
        } else {
            jobthread.imap.disconnect(context);
            ret_connected = 0;
        }
    }

    ret_connected
}

pub unsafe fn dc_jobthread_idle(
    context: &Context,
    jobthread: &dc_jobthread_t,
    use_network: libc::c_int,
) {
    {
        let &(ref lock, ref cvar) = &*jobthread.state.clone();
        let mut state = lock.lock().unwrap();

        if 0 != state.jobs_needed {
            info!(
                context,
                0,
                "{}-IDLE will not be started as it was interrupted while not ideling.",
                jobthread.name,
            );
            state.jobs_needed = 0;
            return;
        }

        if 0 != state.suspended {
            while !state.idle {
                state = cvar.wait(state).unwrap();
            }
            state.idle = false;
            return;
        }

        state.using_handle = 1;

        if 0 == use_network {
            state.using_handle = 0;

            while !state.idle {
                state = cvar.wait(state).unwrap();
            }
            state.idle = false;
            return;
        }
    }

    connect_to_imap(context, jobthread);
    info!(context, 0, "{}-IDLE started...", jobthread.name,);
    jobthread.imap.idle(context);
    info!(context, 0, "{}-IDLE ended.", jobthread.name);

    jobthread.state.0.lock().unwrap().using_handle = 0;
}