gst_element_set_state (test->aggregator, GST_STATE_NULL);
gst_object_unref (test->aggregator);
+ if (test->sinkpad)
+ gst_object_unref (test->sinkpad);
+
g_main_loop_unref (test->ml);
}
g_thread_join (thread1);
g_thread_join (thread2);
+ _chain_data_clear (&data1);
+ _chain_data_clear (&data2);
_test_data_clear (&test);
}
gst_pad_unlink (pad, peer);
gst_element_release_request_pad (data->agg, peer);
fail_unless (gst_bin_remove (GST_BIN (data->pipeline), data->src));
+ gst_object_unref (peer);
g_mutex_lock (data->lock);
g_cond_broadcast (data->cond);
gst_element_state_get_name (GST_STATE (data.src)));
g_cond_wait (&cond, &lock);
g_mutex_unlock (&lock);
+ gst_object_unref (pad);
/* We can not set state from the streaming thread so we
* need to make sure that the source has been removed
gst_element_set_state (pipeline, GST_STATE_NULL);
gst_object_unref (bus);
gst_object_unref (pipeline);
+ g_mutex_clear (&lock);
+ g_cond_clear (&cond);
}
GST_END_TEST;