Lines Matching refs:avtpcrfbase
75 static void crf_listener_thread_func (GstAvtpCrfBase * avtpcrfbase);
120 gst_avtp_crf_base_init (GstAvtpCrfBase * avtpcrfbase) in gst_avtp_crf_base_init() argument
122 avtpcrfbase->streamid = DEFAULT_STREAMID; in gst_avtp_crf_base_init()
123 avtpcrfbase->ifname = g_strdup (DEFAULT_IFNAME); in gst_avtp_crf_base_init()
124 avtpcrfbase->address = g_strdup (DEFAULT_ADDRESS); in gst_avtp_crf_base_init()
130 GstAvtpCrfBase *avtpcrfbase = GST_AVTP_CRF_BASE (element); in gst_avtp_crf_base_change_state() local
131 GstAvtpCrfThreadData *thread_data = &avtpcrfbase->thread_data; in gst_avtp_crf_base_change_state()
135 GST_DEBUG_OBJECT (avtpcrfbase, "transition %d", transition); in gst_avtp_crf_base_change_state()
146 (GThreadFunc) crf_listener_thread_func, avtpcrfbase, &error); in gst_avtp_crf_base_change_state()
149 GST_ERROR_OBJECT (avtpcrfbase, "failed to start thread, %s", in gst_avtp_crf_base_change_state()
176 setup_socket (GstAvtpCrfBase * avtpcrfbase) in setup_socket() argument
186 GST_ERROR_OBJECT (avtpcrfbase, "Failed to open socket: %s", in setup_socket()
191 ifindex = if_nametoindex (avtpcrfbase->ifname); in setup_socket()
194 GST_ERROR_OBJECT (avtpcrfbase, "Failed to get index for interface: %s", in setup_socket()
205 GST_ERROR_OBJECT (avtpcrfbase, "Failed to bind socket: %s", in setup_socket()
210 res = sscanf (avtpcrfbase->address, "%hhx:%hhx:%hhx:%hhx:%hhx:%hhx", in setup_socket()
214 GST_ERROR_OBJECT (avtpcrfbase, "Destination MAC address format not valid"); in setup_socket()
225 GST_ERROR_OBJECT (avtpcrfbase, "Failed to set multicast address: %s", in setup_socket()
235 GST_ERROR_OBJECT (avtpcrfbase, "Failed to set receive timeout: %s", in setup_socket()
248 validate_crf_pdu (GstAvtpCrfBase * avtpcrfbase, struct avtp_crf_pdu *crf_pdu, in validate_crf_pdu() argument
251 GstAvtpCrfThreadData *data = &avtpcrfbase->thread_data; in validate_crf_pdu()
264 GST_DEBUG_OBJECT (avtpcrfbase, "Not a CRF PDU.subtype: %u", subtype); in validate_crf_pdu()
284 if (!streamid_valid || streamid != avtpcrfbase->streamid) { in validate_crf_pdu()
285 GST_DEBUG_OBJECT (avtpcrfbase, in validate_crf_pdu()
291 GST_DEBUG_OBJECT (avtpcrfbase, in validate_crf_pdu()
298 GST_DEBUG_OBJECT (avtpcrfbase, in validate_crf_pdu()
305 GST_DEBUG_OBJECT (avtpcrfbase, in validate_crf_pdu()
312 GST_DEBUG_OBJECT (avtpcrfbase, in validate_crf_pdu()
319 GST_DEBUG_OBJECT (avtpcrfbase, in validate_crf_pdu()
326 GST_DEBUG_OBJECT (avtpcrfbase, in validate_crf_pdu()
333 GST_DEBUG_OBJECT (avtpcrfbase, in validate_crf_pdu()
339 GST_DEBUG_OBJECT (avtpcrfbase, in validate_crf_pdu()
345 GST_DEBUG_OBJECT (avtpcrfbase, in validate_crf_pdu()
351 GST_DEBUG_OBJECT (avtpcrfbase, in validate_crf_pdu()
357 GST_DEBUG_OBJECT (avtpcrfbase, in validate_crf_pdu()
370 GST_DEBUG_OBJECT (avtpcrfbase, in validate_crf_pdu()
384 get_base_freq_multiplier (GstAvtpCrfBase * avtpcrfbase, guint64 pull) in get_base_freq_multiplier() argument
400 GST_ERROR_OBJECT (avtpcrfbase, "Invalid pull value"); in get_base_freq_multiplier()
406 calculate_average_period (GstAvtpCrfBase * avtpcrfbase, in calculate_average_period() argument
409 GstAvtpCrfThreadData *data = &avtpcrfbase->thread_data; in calculate_average_period()
439 base_freq_mult = get_base_freq_multiplier (avtpcrfbase, data->pull); in calculate_average_period()
478 crf_listener_thread_func (GstAvtpCrfBase * avtpcrfbase) in crf_listener_thread_func() argument
480 GstAvtpCrfThreadData *data = &avtpcrfbase->thread_data; in crf_listener_thread_func()
485 fd = setup_socket (avtpcrfbase); in crf_listener_thread_func()
487 GST_ELEMENT_ERROR (avtpcrfbase, RESOURCE, OPEN_READ, in crf_listener_thread_func()
499 GST_ERROR_OBJECT (avtpcrfbase, "Failed to receive packet: %s", in crf_listener_thread_func()
504 if (!validate_crf_pdu (avtpcrfbase, crf_pdu, n)) in crf_listener_thread_func()
507 GST_DEBUG_OBJECT (avtpcrfbase, "Packet valid. Adding to buffer\n"); in crf_listener_thread_func()
523 calculate_average_period (avtpcrfbase, crf_pdu); in crf_listener_thread_func()
532 GstAvtpCrfBase *avtpcrfbase = GST_AVTP_CRF_BASE (object); in gst_avtp_crf_base_finalize() local
534 g_free (avtpcrfbase->ifname); in gst_avtp_crf_base_finalize()
535 g_free (avtpcrfbase->address); in gst_avtp_crf_base_finalize()
544 GstAvtpCrfBase *avtpcrfbase = GST_AVTP_CRF_BASE (object); in gst_avtp_crf_base_set_property() local
546 GST_DEBUG_OBJECT (avtpcrfbase, "prop_id %u", prop_id); in gst_avtp_crf_base_set_property()
550 avtpcrfbase->streamid = g_value_get_uint64 (value); in gst_avtp_crf_base_set_property()
553 g_free (avtpcrfbase->ifname); in gst_avtp_crf_base_set_property()
554 avtpcrfbase->ifname = g_value_dup_string (value); in gst_avtp_crf_base_set_property()
557 g_free (avtpcrfbase->address); in gst_avtp_crf_base_set_property()
558 avtpcrfbase->address = g_value_dup_string (value); in gst_avtp_crf_base_set_property()
570 GstAvtpCrfBase *avtpcrfbase = GST_AVTP_CRF_BASE (object); in gst_avtp_crf_base_get_property() local
572 GST_DEBUG_OBJECT (avtpcrfbase, "prop_id %u", prop_id); in gst_avtp_crf_base_get_property()
576 g_value_set_uint64 (value, avtpcrfbase->streamid); in gst_avtp_crf_base_get_property()
579 g_value_set_string (value, avtpcrfbase->ifname); in gst_avtp_crf_base_get_property()
582 g_value_set_string (value, avtpcrfbase->address); in gst_avtp_crf_base_get_property()