mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-01-02 21:48:55 +00:00
Code Issues 1 Projects Releases Wiki Activity

use new dparams api. run demo_dparams to hear how smooth it is now

Browse source 
Original commit message from CVS:
use new dparams api. run demo_dparams to hear how smooth it is now
This commit is contained in:
Steve Baker 2002-05-29 18:54:17 +00:00
parent 40b3b23ce1
commit edad35067b
1 changed files with 12 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
ext/ladspa/gstladspa.c
View file

@ -811,15 +811,16 @@ gst_ladspa_loop(GstElement *element)
} }
} }
num_to_process = GST_DPMAN_PREPROCESS(ladspa->dpman, ladspa->buffersize, ladspa->timestamp); GST_DPMAN_PREPROCESS(ladspa->dpman, ladspa->buffersize, ladspa->timestamp);
num_processed = 0; num_processed = 0;
/* split up processing of the buffer into chunks so that dparams can /* split up processing of the buffer into chunks so that dparams can
* be updated when required. * be updated when required.
* In many cases the buffer will be processed in one chunk anyway. * In many cases the buffer will be processed in one chunk anyway.
*/ */
while(GST_DPMAN_PROCESS_CHUNK(ladspa->dpman, num_to_process, num_processed)) { while(GST_DPMAN_PROCESS(ladspa->dpman, num_processed)) {
num_to_process = GST_DPMAN_FRAMES_TO_PROCESS(ladspa->dpman);
for (i=0 ; i<numsinkpads ; i++){ for (i=0 ; i<numsinkpads ; i++){
desc->connect_port (ladspa->handle, oclass->sinkpad_portnums[i], data_in[i]); desc->connect_port (ladspa->handle, oclass->sinkpad_portnums[i], data_in[i]);
} }
@ -834,8 +835,7 @@ gst_ladspa_loop(GstElement *element)
data_out[i] += num_to_process; data_out[i] += num_to_process;
} }
num_processed = num_to_process; num_processed += num_to_process;
num_to_process = 0;
} }
for (i=0 ; i<numsrcpads ; i++) { for (i=0 ; i<numsrcpads ; i++) {
@ -936,14 +936,16 @@ gst_ladspa_chain (GstPad *pad, GstBuffer *buf)
} }
} }
num_to_process = GST_DPMAN_PREPROCESS(ladspa->dpman, num_samples, GST_BUFFER_TIMESTAMP(buf)); GST_DPMAN_PREPROCESS(ladspa->dpman, num_samples, GST_BUFFER_TIMESTAMP(buf));
num_processed = 0; num_processed = 0;
/* split up processing of the buffer into chunks so that dparams can /* split up processing of the buffer into chunks so that dparams can
* be updated when required. * be updated when required.
* In many cases the buffer will be processed in one chunk anyway. * In many cases the buffer will be processed in one chunk anyway.
*/ */
while(GST_DPMAN_PROCESS_CHUNK(ladspa->dpman, num_to_process, num_processed)) { while(GST_DPMAN_PROCESS(ladspa->dpman, num_processed)) {
num_to_process = GST_DPMAN_FRAMES_TO_PROCESS(ladspa->dpman);
desc->connect_port(ladspa->handle,oclass->sinkpad_portnums[0],data_in); desc->connect_port(ladspa->handle,oclass->sinkpad_portnums[0],data_in);
for (i=0 ; i<numsrcpads ; i++){ for (i=0 ; i<numsrcpads ; i++){
desc->connect_port(ladspa->handle,oclass->srcpad_portnums[i],data_out[i]); desc->connect_port(ladspa->handle,oclass->srcpad_portnums[i],data_out[i]);
@ -955,7 +957,6 @@ gst_ladspa_chain (GstPad *pad, GstBuffer *buf)
data_out[i] += num_to_process; data_out[i] += num_to_process;
} }
num_processed += num_to_process; num_processed += num_to_process;
num_to_process = 0;
} }
if (numsrcpads > 0){ if (numsrcpads > 0){
@ -1012,7 +1013,7 @@ gst_ladspa_get(GstPad *pad)
data = (LADSPA_Data *) GST_BUFFER_DATA(buf); data = (LADSPA_Data *) GST_BUFFER_DATA(buf);
desc = ladspa->descriptor; desc = ladspa->descriptor;
num_to_process = GST_DPMAN_PREPROCESS(ladspa->dpman, ladspa->buffersize, ladspa->timestamp); GST_DPMAN_PREPROCESS(ladspa->dpman, ladspa->buffersize, ladspa->timestamp);
num_processed = 0; num_processed = 0;
/* update timestamp */ /* update timestamp */
@ -1022,13 +1023,14 @@ gst_ladspa_get(GstPad *pad)
* be updated when required. * be updated when required.
* In many cases the buffer will be processed in one chunk anyway. * In many cases the buffer will be processed in one chunk anyway.
*/ */
while(GST_DPMAN_PROCESS_CHUNK(ladspa->dpman, num_to_process, num_processed)) { while(GST_DPMAN_PROCESS(ladspa->dpman, num_processed)) {
num_to_process = GST_DPMAN_FRAMES_TO_PROCESS(ladspa->dpman);
desc->connect_port(ladspa->handle,oclass->srcpad_portnums[0],data); desc->connect_port(ladspa->handle,oclass->srcpad_portnums[0],data);
desc->run(ladspa->handle, num_to_process); desc->run(ladspa->handle, num_to_process);
data += num_to_process; data += num_to_process;
num_processed = num_to_process; num_processed = num_to_process;
num_to_process = 0;
} }
return buf; return buf;