mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-18 07:47:17 +00:00
Code Issues 1 Projects Releases Wiki Activity

fix to adder: don't pull on unusable pads

Browse source 
Original commit message from CVS:
* fix to adder: don't pull on unusable pads
* fix to ladspa: get output buffers first, so we can know how many frames to
process
- this breaks inplace buffer stuff, hmm
* fix to float2int: add a bufferpool with the same nframes as the source pad's
pool -> no extra latency
This commit is contained in:
Andy Wingo 2002-07-26 18:55:42 +00:00
parent da620f6842
commit e52bee3647
1 changed files with 21 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
ext/ladspa/gstladspa.c
View file

@ -772,10 +772,14 @@ gst_ladspa_loop(GstElement *element)
buffers_out = g_new0(GstBuffer*, numsrcpads);
bytestreams = g_new0(GstByteStream*, numsinkpads);
bufferbytesize = sizeof (LADSPA_Data) * ladspa->buffersize;
/* find a bufferpool */
bufpool = gst_buffer_pool_get_default (bufferbytesize, ladspa->numbuffers);
if (numsrcpads > 0 && (bufpool = gst_pad_get_bufferpool (ladspa->srcpads[0]))) {
GST_DEBUG (0, "Got bufferpool from first source pad");
} else {
bufferbytesize = sizeof (LADSPA_Data) * ladspa->buffersize;
bufpool = gst_buffer_pool_get_default (bufferbytesize, ladspa->numbuffers);
GST_DEBUG (0, "Created default bufferpool, %d x %d bytes", ladspa->numbuffers, bufferbytesize);
}
/* get the bytestreams for each pad */
for (i=0 ; i<numsinkpads ; i++){
@ -784,10 +788,20 @@ gst_ladspa_loop(GstElement *element)
/* since this is a loop element, we just loop here til things fall apart. */
do {
/* we need to get the buffers_out first so we can know how many bytes to process */
for (i=0 ; i<numsrcpads ; i++){
buffers_out[i] = gst_buffer_new_from_pool (bufpool, 0, 0);
GST_BUFFER_TIMESTAMP(buffers_out[i]) = ladspa->timestamp;
data_out[i] = (LADSPA_Data *) GST_BUFFER_DATA(buffers_out[i]);
}
bufferbytesize = GST_BUFFER_SIZE (buffers_out[0]);
ladspa->buffersize = bufferbytesize / sizeof (LADSPA_Data);
num_empty_pads = 0;
/* first get all the necessary data from the input ports */
for (i=0 ; i<numsinkpads ; i++){
GST_DEBUG (0, "pulling %u bytes through channel %d'sbytestream", bufferbytesize, i);
GST_DEBUG (0, "pulling %u bytes through channel %d's bytestream", bufferbytesize, i);
got_bytes = gst_bytestream_read (bytestreams[i], buffers_in + i, bufferbytesize);
if (got_bytes != bufferbytesize) {
@ -834,20 +848,6 @@ gst_ladspa_loop(GstElement *element)
}
}
/* we now have a full set of buffers_in.
* now share or create the buffers_out */
for (i=0 ; i<numsrcpads ; i++){
if (i <= numsinkpads && !ladspa->inplace_broken){
/* we can share buffers */
buffers_out[i] = buffers_in[i];
data_out[i] = data_in[i];
} else {
buffers_out[i] = gst_buffer_new_from_pool (bufpool, 0, 0);
GST_BUFFER_TIMESTAMP(buffers_out[i]) = ladspa->timestamp;
data_out[i] = (LADSPA_Data *) GST_BUFFER_DATA(buffers_out[i]);
}
}
GST_DPMAN_PREPROCESS(ladspa->dpman, ladspa->buffersize, ladspa->timestamp);
num_processed = 0;
@ -883,15 +883,14 @@ gst_ladspa_loop(GstElement *element)
buffers_out[i] = NULL;
}
for (i=0 ; i<numsinkpads ; i++) {
if (i > numsrcpads || ladspa->inplace_broken){
/* we have some buffers to unref */
gst_buffer_unref(buffers_in[i]);
}
gst_buffer_unref(buffers_in[i]);
data_in[i] = NULL;
buffers_in[i] = NULL;
}
ladspa->timestamp += ladspa->buffersize * 10^9 / ladspa->samplerate;
gst_element_yield (element);
} while (TRUE);
gst_buffer_pool_unref(bufpool);