cbsk_socket 2.1.2

cbsk_socket is a socket callback tool
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
57
58
59
60
61
62
63
64
65
66
67

use cbsk_base::fastdate::DateTime;

/// TCP time control related trait
pub trait TimeTrait {
    /// set the last time the data was received for tcp
    fn set_recv_time(&self, time: i64);

    /// get the last time the data was received for tcp
    fn get_recv_time(&self) -> i64;

    /// set tcp last read timeout
    fn set_timeout_time(&self, time: i64);

    /// get tcp last read timeout
    fn get_timeout_time(&self) -> i64;

    /// set is wait callback
    fn set_wait_callback(&self, is_wait: bool);

    /// get is wait callback
    fn get_wait_callback(&self) -> bool;

    /// set ignore once time check
    fn set_ignore_once(&self, is_ignore: bool) {
        // default do nothing
        let _ = is_ignore;
    }

    /// get ignore
    fn get_ignore(&self) -> bool {
        // default is false
        false
    }

    /// set recv time and timeout time to now
    fn set_now(&self) {
        self.set_recv_time_now();
        self.set_timeout_time_now();
    }

    /// set recv time to now
    fn set_recv_time_now(&self) {
        self.set_recv_time(Self::now());
    }

    /// set timeout time to now
    fn set_timeout_time_now(&self) {
        self.set_timeout_time(Self::now())
    }

    /// get now unix_timestamp_millis
    fn now() -> i64 {
        DateTime::now().unix_timestamp_millis()
    }

    /// need wait callback finish business logic
    fn wait_callback(&self) {
        self.set_wait_callback(true);
    }

    /// callback the business logic has been completed
    fn finish_callback(&self) {
        // if finish callback, default timeout is now
        self.set_timeout_time_now();
        self.set_wait_callback(false);
    }
}