mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2024-12-25 11:30:29 +00:00
Code Issues Projects Releases Wiki Activity

threadshare/udpsink: Unconfigure all clients that are removed on clear()

Browse source 
Fixes https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/issues/101
This commit is contained in:
Sebastian Dröge 2020-04-02 19:42:00 +03:00
parent 3f05e448d7
commit 9cdf09d106
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
gst-plugin-threadshare/src/udpsink.rs
View file

@ -358,12 +358,15 @@ impl UdpSinkPadHandlerInner {
gst_pad: &gst::Pad, gst_pad: &gst::Pad,
clients_to_add: impl Iterator<Item = SocketAddr>, clients_to_add: impl Iterator<Item = SocketAddr>,
) { ) {
Arc::make_mut(&mut self.clients).clear(); let old_clients = mem::replace(&mut *Arc::make_mut(&mut self.clients), vec![]);
self.clients_to_configure = vec![]; self.clients_to_configure = vec![];
self.clients_to_unconfigure = vec![]; self.clients_to_unconfigure = vec![];
for addr in clients_to_add { for addr in clients_to_add {
if !old_clients.contains(&addr) {
self.clients_to_unconfigure.push(addr);
}
self.add_client(gst_pad, addr); self.add_client(gst_pad, addr);
} }
} }