while (size >= 80) {
/* Allocate a new buffer, set the timestamp */
if (outbuf == NULL) {
- outbuf = gst_rtp_buffer_new_allocate (max_payload_size, 0, 0);
+ outbuf =
+ gst_rtp_base_payload_allocate_output_buffer (basepayload,
+ max_payload_size, 0, 0);
GST_BUFFER_PTS (outbuf) = GST_BUFFER_PTS (buffer);
if (!gst_rtp_buffer_map (outbuf, GST_MAP_WRITE, &rtp)) {
nbytes = bitrange_to_bytes (start, end);
- outbuf = gst_rtp_buffer_new_allocate (nbytes +
- GST_RTP_H261_PAYLOAD_HEADER_LEN, 0, 0);
+ outbuf =
+ gst_rtp_base_payload_allocate_output_buffer (GST_RTP_BASE_PAYLOAD (pay),
+ nbytes + GST_RTP_H261_PAYLOAD_HEADER_LEN, 0, 0);
gst_rtp_buffer_map (outbuf, GST_MAP_WRITE, &rtp);
payload = gst_rtp_buffer_get_payload (&rtp);
header = (GstRtpH261PayHeader *) payload;
pack->gobn = context->gobs[first]->gobn;
pack->mode = GST_RTP_H263_PAYLOAD_HEADER_MODE_A;
- pack->outbuf = gst_rtp_buffer_new_allocate (pack->mode, 0, 0);
+ pack->outbuf =
+ gst_rtp_base_payload_allocate_output_buffer (GST_RTP_BASE_PAYLOAD
+ (rtph263pay), pack->mode, 0, 0);
GST_DEBUG_OBJECT (rtph263pay, "Sending len:%d data to push function",
pack->payload_len);
}
pack->payload_len = pack->payload_end - pack->payload_start + 1;
- pack->outbuf = gst_rtp_buffer_new_allocate (pack->mode, 0, 0);
+ pack->outbuf =
+ gst_rtp_base_payload_allocate_output_buffer (GST_RTP_BASE_PAYLOAD
+ (rtph263pay), pack->mode, 0, 0);
return gst_rtp_h263_pay_push (rtph263pay, context, pack);
}
rtph263pay->available_data);
pack->outbuf =
- gst_rtp_buffer_new_allocate (GST_RTP_H263_PAYLOAD_HEADER_MODE_A, 0, 0);
+ gst_rtp_base_payload_allocate_output_buffer (GST_RTP_BASE_PAYLOAD
+ (rtph263pay), GST_RTP_H263_PAYLOAD_HEADER_MODE_A, 0, 0);
return gst_rtp_h263_pay_push (rtph263pay, context, pack);
}
if (next_gop > 0)
towrite = MIN (next_gop, towrite);
- outbuf = gst_rtp_buffer_new_allocate (header_len, 0, 0);
+ outbuf =
+ gst_rtp_base_payload_allocate_output_buffer (GST_RTP_BASE_PAYLOAD
+ (rtph263ppay), header_len, 0, 0);
gst_rtp_buffer_map (outbuf, GST_MAP_WRITE, &rtp);
/* last fragment gets the marker bit set */
/* use buffer lists
* create buffer without payload containing only the RTP header
* (memory block at index 0) */
- outbuf = gst_rtp_buffer_new_allocate (2, 0, 0);
+ outbuf = gst_rtp_base_payload_allocate_output_buffer (basepayload, 2, 0, 0);
gst_rtp_buffer_map (outbuf, GST_MAP_WRITE, &rtp);
/* create buffer without payload containing only the RTP header
* (memory block at index 0) */
- outbuf = gst_rtp_buffer_new_allocate (0, 0, 0);
+ outbuf = gst_rtp_base_payload_allocate_output_buffer (basepayload, 0, 0, 0);
gst_rtp_buffer_map (outbuf, GST_MAP_WRITE, &rtp);
/* use buffer lists
* create buffer without payload containing only the RTP header
* (memory block at index 0) */
- outbuf = gst_rtp_buffer_new_allocate (0, 0, 0);
+ outbuf = gst_rtp_base_payload_allocate_output_buffer (basepayload, 0, 0, 0);
gst_rtp_buffer_map (outbuf, GST_MAP_WRITE, &rtp);
/* use buffer lists
* create buffer without payload containing only the RTP header
* (memory block at index 0), and with space for PayloadHdr and FU header */
- outbuf = gst_rtp_buffer_new_allocate (3, 0, 0);
+ outbuf = gst_rtp_base_payload_allocate_output_buffer (basepayload, 3, 0, 0);
gst_rtp_buffer_map (outbuf, GST_MAP_WRITE, &rtp);
data_size = payload_size - GST_RTP_J2K_HEADER_SIZE;
/* make buffer for header */
- outbuf = gst_rtp_buffer_new_allocate (GST_RTP_J2K_HEADER_SIZE, 0, 0);
+ outbuf =
+ gst_rtp_base_payload_allocate_output_buffer (basepayload,
+ GST_RTP_J2K_HEADER_SIZE, 0, 0);
GST_BUFFER_PTS (outbuf) = timestamp;
if (dri_found)
header_size += sizeof (restart_marker_header);
- outbuf = gst_rtp_buffer_new_allocate (header_size, 0, 0);
+ outbuf =
+ gst_rtp_base_payload_allocate_output_buffer (basepayload, header_size,
+ 0, 0);
gst_rtp_buffer_map (outbuf, GST_MAP_WRITE, &rtp);
bytes_left = map.size - offset;
payload_size = MIN (bytes_left, max_payload_size);
- outbuf = gst_rtp_buffer_new_allocate (0, 0, 0);
+ outbuf = gst_rtp_base_payload_allocate_output_buffer (basepayload, 0, 0, 0);
if (payload_size == bytes_left) {
GST_LOG_OBJECT (pay, "last packet of KLV unit");
/* create buffer without payload. The payload will be put
* in next buffer instead. Both buffers will be merged */
- outbuf = gst_rtp_buffer_new_allocate (0, 0, 0);
+ outbuf =
+ gst_rtp_base_payload_allocate_output_buffer (GST_RTP_BASE_PAYLOAD
+ (rtpmp4vpay), 0, 0, 0);
/* Take buffer with the payload from the adapter */
outbuf_data = gst_adapter_take_buffer_fast (rtpmp4vpay->adapter,
payload_len = gst_rtp_buffer_calc_payload_len (towrite, 0, 0);
- outbuf = gst_rtp_buffer_new_allocate (4, 0, 0);
+ outbuf =
+ gst_rtp_base_payload_allocate_output_buffer (GST_RTP_BASE_PAYLOAD
+ (rtpmpvpay), 4, 0, 0);
payload_len -= 4;
/* new packet allocate max packet size */
rtptheorapay->packet =
- gst_rtp_buffer_new_allocate_len (GST_RTP_BASE_PAYLOAD_MTU
- (rtptheorapay), 0, 0);
+ gst_rtp_base_payload_allocate_output_buffer (GST_RTP_BASE_PAYLOAD
+ (rtptheorapay), GST_RTP_BASE_PAYLOAD_MTU (rtptheorapay), 0, 0);
gst_rtp_theora_pay_reset_packet (rtptheorapay, TDT);
GST_BUFFER_PTS (rtptheorapay->packet) = timestamp;
guint8 *p;
GstRTPBuffer rtpbuffer = GST_RTP_BUFFER_INIT;
- out = gst_rtp_base_payload_allocate_output_buffer (
- GST_RTP_BASE_PAYLOAD_CAST (self), gst_rtp_vp8_calc_header_len (self),
- 0, 0);
+ out =
+ gst_rtp_base_payload_allocate_output_buffer (GST_RTP_BASE_PAYLOAD_CAST
+ (self), gst_rtp_vp8_calc_header_len (self), 0, 0);
gst_rtp_buffer_map (out, GST_MAP_READWRITE, &rtpbuffer);
p = gst_rtp_buffer_get_payload (&rtpbuffer);
/* X=0,R=0,N=0,S=start,PartID=partid */
guint off = 1;
guint hdrlen = gst_rtp_vp9_calc_header_len (self, start);
- out = gst_rtp_buffer_new_allocate (hdrlen, 0, 0);
+ out =
+ gst_rtp_base_payload_allocate_output_buffer (GST_RTP_BASE_PAYLOAD (self),
+ hdrlen, 0, 0);
gst_rtp_buffer_map (out, GST_MAP_READWRITE, &rtpbuffer);
p = gst_rtp_buffer_get_payload (&rtpbuffer);
p[0] = 0x0;