Lines Matching refs:rtp
317 gst_rtp_buffer_map (GstBuffer * buffer, GstMapFlags flags, GstRTPBuffer * rtp) in gst_rtp_buffer_map() argument
330 g_return_val_if_fail (rtp != NULL, FALSE); in gst_rtp_buffer_map()
331 g_return_val_if_fail (rtp->buffer == NULL, FALSE); in gst_rtp_buffer_map()
338 if (!gst_buffer_map_range (buffer, 0, 1, &rtp->map[0], flags)) in gst_rtp_buffer_map()
341 data = rtp->data[0] = rtp->map[0].data; in gst_rtp_buffer_map()
342 size = rtp->map[0].size; in gst_rtp_buffer_map()
365 rtp->size[0] = header_len; in gst_rtp_buffer_map()
379 if (!gst_buffer_map_range (buffer, idx, length, &rtp->map[1], flags)) in gst_rtp_buffer_map()
382 extdata = rtp->data[1] = rtp->map[1].data + skip; in gst_rtp_buffer_map()
392 if (G_UNLIKELY (rtp->map[1].size < extlen)) in gst_rtp_buffer_map()
395 rtp->size[1] = extlen; in gst_rtp_buffer_map()
397 header_len += rtp->size[1]; in gst_rtp_buffer_map()
399 rtp->data[1] = NULL; in gst_rtp_buffer_map()
400 rtp->size[1] = 0; in gst_rtp_buffer_map()
410 if (!gst_buffer_map_range (buffer, idx, length, &rtp->map[3], flags)) in gst_rtp_buffer_map()
413 padding = rtp->map[3].data[skip]; in gst_rtp_buffer_map()
414 rtp->data[3] = rtp->map[3].data + skip + 1 - padding; in gst_rtp_buffer_map()
415 rtp->size[3] = padding; in gst_rtp_buffer_map()
420 rtp->data[3] = NULL; in gst_rtp_buffer_map()
421 rtp->size[3] = 0; in gst_rtp_buffer_map()
429 rtp->buffer = buffer; in gst_rtp_buffer_map()
434 rtp->data[2] = rtp->map[0].data + header_len; in gst_rtp_buffer_map()
435 rtp->size[2] = bufsize - header_len - padding; in gst_rtp_buffer_map()
438 rtp->data[2] = NULL; in gst_rtp_buffer_map()
439 rtp->size[2] = 0; in gst_rtp_buffer_map()
484 for (i = 0; i < G_N_ELEMENTS (rtp->map); ++i) { in gst_rtp_buffer_map()
485 if (rtp->map[i].memory != NULL) in gst_rtp_buffer_map()
486 gst_buffer_unmap (buffer, &rtp->map[i]); in gst_rtp_buffer_map()
499 gst_rtp_buffer_unmap (GstRTPBuffer * rtp) in gst_rtp_buffer_unmap() argument
503 g_return_if_fail (rtp != NULL); in gst_rtp_buffer_unmap()
504 g_return_if_fail (rtp->buffer != NULL); in gst_rtp_buffer_unmap()
507 if (rtp->map[i].memory != NULL) { in gst_rtp_buffer_unmap()
508 gst_buffer_unmap (rtp->buffer, &rtp->map[i]); in gst_rtp_buffer_unmap()
509 rtp->map[i].memory = NULL; in gst_rtp_buffer_unmap()
511 rtp->data[i] = NULL; in gst_rtp_buffer_unmap()
512 rtp->size[i] = 0; in gst_rtp_buffer_unmap()
514 rtp->buffer = NULL; in gst_rtp_buffer_unmap()
527 gst_rtp_buffer_set_packet_len (GstRTPBuffer * rtp, guint len) in gst_rtp_buffer_set_packet_len() argument
531 data = rtp->data[0]; in gst_rtp_buffer_set_packet_len()
535 if (rtp->map[0].maxsize <= len) { in gst_rtp_buffer_set_packet_len()
540 gst_buffer_set_size (rtp->buffer, len); in gst_rtp_buffer_set_packet_len()
541 rtp->map[0].size = len; in gst_rtp_buffer_set_packet_len()
556 gst_rtp_buffer_get_packet_len (GstRTPBuffer * rtp) in gst_rtp_buffer_get_packet_len() argument
558 return gst_buffer_get_size (rtp->buffer); in gst_rtp_buffer_get_packet_len()
571 gst_rtp_buffer_get_header_len (GstRTPBuffer * rtp) in gst_rtp_buffer_get_header_len() argument
573 return rtp->size[0] + rtp->size[1]; in gst_rtp_buffer_get_header_len()
585 gst_rtp_buffer_get_version (GstRTPBuffer * rtp) in gst_rtp_buffer_get_version() argument
587 return GST_RTP_HEADER_VERSION (rtp->data[0]); in gst_rtp_buffer_get_version()
598 gst_rtp_buffer_set_version (GstRTPBuffer * rtp, guint8 version) in gst_rtp_buffer_set_version() argument
602 GST_RTP_HEADER_VERSION (rtp->data[0]) = version; in gst_rtp_buffer_set_version()
614 gst_rtp_buffer_get_padding (GstRTPBuffer * rtp) in gst_rtp_buffer_get_padding() argument
616 return GST_RTP_HEADER_PADDING (rtp->data[0]); in gst_rtp_buffer_get_padding()
627 gst_rtp_buffer_set_padding (GstRTPBuffer * rtp, gboolean padding) in gst_rtp_buffer_set_padding() argument
629 GST_RTP_HEADER_PADDING (rtp->data[0]) = padding; in gst_rtp_buffer_set_padding()
643 gst_rtp_buffer_pad_to (GstRTPBuffer * rtp, guint len) in gst_rtp_buffer_pad_to() argument
647 data = rtp->data[0]; in gst_rtp_buffer_pad_to()
666 gst_rtp_buffer_get_extension (GstRTPBuffer * rtp) in gst_rtp_buffer_get_extension() argument
668 return GST_RTP_HEADER_EXTENSION (rtp->data[0]); in gst_rtp_buffer_get_extension()
679 gst_rtp_buffer_set_extension (GstRTPBuffer * rtp, gboolean extension) in gst_rtp_buffer_set_extension() argument
681 GST_RTP_HEADER_EXTENSION (rtp->data[0]) = extension; in gst_rtp_buffer_set_extension()
701 gst_rtp_buffer_get_extension_data (GstRTPBuffer * rtp, guint16 * bits, in gst_rtp_buffer_get_extension_data() argument
707 pdata = rtp->data[1]; in gst_rtp_buffer_get_extension_data()
742 gst_rtp_buffer_get_extension_bytes (GstRTPBuffer * rtp, guint16 * bits) in gst_rtp_buffer_get_extension_bytes() argument
747 g_return_val_if_fail (rtp != NULL, FALSE); in gst_rtp_buffer_get_extension_bytes()
749 if (!gst_rtp_buffer_get_extension_data (rtp, bits, &buf_data, &buf_len)) in gst_rtp_buffer_get_extension_bytes()
762 gst_rtp_buffer_map_payload (GstRTPBuffer * rtp) in gst_rtp_buffer_map_payload() argument
768 if (rtp->map[2].memory != NULL) in gst_rtp_buffer_map_payload()
771 hlen = gst_rtp_buffer_get_header_len (rtp); in gst_rtp_buffer_map_payload()
772 plen = gst_buffer_get_size (rtp->buffer) - hlen - rtp->size[3]; in gst_rtp_buffer_map_payload()
774 if (!gst_buffer_find_memory (rtp->buffer, hlen, plen, &idx, &length, &skip)) in gst_rtp_buffer_map_payload()
777 if (!gst_buffer_map_range (rtp->buffer, idx, length, &rtp->map[2], in gst_rtp_buffer_map_payload()
778 rtp->map[0].flags)) in gst_rtp_buffer_map_payload()
781 rtp->data[2] = rtp->map[2].data + skip; in gst_rtp_buffer_map_payload()
782 rtp->size[2] = plen; in gst_rtp_buffer_map_payload()
789 ensure_buffers (GstRTPBuffer * rtp) in ensure_buffers() argument
795 gst_rtp_buffer_map_payload (rtp); in ensure_buffers()
798 if (rtp->size[i]) { in ensure_buffers()
799 gsize offset = (guint8 *) rtp->data[i] - rtp->map[i].data; in ensure_buffers()
801 if (offset != 0 || rtp->map[i].size != rtp->size[i]) { in ensure_buffers()
805 mem = gst_memory_copy (rtp->map[i].memory, offset, rtp->size[i]); in ensure_buffers()
808 gst_buffer_insert_memory (rtp->buffer, pos, mem); in ensure_buffers()
817 GstBuffer *buf = rtp->buffer; in ensure_buffers()
819 gst_rtp_buffer_unmap (rtp); in ensure_buffers()
821 gst_rtp_buffer_map (buf, GST_MAP_READWRITE, rtp); in ensure_buffers()
841 gst_rtp_buffer_set_extension_data (GstRTPBuffer * rtp, guint16 bits, in gst_rtp_buffer_set_extension_data() argument
848 ensure_buffers (rtp); in gst_rtp_buffer_set_extension_data()
854 if (rtp->data[1] == NULL || min_size > rtp->size[1]) { in gst_rtp_buffer_set_extension_data()
860 if (rtp->data[1]) { in gst_rtp_buffer_set_extension_data()
863 memcpy (map.data, rtp->data[1], rtp->size[1]); in gst_rtp_buffer_set_extension_data()
864 if (min_size > rtp->size[1]) { in gst_rtp_buffer_set_extension_data()
865 memset (map.data + rtp->size[1], 0, min_size - rtp->size[1]); in gst_rtp_buffer_set_extension_data()
870 gst_buffer_unmap (rtp->buffer, &rtp->map[1]); in gst_rtp_buffer_set_extension_data()
871 gst_buffer_replace_memory (rtp->buffer, 1, mem); in gst_rtp_buffer_set_extension_data()
879 gst_buffer_insert_memory (rtp->buffer, 1, mem); in gst_rtp_buffer_set_extension_data()
883 gst_memory_map (mem, &rtp->map[1], GST_MAP_READWRITE); in gst_rtp_buffer_set_extension_data()
885 rtp->data[1] = rtp->map[1].data; in gst_rtp_buffer_set_extension_data()
886 rtp->size[1] = rtp->map[1].size; in gst_rtp_buffer_set_extension_data()
887 } else if (min_size < rtp->size[1]) { in gst_rtp_buffer_set_extension_data()
888 GstMemory *mem = rtp->map[1].memory; in gst_rtp_buffer_set_extension_data()
891 gst_buffer_unmap (rtp->buffer, &rtp->map[1]); in gst_rtp_buffer_set_extension_data()
893 gst_memory_map (mem, &rtp->map[1], GST_MAP_READWRITE); in gst_rtp_buffer_set_extension_data()
894 rtp->data[1] = rtp->map[1].data; in gst_rtp_buffer_set_extension_data()
895 rtp->size[1] = rtp->map[1].size; in gst_rtp_buffer_set_extension_data()
899 data = rtp->data[0]; in gst_rtp_buffer_set_extension_data()
902 data = rtp->data[1]; in gst_rtp_buffer_set_extension_data()
923 gst_rtp_buffer_remove_extension_data (GstRTPBuffer * rtp) in gst_rtp_buffer_remove_extension_data() argument
925 g_return_if_fail (gst_buffer_is_writable (rtp->buffer)); in gst_rtp_buffer_remove_extension_data()
926 g_return_if_fail (rtp->map[0].flags & GST_MAP_WRITE); in gst_rtp_buffer_remove_extension_data()
928 if (rtp->data[1] != NULL) { in gst_rtp_buffer_remove_extension_data()
929 GstBuffer *buf = rtp->buffer; in gst_rtp_buffer_remove_extension_data()
931 ensure_buffers (rtp); in gst_rtp_buffer_remove_extension_data()
933 GST_RTP_HEADER_EXTENSION (rtp->data[0]) = FALSE; in gst_rtp_buffer_remove_extension_data()
934 gst_rtp_buffer_unmap (rtp); in gst_rtp_buffer_remove_extension_data()
936 gst_rtp_buffer_map (buf, GST_MAP_READWRITE, rtp); in gst_rtp_buffer_remove_extension_data()
949 gst_rtp_buffer_get_ssrc (GstRTPBuffer * rtp) in gst_rtp_buffer_get_ssrc() argument
951 return g_ntohl (GST_RTP_HEADER_SSRC (rtp->data[0])); in gst_rtp_buffer_get_ssrc()
962 gst_rtp_buffer_set_ssrc (GstRTPBuffer * rtp, guint32 ssrc) in gst_rtp_buffer_set_ssrc() argument
964 GST_RTP_HEADER_SSRC (rtp->data[0]) = g_htonl (ssrc); in gst_rtp_buffer_set_ssrc()
976 gst_rtp_buffer_get_csrc_count (GstRTPBuffer * rtp) in gst_rtp_buffer_get_csrc_count() argument
978 return GST_RTP_HEADER_CSRC_COUNT (rtp->data[0]); in gst_rtp_buffer_get_csrc_count()
991 gst_rtp_buffer_get_csrc (GstRTPBuffer * rtp, guint8 idx) in gst_rtp_buffer_get_csrc() argument
995 data = rtp->data[0]; in gst_rtp_buffer_get_csrc()
1011 gst_rtp_buffer_set_csrc (GstRTPBuffer * rtp, guint8 idx, guint32 csrc) in gst_rtp_buffer_set_csrc() argument
1015 data = rtp->data[0]; in gst_rtp_buffer_set_csrc()
1031 gst_rtp_buffer_get_marker (GstRTPBuffer * rtp) in gst_rtp_buffer_get_marker() argument
1033 return GST_RTP_HEADER_MARKER (rtp->data[0]); in gst_rtp_buffer_get_marker()
1044 gst_rtp_buffer_set_marker (GstRTPBuffer * rtp, gboolean marker) in gst_rtp_buffer_set_marker() argument
1046 GST_RTP_HEADER_MARKER (rtp->data[0]) = marker; in gst_rtp_buffer_set_marker()
1058 gst_rtp_buffer_get_payload_type (GstRTPBuffer * rtp) in gst_rtp_buffer_get_payload_type() argument
1060 return GST_RTP_HEADER_PAYLOAD_TYPE (rtp->data[0]); in gst_rtp_buffer_get_payload_type()
1071 gst_rtp_buffer_set_payload_type (GstRTPBuffer * rtp, guint8 payload_type) in gst_rtp_buffer_set_payload_type() argument
1075 GST_RTP_HEADER_PAYLOAD_TYPE (rtp->data[0]) = payload_type; in gst_rtp_buffer_set_payload_type()
1087 gst_rtp_buffer_get_seq (GstRTPBuffer * rtp) in gst_rtp_buffer_get_seq() argument
1089 return g_ntohs (GST_RTP_HEADER_SEQ (rtp->data[0])); in gst_rtp_buffer_get_seq()
1100 gst_rtp_buffer_set_seq (GstRTPBuffer * rtp, guint16 seq) in gst_rtp_buffer_set_seq() argument
1102 GST_RTP_HEADER_SEQ (rtp->data[0]) = g_htons (seq); in gst_rtp_buffer_set_seq()
1114 gst_rtp_buffer_get_timestamp (GstRTPBuffer * rtp) in gst_rtp_buffer_get_timestamp() argument
1116 return g_ntohl (GST_RTP_HEADER_TIMESTAMP (rtp->data[0])); in gst_rtp_buffer_get_timestamp()
1127 gst_rtp_buffer_set_timestamp (GstRTPBuffer * rtp, guint32 timestamp) in gst_rtp_buffer_set_timestamp() argument
1129 GST_RTP_HEADER_TIMESTAMP (rtp->data[0]) = g_htonl (timestamp); in gst_rtp_buffer_set_timestamp()
1146 gst_rtp_buffer_get_payload_subbuffer (GstRTPBuffer * rtp, guint offset, in gst_rtp_buffer_get_payload_subbuffer() argument
1151 plen = gst_rtp_buffer_get_payload_len (rtp); in gst_rtp_buffer_get_payload_subbuffer()
1157 poffset = gst_rtp_buffer_get_header_len (rtp) + offset; in gst_rtp_buffer_get_payload_subbuffer()
1164 return gst_buffer_copy_region (rtp->buffer, GST_BUFFER_COPY_ALL, poffset, in gst_rtp_buffer_get_payload_subbuffer()
1186 gst_rtp_buffer_get_payload_buffer (GstRTPBuffer * rtp) in gst_rtp_buffer_get_payload_buffer() argument
1188 return gst_rtp_buffer_get_payload_subbuffer (rtp, 0, -1); in gst_rtp_buffer_get_payload_buffer()
1200 gst_rtp_buffer_get_payload_len (GstRTPBuffer * rtp) in gst_rtp_buffer_get_payload_len() argument
1202 return gst_buffer_get_size (rtp->buffer) - gst_rtp_buffer_get_header_len (rtp) in gst_rtp_buffer_get_payload_len()
1203 - rtp->size[3]; in gst_rtp_buffer_get_payload_len()
1217 gst_rtp_buffer_get_payload (GstRTPBuffer * rtp) in gst_rtp_buffer_get_payload() argument
1219 if (rtp->data[2]) in gst_rtp_buffer_get_payload()
1220 return rtp->data[2]; in gst_rtp_buffer_get_payload()
1222 if (!gst_rtp_buffer_map_payload (rtp)) in gst_rtp_buffer_get_payload()
1225 return rtp->data[2]; in gst_rtp_buffer_get_payload()
1241 gst_rtp_buffer_get_payload_bytes (GstRTPBuffer * rtp) in gst_rtp_buffer_get_payload_bytes() argument
1245 g_return_val_if_fail (rtp != NULL, NULL); in gst_rtp_buffer_get_payload_bytes()
1247 data = gst_rtp_buffer_get_payload (rtp); in gst_rtp_buffer_get_payload_bytes()
1251 return g_bytes_new (data, gst_rtp_buffer_get_payload_len (rtp)); in gst_rtp_buffer_get_payload_bytes()
1471 gst_rtp_buffer_get_extension_onebyte_header (GstRTPBuffer * rtp, guint8 id, in gst_rtp_buffer_get_extension_onebyte_header() argument
1478 if (!gst_rtp_buffer_get_extension_data (rtp, &bit_pattern, (gpointer) & pdata, in gst_rtp_buffer_get_extension_onebyte_header()
1504 gst_rtp_buffer_get_extension_twobytes_header (GstRTPBuffer * rtp, in gst_rtp_buffer_get_extension_twobytes_header() argument
1514 if (!gst_rtp_buffer_get_extension_data (rtp, &bits, (gpointer *) & pdata, in gst_rtp_buffer_get_extension_twobytes_header()
1624 gst_rtp_buffer_add_extension_onebyte_header (GstRTPBuffer * rtp, guint8 id, in gst_rtp_buffer_add_extension_onebyte_header() argument
1636 g_return_val_if_fail (gst_buffer_is_writable (rtp->buffer), FALSE); in gst_rtp_buffer_add_extension_onebyte_header()
1638 has_bit = gst_rtp_buffer_get_extension_data (rtp, &bits, in gst_rtp_buffer_add_extension_onebyte_header()
1655 gst_rtp_buffer_set_extension_data (rtp, 0xBEDE, wordlen_new); in gst_rtp_buffer_add_extension_onebyte_header()
1656 gst_rtp_buffer_get_extension_data (rtp, &bits, (gpointer) & pdata, &wordlen); in gst_rtp_buffer_add_extension_onebyte_header()
1724 gst_rtp_buffer_add_extension_twobytes_header (GstRTPBuffer * rtp, in gst_rtp_buffer_add_extension_twobytes_header() argument
1736 g_return_val_if_fail (gst_buffer_is_writable (rtp->buffer), FALSE); in gst_rtp_buffer_add_extension_twobytes_header()
1738 has_bit = gst_rtp_buffer_get_extension_data (rtp, &bits, in gst_rtp_buffer_add_extension_twobytes_header()
1755 gst_rtp_buffer_set_extension_data (rtp, (0x100 << 4) | (appbits & 0x0F), in gst_rtp_buffer_add_extension_twobytes_header()
1757 gst_rtp_buffer_get_extension_data (rtp, &bits, (gpointer) & pdata, &wordlen); in gst_rtp_buffer_add_extension_twobytes_header()