let [_, p0] = c.new_udp_mediator_component(sock_addrs[0], sock_addrs[1]).unwrap();

    c.connect(SEC1).unwrap();

    c.get(p0).unwrap();

    c.sync(MS300).unwrap_err();

}

#[test]

fn reowolf_to_udp() {

    let test_log_path = Path::new("./logs/reowolf_to_udp");

    let sock_addrs = [next_test_addr(), next_test_addr()];

    let barrier = std::sync::Barrier::new(2);

    scope(|s| {

            barrier.wait();

        });

    })

    .unwrap();

}

#[test]

fn udp_to_reowolf() {

    let test_log_path = Path::new("./logs/udp_to_reowolf");

    let sock_addrs = [next_test_addr(), next_test_addr()];

    let barrier = std::sync::Barrier::new(2);

    scope(|s| {