Fix issue #1096

[asonnino]

Fix issue #1096

[asonnino]

Is there a better way to do that actually? Something like the notify_read we had in Narwhal perhaps

[huitseeker]

The notify_read is in typed_store and you should be able to use it anywhere you have a Store. But it is fundamentally an async API ..

[gdanezis]

You will need to build a notification infra like for the batches to do that. Probably, this will be necessary as new consensus items should trigger execution out of band, but we will cross that bridge when we get to it.

[huitseeker]

I think this may be what you're looking for:

use futures::future::poll_fn;
use futures::task::{Context, Poll};

fn barrier_last_seq_num(_cx: &mut Context<'_>) -> Poll<()> {
    match state.db().last_consensus_index() {
        Some(val) if val == SequenceNumber::from(1) => Poll::Ready(()),
        _ => Poll::Pending,
    }
}

let barrier= poll_fn(barrier_last_seq_num);
...
// later at point of use
barrier.await

[huitseeker]

The notify_read is in typed_store and you should be able to use it anywhere you have a Store. But it is fundamentally an async API ..

[asonnino]

I think this may be what you're looking for:

use futures::future::poll_fn;
use futures::task::{Context, Poll};

fn barrier_last_seq_num(_cx: &mut Context<'_>) -> Poll<()> {
    match state.db().last_consensus_index() {
        Some(val) if val == SequenceNumber::from(1) => Poll::Ready(()),
        _ => Poll::Pending,
    }
}

let barrier= poll_fn(barrier_last_seq_num);
...
// later at point of use
barrier.await

I tried but couldn't make it work. I keep a marker to your snipped for later (when we will need such facility for other things that testing)