v-common 0.25.0

common part of the veda platform
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

//! Queue consumer runtime — see `v-module-queue`.

pub use v_module_queue::{
    get_cmd, get_inner_binobj_as_individual, get_info_of_module, init_log,
    init_log_with_filter, init_log_with_params, Module, PrepareError,
};

use crate::module::info::ModuleInfo;
use std::{thread, time};

pub fn wait_load_ontology() -> i64 {
    wait_module("input-onto", 1)
}

pub fn wait_module(module_name: &str, wait_op_id: i64) -> i64 {
    if wait_op_id < 0 {
        error!(
            "wait module [{}] to complete op_id={}",
            module_name, wait_op_id
        );
        return -1;
    }

    info!(
        "wait module [{}] to complete op_id={}",
        module_name, wait_op_id
    );
    loop {
        let module_info = ModuleInfo::new("./data", module_name, false);
        if module_info.is_err() {
            error!(
                "fail open info of [{}], err={:?}",
                module_name,
                module_info.err()
            );
            thread::sleep(time::Duration::from_millis(300));
            continue;
        }

        let mut info = module_info.unwrap();
        loop {
            if let Some((_, committed)) = info.read_info() {
                if committed >= wait_op_id {
                    info!(
                        "wait module [{}] to complete op_id={}, found commited_op_id={}",
                        module_name, wait_op_id, committed
                    );
                    return committed;
                }
            } else {
                error!("fail read info for module [{}]", module_name);
            }
            thread::sleep(time::Duration::from_millis(300));
        }
    }
}