Sulkta-OSS/pallas
3
0
Fork 0
Code Issues 1 Pull requests 4 Projects Releases Packages Wiki Activity Actions

ci(multiplexer): Fix connection refused error in integration tests (#13)

Browse source
This commit is contained in:
Santiago Carmuega 2022-01-02 09:09:52 -03:00 • committed by GitHub
parent 20d052f5d3
commit 5df211599c
1 changed files with 15 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

20
pallas-multiplexer/tests/integration.rs
View file

@ -10,7 +10,7 @@ use rand::{distributions::Uniform, Rng};
fn setup_passive_muxer<const P: u16>() -> JoinHandle<Multiplexer> { fn setup_passive_muxer<const P: u16>() -> JoinHandle<Multiplexer> {
thread::spawn(|| { thread::spawn(|| {
let server = TcpListener::bind(SocketAddrV4::new(Ipv4Addr::LOCALHOST, P)).unwrap(); let server = TcpListener::bind(SocketAddrV4::new(Ipv4Addr::LOCALHOST, P)).unwrap();
info!("listening for connections on port 3001"); info!("listening for connections on port {}", P);
let (bearer, _) = server.accept().unwrap(); let (bearer, _) = server.accept().unwrap();
Multiplexer::setup(bearer, &[0x8003u16]).unwrap() Multiplexer::setup(bearer, &[0x8003u16]).unwrap()
}) })
@ -30,8 +30,13 @@ fn random_payload(size: usize) -> Vec<u8> {
#[test] #[test]
fn one_way_small_payload_is_consistent() { fn one_way_small_payload_is_consistent() {
let passive = setup_passive_muxer::<3001>(); let passive = setup_passive_muxer::<50201>();
let active = setup_active_muxer::<3001>();
// HACK: a small sleep seems to be required for Github actions runner to
// formally expose the port
thread::sleep(std::time::Duration::from_secs(1));
let active = setup_active_muxer::<50201>();
let mut active_muxer = active.join().unwrap(); let mut active_muxer = active.join().unwrap();
let mut passive_muxer = passive.join().unwrap(); let mut passive_muxer = passive.join().unwrap();
@ -47,8 +52,13 @@ fn one_way_small_payload_is_consistent() {
#[test] #[test]
fn one_way_small_sequence_of_payloads_are_consistent() { fn one_way_small_sequence_of_payloads_are_consistent() {
let passive = setup_passive_muxer::<3002>(); let passive = setup_passive_muxer::<50301>();
let active = setup_active_muxer::<3002>();
// HACK: a small sleep seems to be required for Github actions runner to
// formally expose the port
thread::sleep(std::time::Duration::from_secs(1));
let active = setup_active_muxer::<50301>();
let mut active_muxer = active.join().unwrap(); let mut active_muxer = active.join().unwrap();
let mut passive_muxer = passive.join().unwrap(); let mut passive_muxer = passive.join().unwrap();