<div dir="ltr"><div>Hi,</div><div> </div><div>I'm currently running a pipeline, which streams to twitch. After that is running, I'm adding new elements which also write to file, which don't seem to work. </div><div> </div><div>This is my code: </div><div> </div><div><div style="color:rgb(255,255,255);background-color:rgb(0,0,0);font-family:"Droid Sans Mono","monospace",monospace;font-weight:normal;font-size:14px;line-height:19px;white-space:pre"><div>void Pipeline::run(){</div> <div> if (this->isUserPipeline){</div><div> </div><div> </div><div> videoWriter = new VideoWriter(VideoWriter::VIDEO_MODE::LANDSCAPE, "/home/bageltop/Desktop/surfing_crop.flv", this->pipeline, 17);</div><div> videoWriter2 = new VideoWriter(VideoWriter::VIDEO_MODE::PORTRAIT, "/home/bageltop/Desktop/surfing_crop.flv", this->pipeline, 19);</div><div> videoWriter3 = new VideoWriter(VideoWriter::VIDEO_MODE::SQUARE, "/home/bageltop/Desktop/surfing_crop.flv", this->pipeline, 1);</div><div> }</div> <div> std::string teeName = "tee" + pipelineUsername;</div><div> this->videoTee = gst_element_factory_make("tee", teeName.c_str());</div><div> std::string inputname = "input-selector" + this->pipelineUsername;</div><div> this->inputselector = gst_element_factory_make("input-selector", inputname.c_str());</div><div> gst_bin_add_many(GST_BIN(this->pipeline),</div><div> this->videoTee,</div><div> this->inputselector,</div><div> NULL);</div> <div> for (Camera* cam: this->config->cameras){</div><div> if ((this->isUserPipeline && cam->sinkIndex == 1) || (!this->isUserPipeline && cam->sinkIndex == 2)){</div><div> GstPadTemplate *teeTempl = gst_element_class_get_pad_template (GST_ELEMENT_GET_CLASS (cam->tee), "src_%u");</div> <div> GstPad* teepad = gst_element_request_pad (cam->tee, teeTempl, NULL, NULL);</div> <div> GstPadTemplate *teeTmp = gst_element_class_get_pad_template (GST_ELEMENT_GET_CLASS (this->inputselector), "sink_%u");</div> <div> GstPad* sinkPad = gst_element_request_pad (this->inputselector, teeTmp, NULL, NULL);</div> <div> std::cout << "Link pads: " << gst_pad_link(teepad, sinkPad) << std::endl;</div><div> }</div><div> }</div> <div> gst_element_link(this->inputselector, this->videoTee);</div> <div> if (!this->isUserPipeline){</div><div> </div><div> this->loop = g_main_loop_new(NULL, FALSE);</div> <div> currentCam = this->config->cameras.at(1);</div> <div> // Start main loop</div><div> this->loop = g_main_loop_new(NULL, TRUE);</div><div> g_timeout_add(20, (GSourceFunc) doWork, this);</div> <div> // Get message bus</div><div> this->pBus = gst_pipeline_get_bus(GST_PIPELINE(this->pipeline));</div><div> // Check if message bus exists</div><div> g_assert(this->pBus);</div> <div> // Add message bus watcher</div><div> gst_bus_add_watch(this->pBus, (GstBusFunc) bus_message, this);</div> <div> gst_element_set_state(this->pipeline, GST_STATE_PLAYING);</div><div> } else {</div><div> currentCam = this->config->cameras.at(0);</div><div> }</div> <div> this->sinkName = "recordsink" + this->pipelineUsername + std::to_string(0);</div><div> this->videoName = "/home/bageltop/Desktop/video" + this->pipelineUsername + std::to_string(currentCam->sinkIndex) + ".mp4";</div><div> this->queueName = "queue" + this->pipelineUsername + std::to_string(currentCam->sinkIndex);</div><div> </div><div> if (this->isUserPipeline)</div><div> this->setCameraSource(1);</div><div> else</div><div> this->setCameraSource(2);</div><div> </div><div> if (!this->isUserPipeline){</div><div> //twitch->attachToPipeline(this->videoTee, this->pipeline);</div><div> }</div><div> </div><div> //gst_bin_add_many (GST_BIN (this->pipeline), queue, videocrop, avenc_flv, aspratio, mux, demux, avdec_h264, NULL);</div> <div> GstPadTemplate *templa = gst_element_class_get_pad_template (GST_ELEMENT_GET_CLASS (this->videoTee), "src_%u");</div> <div> // Link to file writers(next steps: Only do when user pipeline)</div><div> if (this->isUserPipeline) {</div><div> videoWriter->linkToTee(this->videoTee);</div><div> videoWriter2->linkToTee(this->videoTee);</div><div> videoWriter3->linkToTee(this->videoTee);</div> <div> }</div> <div> // Run main loop</div><div> GST_DEBUG_BIN_TO_DOT_FILE(GST_BIN(pipeline), GST_DEBUG_GRAPH_SHOW_ALL, "pipeline");</div> <div> if (!this->isUserPipeline){</div> <div> gst_element_set_state(this->pipeline, GST_STATE_PLAYING);</div><div> this->isRunning = true;</div><div> g_timeout_add_seconds (1, timeout_cb, loop);</div><div> GstPad* src = gst_element_get_static_pad (this->videoTee, "sink");</div><div> gst_pad_add_probe (src, GST_PAD_PROBE_TYPE_EVENT_DOWNSTREAM, empathy_video_src_drop_eos, NULL, NULL);</div> <div> g_main_loop_run(this->loop);</div> <div> // Stop playing pipeline</div><div> gst_element_set_state(this->pipeline, GST_STATE_NULL);</div> <div> // Free memory</div><div> gst_object_unref(this->pBus);</div><div> g_main_loop_unref(this->loop);</div><div> }</div><div>}</div> <div>void Pipeline::setCameraSource(int index){</div> <div> currentCam = this->config->getCamera(index);</div><div> GstPad *newPad = gst_element_get_static_pad(this->inputselector, "sink_0");</div> <div> std::cout << "Got new pad: " << newPad << std::endl;</div> <div> g_object_set(G_OBJECT(this->inputselector), "active-pad", newPad, NULL);</div><div> gst_object_unref(newPad);</div> <div>}</div></div></div><div> </div><div> </div><div>Can somebody help on on this?</div></div>