pub fn run(
    timely_configuration: timely::Configuration,
    replay_source: ReplaySource) -> Result<(), STError> {

    timely::execute(timely_configuration, move |worker| {
        let index = worker.index();

        // read replayers from file (offline) or TCP stream (online)
        let readers = connect::make_readers(replay_source.clone(), worker.index(), worker.peers()).expect("couldn't create readers");

        let probe: ProbeHandle<Pair<u64, Duration>> = worker.dataflow(|scope| {
            // use timely::dataflow::operators::inspect::Inspect;
            // use timely_adapter::replay_throttled::ReplayThrottled;
            // use timely_adapter::ConstructLRs;
            // readers
            //     .replay_throttled_into(index, scope, None, throttle)
            //     .peel_ops(index)
            //     .inspect(|x| println!("{:?}", x))
            //     .probe()

            pag::create_pag(scope, readers, index, 1)
                // .bench(index)
                .probe()
        });

        while !probe.done() { worker.step_or_park(None); };

        info!("w{} done", index);

        // stall application
        // use std::io::stdin;
        // stdin().read_line(&mut String::new()).unwrap();
    })
        .map_err(|x| STError(format!("error in the timely computation: {}", x)))?;

    Ok(())
}
/// Inspects a running SnailTrail computation, e.g. for benchmarking of SnailTrail itself.
Inspects a running SnailTrail computation, e.g. for benchmarking of SnailTrail itself.
Inspects a running SnailTrail computation e . g . for benchmarking of SnailTrail itself .
pub fn run(
    timely_configuration: timely::Configuration,
    replay_source: ReplaySource) -> Result<(), STError> {
    timely::execute(timely_configuration, move |worker| {
        let index = worker.index();
        // read replayers from file (offline) or TCP stream (online)
        let readers = connect::make_readers(replay_source.clone(), worker.index(), worker.peers()).expect("couldn't create readers");
        let probe: ProbeHandle<Pair<u64, Duration>> = worker.dataflow(|scope| {
            // use timely::dataflow::operators::inspect::Inspect;
            // use timely_adapter::replay_throttled::ReplayThrottled;
            // use timely_adapter::ConstructLRs;
            // readers
            //     .replay_throttled_into(index, scope, None, throttle)
            //     .peel_ops(index)
            //     .inspect(|x| println!("{:?}", x))
            //     .probe()
            pag::create_pag(scope, readers, index, 1)
                // .bench(index)
                .probe()
        });
        while !probe.done() { worker.step_or_park(None); };
        info!("w{} done", index);
        // stall application
        // use std::io::stdin;
        // stdin().read_line(&mut String::new()).unwrap();
    })
        .map_err(|x| STError(format!("error in the timely computation: {}", x)))?;
    Ok(())
}
pub fn run ( timely_configuration : timely :: Configuration , replay_source : ReplaySource ) -> Result < ( ) , STError > { timely :: execute ( timely_configuration , move | worker | { let index = worker . index ( ) ; // read replayers from file (offline) or TCP stream (online) let readers = connect :: make_readers ( replay_source . clone ( ) , worker . index ( ) , worker . peers ( ) ) . expect ( " " ) ; let probe : ProbeHandle < Pair < u64 , Duration > > = worker . dataflow ( | scope | { // use timely::dataflow::operators::inspect::Inspect; // use timely_adapter::replay_throttled::ReplayThrottled; // use timely_adapter::ConstructLRs; // readers //     .replay_throttled_into(index, scope, None, throttle) //     .peel_ops(index) //     .inspect(|x| println!("{:?}", x)) //     .probe() pag :: create_pag ( scope , readers , index , 1 ) // .bench(index) . probe ( ) } ) ; while ! probe . done ( ) { worker . step_or_park ( None ) ; } ; info ! ( " " index ) ; // stall application // use std::io::stdin; // stdin().read_line(&mut String::new()).unwrap(); } ) . map_err ( | x | STError ( format ! ( " " x ) ) ) ? ; Ok ( ( ) ) }
Inspects a running SnailTrail computation, e.g.
Inspects a running SnailTrail computation e . g .
timely_configuration
timely::Configuration
replay_source
ReplaySource
timely_configuration
timely::Configuration
replay_source
ReplaySource