picologger 0.9.1

Logger for HPC
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use std::sync::atomic::{AtomicU64, Ordering};

static SEQUENCE_ID: AtomicU64 = AtomicU64::new(0);
static ACK_NUMBER: AtomicU64 = AtomicU64::new(0);
static PAGE_ID: AtomicU64 = AtomicU64::new(0);

pub fn next_seq_id() -> u64 {
    SEQUENCE_ID.fetch_add(1, Ordering::Relaxed)
}


pub fn get_ack_number() -> u64 {
    ACK_NUMBER.load(Ordering::Acquire)
}

pub fn set_ack_number(val: u64) {
    ACK_NUMBER.fetch_max(val, Ordering::Release);
}

pub fn next_page_id() -> u64 {
    PAGE_ID.fetch_add(1, Ordering::Relaxed)
}