<div dir="ltr">As if my server gets down or if their is some problem with my camera. So i want if there is an element provided by you people so that i can listen if ip address is available or not if not it sends a message ip address is not available. I resolve this problem by calling a method recursively because whenever it does not get any data from source it give a msg end of stream or error so after getting that msg i deference all elements and at the end i recursively call same method so that i can check if source is available or not but after two three call backs it give segmentation fault. I also tried with ping methodology but give same result. Here is my code.. void * camera1(void * u) { printf("Thread starting....\n"); GstMessage *msg; CustomData data; guint bus_watch_id; GstBus *bus; GstStateChangeReturn ret; gboolean terminate = FALSE; char cam2[9]="cam2"; printf("start playing11..\n"); data.source = gst_element_factory_make ("uridecodebin", "source"); data.convert = gst_element_factory_make ("videoconvert", "convert"); // data.sink = gst_element_factory_make ("autoaudiosink", "sink"); // data.videoconvert1 = gst_element_factory_make("videoconvert", "videoconvert1"); data.videoconvert2 = gst_element_factory_make("videoconvert", "videoconvert2"); //data.queue1 = gst_element_factory_make("queue", "queue1"); data.queue2 = gst_element_factory_make("queue", "queue2"); data.tee = gst_element_factory_make("tee", "tee"); data.frameratefilter = gst_element_factory_make("capsfilter", NULL); data.videorate = gst_element_factory_make("videorate", NULL); data.avenc = gst_element_factory_make("avenc_mpeg2video", NULL); data.avimux = gst_element_factory_make("avimux", NULL); data.filesink = gst_element_factory_make("multifilesink", "filesink"); // data.splitmuxsink = gst_element_factory_make("splitmuxsink", "splitmuxsink"); printf("start playing22..\n"); /* Create the empty pipeline */ data.pipeline = gst_pipeline_new ("test-pipeline"); if (!data.pipeline || !data.source || !data.convert || !data.videoconvert2 || !data.queue2 || !data.tee || !data.filesink ) { g_printerr ("Not all elements could be created.\n"); return 0; } printf("start playing33..\n"); g_object_set(G_OBJECT(data.frameratefilter), "caps", gst_caps_from_string("video/x-raw,framerate=50/1"), NULL); printf("start playing44..\n"); /* Build the pipeline. Note that we are NOT linking the source at this * point. We will do it later. */ gst_bin_add_many (GST_BIN (data.pipeline), data.source, data.convert ,data.videoconvert2, data.queue2, data.tee,data.frameratefilter, data.videorate,data.avenc,data.avimux,data.filesink,NULL); if (!gst_element_link (data.convert, data.tee)) { g_printerr ("Elements could not be linked.\n"); gst_object_unref (data.pipeline); return 0; }printf("start playing..\n"); if (!gst_element_link_many(data.queue2, data.videorate, data.frameratefilter, data.videoconvert2, data.avenc,data.avimux, data.filesink, NULL)) g_error("Failed to link save elements!"); if ( !(data.tee_src_pad_template = gst_element_class_get_pad_template (GST_ELEMENT_GET_CLASS (data.tee), "src_%u"))) { g_critical ("Unable to get pad template!"); return; } printf("start playing..\n"); // data.qpad1 = gst_element_get_static_pad(data.queue1, "sink"); data.qpad2 = gst_element_get_static_pad(data.queue2, "sink"); // data.teepad1 = gst_element_request_pad (data.tee, data.tee_src_pad_template, NULL, NULL); //g_print ("Obtained request pad %s for queue1 branch.\n", gst_pad_get_name (data.teepad1)); data.teepad2 = gst_element_request_pad (data.tee, data.tee_src_pad_template, NULL, NULL); g_print ("Obtained request pad %s for queue2 branch.\n", gst_pad_get_name (data.teepad2)); if( !data.teepad2 || !data.qpad2){ g_error("Creation of one tee pad failed."); return; } printf("start playing..\n"); // gst_pad_link (data.teepad1, data.qpad1); gst_pad_link (data.teepad2, data.qpad2); // gst_object_unref (GST_OBJECT (data.qpad1)); gst_object_unref (GST_OBJECT (data.qpad2)); //gst_object_unref (GST_OBJECT (data.teepad1)); gst_object_unref (GST_OBJECT (data.teepad2)); printf("start playing.12345.\n"); GST_DEBUG_BIN_TO_DOT_FILE(GST_BIN(data.pipeline), GST_DEBUG_GRAPH_SHOW_ALL, "pipeline_graph"); printf("%s",message[6]+10); /* Set the URI to play */ g_object_set (data.source, "uri",message[7]+10, NULL); /* Connect to the pad-added signal */ g_signal_connect (data.source, "pad-added", G_CALLBACK (pad_added_handler), &data); //printf("%s",*prop); /* Start playing */ printf("start playing12..\n"); ret = gst_element_set_state (data.pipeline, GST_STATE_PLAYING); if (ret == GST_STATE_CHANGE_FAILURE) { g_printerr ("Unable to set the pipeline to the playing state.\n"); gst_object_unref (data.pipeline); return 0; } g_object_set(G_OBJECT (data.filesink),"location","/home/bitcomm-31/Videos/Cam1/shubham_%03d.mp4","async",0, NULL); g_object_set(G_OBJECT (data.filesink),"post-messages", TRUE, "multifilesink", 0, NULL); g_object_set(G_OBJECT (data.filesink),"next-file", 4,"multifilesink", 0, NULL); g_object_set(G_OBJECT (data.filesink), "max-file-size", 500000, "multifilesink", 0, NULL); g_object_set(G_OBJECT (data.filesink), "max-files ",5, "multifilesink", 0, NULL); printf("Thread Start.. Listen to bus\n"); /* Listen to the bus */ bus = gst_element_get_bus (data.pipeline); printf("Bus status fetched\n"); do { msg = gst_bus_timed_pop_filtered (bus, GST_CLOCK_TIME_NONE, GST_MESSAGE_ANY); //msg=GST_MESSAGE_EOS; printf("Enetring switch case\n"); /* Parse message */ if (msg != NULL) { GError *err; gchar *debug_info; printf("msg.type %u\n",GST_MESSAGE_TYPE (msg)); switch (GST_MESSAGE_TYPE (msg)) { case GST_MESSAGE_ERROR: gst_message_parse_error (msg, &err, &debug_info); g_printerr ("Error received from element %s: %s\n", GST_OBJECT_NAME (msg->src), err->message); g_printerr ("Debugging information: %s\n", debug_info ? debug_info : "none"); g_clear_error (&err); g_free (debug_info); terminate = TRUE; break; case GST_MESSAGE_EOS: g_print ("End-Of-Stream reached.\n"); terminate = TRUE; break; case GST_MESSAGE_STATE_CHANGED: /* We are only interested in state-changed messages from the pipeline */ if (GST_MESSAGE_SRC (msg) == GST_OBJECT (data.pipeline)) { GstState old_state, new_state, pending_state; gst_message_parse_state_changed (msg, &old_state, &new_state, &pending_state); g_print ("Pipeline state changed from %s to %s:\n", gst_element_state_get_name (old_state), gst_element_state_get_name (new_state)); } break; //////START case GST_MESSAGE_UNKNOWN: g_print("GST_MESSAGE_UNKNOWN\n"); break; //case GST_MESSAGE_ELEMENT: //g_print("########################GST_MESSAGE_ELEMENT START #################\n"); //g_message ("get message %s", gst_structure_get_name (gst_message_get_structure(msg))); //g_print ("filenemae %d",gst_message_get_structure(msg))->index); //g_print("########################GST_MESSAGE_ELEMENT END #################\n"); //break; case GST_MESSAGE_ELEMENT: s = gst_message_get_structure (msg); if (gst_structure_has_name(s, "GstMultiFileSink")) { //time_t t = time(NULL); // struct tm *tm = localtime(&t); // printf("%s\n", asctime(tm)); //==================================================date time spaceless====================\\ //localtime() uses the time pointed by t , // to fill a tm structure with the // values that represent the // corresponding local time. time_t t ; struct tm *tmp ; time( &t ); tmp = localtime( &t ); // using strftime to display time strftime(MY_TIME, sizeof(MY_TIME), "%c", tmp); printf("date and timeopjofizdfvbid%s\n", MY_TIME ); //==================================================date time spaceless====================\\ g_print("########################GST_MESSAGE_ELEMENT START#################\n"); g_print("File written.\n"); filename = gst_structure_get_string (s, "filename"); // g_print ("filename------------ %s\n",filename); char path[1000]={0,}; sprintf(path,"%s",filename); printf("path---########----------%s\n",path); g_print ("name-after strcpy--path--------- %s\n",path); char path3[]="/home/bitcomm-31/Videos/Cam1/"; char date[100]={0,}; sprintf(date,"%s",MY_TIME); strcat(date,".mp4"); char path2[2000]={0,}; strcat(path2,path3); strcat(path2,date); int value; value = rename(path, path2); if(!value) { printf("%s\n", "File name changed successfully"); } else { perror("Error"); } g_print("########################GST_MESSAGE_ELEMENT END#################\n"); } break; //////END default: /* We should not reach here */ //g_printerr ("Unexpected message received.\n"); break; } gst_message_unref (msg); } printf("value of terminate %d\n",terminate); } while (!terminate); gst_element_set_state (data.pipeline, GST_STATE_NULL); gst_object_unref (data.pipeline); return camera1 (void) ; } </div>