undo regression
@@ -6,7 +6,6 @@ use rand::{Rng, SeedableRng, StdRng};
use timely::dataflow::*;
use timely::dataflow::operators::probe::Handle;
-use timely::dataflow::operators::capture::EventWriter;
use differential_dataflow::input::Input;
use differential_dataflow::Collection;
@@ -24,28 +23,8 @@ fn main() {
let rounds: u32 = std::env::args().nth(4).unwrap().parse().unwrap();
let inspect: bool = std::env::args().nth(5).unwrap() == "inspect";
- use timely::logging::{LoggerConfig, EventPusherTee};
- let logger_config = LoggerConfig::new(
- |setup| {
- use std::net::TcpStream;
- let addr = format!("127.0.0.1:{}", 8000 + setup.index);
- let send = TcpStream::connect(addr).unwrap();
- EventWriter::new(send)
- },
- |_setup| {
- // No support for communication threads in this example.
- unimplemented!();
- use std::net::TcpStream;
- let addr = format!("127.0.0.1:{}", 8001);
- let send = TcpStream::connect(addr).unwrap();
- EventWriter::new(send)
- }
- );
-
- timely::execute_from_args_logging(std::env::args().skip(6), logger_config, move |worker| {
-
- // // define a new computational scope, in which to run BFS
- // timely::execute_from_args(std::env::args(), move |worker| {
+ // define a new computational scope, in which to run BFS
+ timely::execute_from_args(std::env::args(), move |worker| {
let timer = ::std::time::Instant::now();
