dsp.cpp

Go to the documentation of this file.

#include "foobar2000.h"
#include <math.h>

t_size dsp_chunk_list_impl::get_count() const {return m_data.get_count();}

audio_chunk * dsp_chunk_list_impl::get_item(t_size n) const {return n<m_data.get_count() ? &*m_data[n] : 0;}

void dsp_chunk_list_impl::remove_by_idx(t_size idx)
{
    if (idx<m_data.get_count())
        m_recycled.add_item(m_data.remove_by_idx(idx));
}

void dsp_chunk_list_impl::remove_mask(const bit_array & mask)
{
    t_size n, m = m_data.get_count();
    for(n=0;n<m;n++)
        if (mask[m])
            m_recycled.add_item(m_data[n]);
    m_data.remove_mask(mask);
}

audio_chunk * dsp_chunk_list_impl::insert_item(t_size idx,t_size hint_size)
{
    t_size max = get_count();
    if (idx>max) idx = max;
    pfc::rcptr_t<audio_chunk> ret;
    if (m_recycled.get_count()>0)
    {
        t_size best;
        if (hint_size>0)
        {
            best = 0;
            t_size best_found = m_recycled[0]->get_data_size(), n, total = m_recycled.get_count();
            for(n=1;n<total;n++)
            {
                if (best_found==hint_size) break;
                t_size size = m_recycled[n]->get_data_size();
                int delta_old = abs((int)best_found - (int)hint_size), delta_new = abs((int)size - (int)hint_size);
                if (delta_new < delta_old)
                {
                    best_found = size;
                    best = n;
                }
            }
        }
        else best = m_recycled.get_count()-1;

        ret = m_recycled.remove_by_idx(best);
        ret->set_sample_count(0);
        ret->set_channels(0);
        ret->set_srate(0);
    }
    else ret = pfc::rcnew_t<audio_chunk_impl>();
    if (idx==max) m_data.add_item(ret);
    else m_data.insert_item(ret,idx);
    return &*ret;
}

void dsp_chunk_list::remove_bad_chunks()
{
    bool blah = false;
    t_size idx;
    for(idx=0;idx<get_count();)
    {
        audio_chunk * chunk = get_item(idx);
        if (!chunk->is_valid())
        {
            chunk->reset();
            remove_by_idx(idx);
            blah = true;
        }
        else idx++;
    }
    if (blah) console::info("one or more bad chunks removed from dsp chunk list");
}


bool dsp_entry::g_instantiate(service_ptr_t<dsp> & p_out,const dsp_preset & p_preset)
{
    service_ptr_t<dsp_entry> ptr;
    if (!g_get_interface(ptr,p_preset.get_owner())) return false;
    return ptr->instantiate(p_out,p_preset);
}

bool dsp_entry::g_instantiate_default(service_ptr_t<dsp> & p_out,const GUID & p_guid)
{
    service_ptr_t<dsp_entry> ptr;
    if (!g_get_interface(ptr,p_guid)) return false;
    dsp_preset_impl preset;
    if (!ptr->get_default_preset(preset)) return false;
    return ptr->instantiate(p_out,preset);
}

bool dsp_entry::g_name_from_guid(pfc::string_base & p_out,const GUID & p_guid)
{
    service_ptr_t<dsp_entry> ptr;
    if (!g_get_interface(ptr,p_guid)) return false;
    ptr->get_name(p_out);
    return true;
}

bool dsp_entry::g_dsp_exists(const GUID & p_guid)
{
    service_ptr_t<dsp_entry> blah;
    return g_get_interface(blah,p_guid);
}

bool dsp_entry::g_get_default_preset(dsp_preset & p_out,const GUID & p_guid)
{
    service_ptr_t<dsp_entry> ptr;
    if (!g_get_interface(ptr,p_guid)) return false;
    return ptr->get_default_preset(p_out);
}

void dsp_chain_config::contents_to_stream(stream_writer * p_stream,abort_callback & p_abort) const {
    t_size n, count = get_count();
    p_stream->write_lendian_t(count,p_abort);
    for(n=0;n<count;n++) {
        get_item(n).contents_to_stream(p_stream,p_abort);
    }
}

void dsp_chain_config::contents_from_stream(stream_reader * p_stream,abort_callback & p_abort) {
    t_uint32 n,count;

    remove_all();

    p_stream->read_lendian_t(count,p_abort);

    dsp_preset_impl temp;

    for(n=0;n<count;n++) {
        temp.contents_from_stream(p_stream,p_abort);
        add_item(temp);
    }
}


bool cfg_dsp_chain_config::get_data(dsp_chain_config & p_data) const {
    p_data.copy(m_data);
    return true;
}

void cfg_dsp_chain_config::set_data(const dsp_chain_config & p_data) {
    m_data.copy(p_data);
}

void cfg_dsp_chain_config::reset() {
    m_data.remove_all();
}

void cfg_dsp_chain_config::get_data_raw(stream_writer * p_stream,abort_callback & p_abort) {
    m_data.contents_to_stream(p_stream,p_abort);
}

void cfg_dsp_chain_config::set_data_raw(stream_reader * p_stream,t_size,abort_callback & p_abort) {
    m_data.contents_from_stream(p_stream,p_abort);
}

void dsp_chain_config::remove_item(t_size p_index)
{
    remove_mask(bit_array_one(p_index));
}

void dsp_chain_config::add_item(const dsp_preset & p_data)
{
    insert_item(p_data,get_count());
}

void dsp_chain_config::remove_all()
{
    remove_mask(bit_array_true());
}

void dsp_chain_config::instantiate(service_list_t<dsp> & p_out)
{
    p_out.remove_all();
    t_size n, m = get_count();
    for(n=0;n<m;n++)
    {
        service_ptr_t<dsp> temp;
        if (dsp_entry::g_instantiate(temp,get_item(n)))
            p_out.add_item(temp);
    }
}

t_size dsp_chain_config_impl::get_count() const
{
    return m_data.get_count();
}

const dsp_preset & dsp_chain_config_impl::get_item(t_size p_index) const
{
    return *m_data[p_index];
}

void dsp_chain_config_impl::replace_item(const dsp_preset & p_data,t_size p_index)
{
    *m_data[p_index] = p_data;
}

void dsp_chain_config_impl::insert_item(const dsp_preset & p_data,t_size p_index)
{
    m_data.insert_item(new dsp_preset_impl(p_data),p_index);
}

void dsp_chain_config_impl::remove_mask(const bit_array & p_mask)
{
    m_data.delete_mask(p_mask);
}

dsp_chain_config_impl::~dsp_chain_config_impl()
{
    m_data.delete_all();
}

void dsp_preset::contents_to_stream(stream_writer * p_stream,abort_callback & p_abort) const {
    t_size size = get_data_size();
    p_stream->write_lendian_t(get_owner(),p_abort);
    p_stream->write_lendian_t(size,p_abort);
    if (size > 0) {
        p_stream->write_object(get_data(),size,p_abort);
    }
}

void dsp_preset::contents_from_stream(stream_reader * p_stream,abort_callback & p_abort) {
    t_uint32 size;
    GUID guid;
    p_stream->read_lendian_t(guid,p_abort);
    set_owner(guid);
    p_stream->read_lendian_t(size,p_abort);
    if (size > 1024*1024*32) throw exception_io_data();
    set_data_from_stream(p_stream,size,p_abort);
}

void dsp_preset::g_contents_from_stream_skip(stream_reader * p_stream,abort_callback & p_abort) {
    t_uint32 size;
    GUID guid;
    p_stream->read_lendian_t(guid,p_abort);
    p_stream->read_lendian_t(size,p_abort);
    if (size > 1024*1024*32) throw exception_io_data();
    p_stream->skip_object(size,p_abort);
}

void dsp_preset_impl::set_data_from_stream(stream_reader * p_stream,t_size p_bytes,abort_callback & p_abort) {
    m_data.set_size(p_bytes);
    if (p_bytes > 0) p_stream->read_object(m_data.get_ptr(),p_bytes,p_abort);
}

void dsp_chain_config::copy(const dsp_chain_config & p_source) {
    remove_all();
    t_size n, m = p_source.get_count();
    for(n=0;n<m;n++)
        add_item(p_source.get_item(n));
}

bool dsp_entry::g_have_config_popup(const GUID & p_guid)
{
    service_ptr_t<dsp_entry> entry;
    if (!g_get_interface(entry,p_guid)) return false;
    return entry->have_config_popup();
}

bool dsp_entry::g_have_config_popup(const dsp_preset & p_preset)
{
    return g_have_config_popup(p_preset.get_owner());
}

bool dsp_entry::g_show_config_popup(dsp_preset & p_preset,HWND p_parent)
{
    service_ptr_t<dsp_entry> entry;
    if (!g_get_interface(entry,p_preset.get_owner())) return false;
    return entry->show_config_popup(p_preset,p_parent);
}

void dsp_entry::g_show_config_popup_v2(const dsp_preset & p_preset,HWND p_parent,dsp_preset_edit_callback & p_callback) {
    service_ptr_t<dsp_entry> entry;
    if (g_get_interface(entry,p_preset.get_owner())) {
        service_ptr_t<dsp_entry_v2> entry_v2;
        if (entry->service_query_t(entry_v2)) {
            entry_v2->show_config_popup_v2(p_preset,p_parent,p_callback);
        } else {
            dsp_preset_impl temp(p_preset);
            if (entry->show_config_popup(temp,p_parent)) p_callback.on_preset_changed(temp);
        }
    }
}

bool dsp_entry::g_get_interface(service_ptr_t<dsp_entry> & p_out,const GUID & p_guid)
{
    service_ptr_t<dsp_entry> ptr;
    service_enum_t<dsp_entry> e;
    e.reset();
    while(e.next(ptr))
    {
        if (ptr->get_guid() == p_guid)
        {
            p_out = ptr;
            return true;
        }
    }
    return false;
}

bool resampler_entry::g_get_interface(service_ptr_t<resampler_entry> & p_out,unsigned p_srate_from,unsigned p_srate_to)
{
    service_ptr_t<dsp_entry> ptr_dsp;
    service_ptr_t<resampler_entry> ptr_resampler;
    service_enum_t<dsp_entry> e;
    e.reset();
    float found_priority = 0;
    service_ptr_t<resampler_entry> found;
    while(e.next(ptr_dsp))
    {
        if (ptr_dsp->service_query_t(ptr_resampler))
        {
            if (p_srate_from == 0 || ptr_resampler->is_conversion_supported(p_srate_from,p_srate_to))
            {
                float priority = ptr_resampler->get_priority();
                if (found.is_empty() || priority > found_priority)
                {
                    found = ptr_resampler;
                    found_priority = priority;
                }
            }
        }
    }
    if (found.is_empty()) return false;
    p_out = found;
    return true;
}

bool resampler_entry::g_create_preset(dsp_preset & p_out,unsigned p_srate_from,unsigned p_srate_to,float p_qualityscale)
{
    service_ptr_t<resampler_entry> entry;
    if (!g_get_interface(entry,p_srate_from,p_srate_to)) return false;
    return entry->create_preset(p_out,p_srate_to,p_qualityscale);
}

bool resampler_entry::g_create(service_ptr_t<dsp> & p_out,unsigned p_srate_from,unsigned p_srate_to,float p_qualityscale)
{
    service_ptr_t<resampler_entry> entry;
    if (!g_get_interface(entry,p_srate_from,p_srate_to)) return false;
    dsp_preset_impl preset;
    if (!entry->create_preset(preset,p_srate_to,p_qualityscale)) return false;
    return entry->instantiate(p_out,preset);
}


bool dsp_chain_config::equals(dsp_chain_config const & v1, dsp_chain_config const & v2) {
    const t_size count = v1.get_count();
    if (count != v2.get_count()) return false;
    for(t_size walk = 0; walk < count; ++walk) {
        if (v1.get_item(walk) != v2.get_item(walk)) return false;
    }
    return true;
}
void dsp_chain_config::get_name_list(pfc::string_base & p_out) const
{
    const t_size count = get_count();
    bool added = false;
    for(unsigned n=0;n<count;n++)
    {
        service_ptr_t<dsp_entry> ptr;
        if (dsp_entry::g_get_interface(ptr,get_item(n).get_owner()))
        {
            if (added) p_out += ", ";
            added = true;

            pfc::string8 temp;
            ptr->get_name(temp);
            p_out += temp;
        }
    }
}

void dsp::run_abortable(dsp_chunk_list * p_chunk_list,const metadb_handle_ptr & p_cur_file,int p_flags,abort_callback & p_abort) {
    service_ptr_t<dsp_v2> this_v2;
    if (this->service_query_t(this_v2)) this_v2->run_v2(p_chunk_list,p_cur_file,p_flags,p_abort);
    else run(p_chunk_list,p_cur_file,p_flags);
}

namespace {
    class dsp_preset_edit_callback_impl : public dsp_preset_edit_callback {
    public:
        dsp_preset_edit_callback_impl(dsp_preset & p_data) : m_data(p_data) {}
        void on_preset_changed(const dsp_preset & p_data) {m_data = p_data;}
    private:
        dsp_preset & m_data;
    };
};

bool dsp_entry_v2::show_config_popup(dsp_preset & p_data,HWND p_parent) {
    PFC_ASSERT(p_data.get_owner() == get_guid());
    dsp_preset_impl temp(p_data);
    
    {
        dsp_preset_edit_callback_impl cb(temp);
        show_config_popup_v2(p_data,p_parent,cb);
    }
    PFC_ASSERT(temp.get_owner() == get_guid());
    if (temp == p_data) return false;
    p_data = temp;
    return true;
}