int _gst_build_pipeline(webrtc_s *webrtc)
{
- GstElement *rtpbin;
-
RET_VAL_IF(webrtc == NULL, WEBRTC_ERROR_INVALID_PARAMETER, "webrtc is NULL");
webrtc->gst.pipeline = gst_pipeline_new("webrtc-pipeline");
LOG_INFO("stun_server[%s]", webrtc->stun_server_url);
}
- if (!(rtpbin = gst_bin_get_by_name(GST_BIN(webrtc->gst.webrtcbin), "rtpbin"))) {
- LOG_ERROR("failed to get rtpbin");
- goto error;
- }
- g_object_set(G_OBJECT(rtpbin), "latency", webrtc->ini.general.jitterbuffer_latency, NULL);
- gst_object_unref(rtpbin);
+ g_object_set(G_OBJECT(webrtc->gst.webrtcbin), "latency", webrtc->ini.general.jitterbuffer_latency, NULL);
_connect_and_append_signal(&webrtc->signals, (GObject *)webrtc->gst.webrtcbin, "on-negotiation-needed", G_CALLBACK(__webrtcbin_on_negotiation_needed_cb), webrtc);
_connect_and_append_signal(&webrtc->signals, (GObject *)webrtc->gst.webrtcbin, "on-ice-candidate", G_CALLBACK(__webrtcbin_on_ice_candidate_cb), webrtc);