I am using gstreamer 1.14.4
library to listen to a local port and dump the content to a file. I have written the code in C++.
When I am executing the pipeline, it works successfully (but not always). Randomly sometimes, the program throws
GLib-CRITICAL **: g_main_loop_quit: assertion 'g_atomic_int_get (&loop->ref_count) > 0' failed
Terminating the Gstreamer pipeline
Now, I have added try-catch
to it but I do not think it is a std::exception
.
gboolean GstRtpDepayloader::CallBackBus(GstBus *bus, GstMessage *message, gpointer my_gst_instance) {
/*******************************************************
* Recover your class instance
*******************************************************/
GstRtpDepayloader *pGstptr = (GstRtpDepayloader *) my_gst_instance;
if (pGstptr) {
/*******************************************************
* Check the message type and perform actions accordingly
*******************************************************/
switch (GST_MESSAGE_TYPE(message)) {
case GST_MESSAGE_ERROR: { //Error occured in gstreamer pipeline
GError *err;
gchar *debug;
gst_message_parse_error(message, &err, &debug);
g_print("Error: %s\n", err->message);
g_error_free(err);
g_free(debug);
pGstptr->QuitLoop(pGstptr);
break;
}
case GST_MESSAGE_EOS: { //End of stream reached
pGstptr->QuitLoop(pGstptr);
break;
}
case GST_MESSAGE_ELEMENT: { //UDPSRC throws element message upon set timeout (1sec)
//store and increment the timeout count every this block is executed
if (//timeout is thrown 5 times) {
pGstptr->QuitLoop(pGstptr);
}
break;
default: {
/* unhandled message */
break;
}
}
return (TRUE);
}
return (FALSE);
}
void GstRtpDepayloader::QuitLoop(GstRtpDepayloader *pGstptr){
/*******************************************************
* Quit the main loop
*******************************************************/
try{
g_main_loop_quit(msLoop);
}catch (exception *e) {
/*******************************************************
* Catch any standard exception type failures
*******************************************************/
cerr << "Error: " << e->what() << endl;
}
}
void GstRtpDepayloader::GstPipelineCreation() {
try {
GstBus *bus;
guint bus_watch_id;
auto msLoop = g_main_loop_new(NULL, FALSE);
if (NULL==msLoop){
throw ("Null Loop pointer received @ ");
}
GstElement *pPipeline = gst_pipeline_new("PIPELINE");
/**
* Create the pipeline elements
* udpsrc
* rtppcmudepay
* filesink
*/
/**
* Add elements in pipeline and link them
*/
/*****************************************************************
* adds a watch for new message on our pipeline's message bus to
* the default GLib main context, which is the main context that
* our GLib main loop is attached to below
*****************************************************************/
bus = gst_pipeline_get_bus(GST_PIPELINE(pPipeline));
bus_watch_id = gst_bus_add_watch(bus, CallBackBus, this);
gst_object_unref(bus);
/**********************************************************************
* Pipeline state - PLAYING
**********************************************************************/
gst_element_set_state(pPipeline, GST_STATE_PLAYING);
/**********************************************************************
* Start the loop
**********************************************************************/
g_main_loop_run(msLoop);
/**********************************************************************
* Clean up after GMainLoop ends
**********************************************************************/
gst_element_set_state(pPipeline, GST_STATE_NULL);
gst_object_unref(GST_OBJECT(pPipeline));
g_source_remove(bus_watch_id);
g_main_loop_unref(msLoop);
} catch (exception *e) {
/*******************************************************
* Catch any standard exception type failures
*******************************************************/
cerr << "Error: " << e->what() << endl;
} catch (const char *msg) {
/*******************************************************
* Catch user defined type failures
*******************************************************/
cerr << "Error: " << msg << __FUNCTION__ << __LINE__ << endl;
}
}
Any suggestions/experience on how to handle such errors?
A critical warning from GLib means that you are misusing the API in some way. It should not be caught and handled/ignored: the fix is to fix your code to not call the API incorrectly.
I can’t tell you what you’re doing wrong with the API without the full error message and a minimal working reproducer example, though.