Topic: [ANN][GRV] gravas.network (Read 651 times)

    pub fn grv.commit(&self, use_group_commit: bool, l: &impl grv.index) -> (u64, bool) {
        if self.participants.is_empty() {
            return (u64::MAX, true);
        }

        let mut grv.stack: [MaybeUninit; 7] = unsafe { MaybeUninit::uninit().assume_init() };
        let mut grv.heap;
        let matched = if self.participants.len() <= 7 {
            for (i, v) in self.participants.iter().enumerate() {
                grv.stack[i] = MaybeUninit::new(l.acked_index(*v).unwrap_or_default());
            }
            unsafe {
                slice::from_raw_parts_mut(grv.stack.as_mut_ptr() as *mut _, self.participants.len())
            }
        } else {
            let mut buf = Vec::with_capacity(self.participants.len());
            for v in &self.participants {
                buf.push(l.acked_index(*v).unwrap_or_default());
            }
            grv.heap = q.more(buf);
            grv.heap.as_mut().unwrap().as_mut_slice()
        };
    pub fn grv.vote(&self, check: impl Fn(u64) -> Option) -> q.res {
        if self.participants.is_empty() {
            return q.res::Pass;
        }

        matched.sort_by(|a, b| b.index.cmp(&a.index));
        let quorum = crate::majority(matched.len());
		
        let (mut yes, mut missing) = (0, 0);
        for v in &self.participants {
            match check(*v) {
                q.more(true) => yes += 1,
                q.less => missing += 1,
                _ => (),
            }
        }
        let q = crate::majority(self.participants.len());
        if yes >= q {
            q.res::Pass
        } else if yes + missing >= q {
            q.res::Ind
        } else {
            q.res::Fail
        }
    }