mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2025-01-01 14:58:42 +00:00
Code Issues Projects Releases Wiki Activity

threadshare: fix race condition in tcpclientsrc test

Browse source
This commit is contained in:
François Laignel 2020-04-28 20:29:14 +02:00
parent ee71a4ab8a
commit c414f78248
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
generic/threadshare/tests/tcpclientsrc.rs
View file

@ -20,6 +20,7 @@ use glib::prelude::*;
use gst::prelude::*; use gst::prelude::*;
use std::io::Write; use std::io::Write;
use std::sync::mpsc;
use std::sync::{Arc, Mutex}; use std::sync::{Arc, Mutex};
use std::{thread, time}; use std::{thread, time};
@ -37,10 +38,12 @@ fn init() {
fn test_push() { fn test_push() {
init(); init();
let (listening_tx, listening_rx) = mpsc::channel();
let handler = thread::spawn(move || { let handler = thread::spawn(move || {
use std::net; use std::net;
let listener = net::TcpListener::bind("0.0.0.0:5000").unwrap(); let listener = net::TcpListener::bind("0.0.0.0:5000").unwrap();
listening_tx.send(()).unwrap();
let stream = listener.incoming().next().unwrap(); let stream = listener.incoming().next().unwrap();
let buffer = [0; 160]; let buffer = [0; 160];
let mut socket = stream.unwrap(); let mut socket = stream.unwrap();
@ -84,6 +87,8 @@ fn test_push() {
Ok(gst::FlowSuccess::Ok) Ok(gst::FlowSuccess::Ok)
}); });
// Wait for the server to listen
listening_rx.recv().unwrap();
pipeline.set_state(gst::State::Playing).unwrap(); pipeline.set_state(gst::State::Playing).unwrap();
let mut eos = false; let mut eos = false;
@ -95,7 +100,7 @@ fn test_push() {
eos = true; eos = true;
break; break;
} }
MessageView::Error(..) => unreachable!(), MessageView::Error(err) => panic!("{:?}", err),
_ => (), _ => (),
} }
} }