cannam@3: /* -*- c-basic-offset: 4 indent-tabs-mode: nil -*-  vi:set ts=8 sts=4 sw=4: */
cannam@3: 
cannam@3: /*
cannam@3:     Vamp
cannam@3: 
cannam@3:     An API for audio analysis and feature extraction plugins.
cannam@3: 
cannam@3:     Centre for Digital Music, Queen Mary, University of London.
cannam@3:     Copyright 2006 Chris Cannam.
cannam@3:   
cannam@3:     Permission is hereby granted, free of charge, to any person
cannam@3:     obtaining a copy of this software and associated documentation
cannam@3:     files (the "Software"), to deal in the Software without
cannam@3:     restriction, including without limitation the rights to use, copy,
cannam@3:     modify, merge, publish, distribute, sublicense, and/or sell copies
cannam@3:     of the Software, and to permit persons to whom the Software is
cannam@3:     furnished to do so, subject to the following conditions:
cannam@3: 
cannam@3:     The above copyright notice and this permission notice shall be
cannam@3:     included in all copies or substantial portions of the Software.
cannam@3: 
cannam@3:     THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
cannam@3:     EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
cannam@3:     MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
cannam@6:     NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS BE LIABLE FOR
cannam@3:     ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF
cannam@3:     CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
cannam@3:     WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
cannam@3: 
cannam@3:     Except as contained in this notice, the names of the Centre for
cannam@3:     Digital Music; Queen Mary, University of London; and Chris Cannam
cannam@3:     shall not be used in advertising or otherwise to promote the sale,
cannam@3:     use or other dealings in this Software without prior written
cannam@3:     authorization.
cannam@3: */
cannam@3: 
cannam@3: #include "PluginAdapter.h"
cannam@3: 
cannam@130: #include <cstring>
cannam@130: #include <cstdlib>
cannam@130: 
cannam@23: //#define DEBUG_PLUGIN_ADAPTER 1
cannam@22: 
cannam@3: namespace Vamp {
cannam@3: 
cannam@76: class PluginAdapterBase::Impl
cannam@3: {
cannam@76: public:
cannam@76:     Impl(PluginAdapterBase *);
cannam@76:     ~Impl();
cannam@76: 
cannam@76:     const VampPluginDescriptor *getDescriptor();
cannam@76: 
cannam@76: protected:
cannam@76:     PluginAdapterBase *m_base;
cannam@76: 
cannam@76:     static VampPluginHandle vampInstantiate(const VampPluginDescriptor *desc,
cannam@167:                                             float inputSampleRate);
cannam@76: 
cannam@76:     static void vampCleanup(VampPluginHandle handle);
cannam@76: 
cannam@76:     static int vampInitialise(VampPluginHandle handle, unsigned int channels,
cannam@76:                              unsigned int stepSize, unsigned int blockSize);
cannam@76: 
cannam@76:     static void vampReset(VampPluginHandle handle);
cannam@76: 
cannam@76:     static float vampGetParameter(VampPluginHandle handle, int param);
cannam@76:     static void vampSetParameter(VampPluginHandle handle, int param, float value);
cannam@76: 
cannam@76:     static unsigned int vampGetCurrentProgram(VampPluginHandle handle);
cannam@76:     static void vampSelectProgram(VampPluginHandle handle, unsigned int program);
cannam@76: 
cannam@76:     static unsigned int vampGetPreferredStepSize(VampPluginHandle handle);
cannam@76:     static unsigned int vampGetPreferredBlockSize(VampPluginHandle handle);
cannam@76:     static unsigned int vampGetMinChannelCount(VampPluginHandle handle);
cannam@76:     static unsigned int vampGetMaxChannelCount(VampPluginHandle handle);
cannam@76: 
cannam@76:     static unsigned int vampGetOutputCount(VampPluginHandle handle);
cannam@76: 
cannam@76:     static VampOutputDescriptor *vampGetOutputDescriptor(VampPluginHandle handle,
cannam@76:                                                        unsigned int i);
cannam@76: 
cannam@76:     static void vampReleaseOutputDescriptor(VampOutputDescriptor *desc);
cannam@76: 
cannam@76:     static VampFeatureList *vampProcess(VampPluginHandle handle,
cannam@76:                                         const float *const *inputBuffers,
cannam@76:                                         int sec,
cannam@76:                                         int nsec);
cannam@76: 
cannam@76:     static VampFeatureList *vampGetRemainingFeatures(VampPluginHandle handle);
cannam@76: 
cannam@76:     static void vampReleaseFeatureSet(VampFeatureList *fs);
cannam@76: 
cannam@76:     void cleanup(Plugin *plugin);
cannam@76:     void checkOutputMap(Plugin *plugin);
cannam@76:     unsigned int getOutputCount(Plugin *plugin);
cannam@76:     VampOutputDescriptor *getOutputDescriptor(Plugin *plugin,
cannam@76:                                              unsigned int i);
cannam@76:     VampFeatureList *process(Plugin *plugin,
cannam@76:                              const float *const *inputBuffers,
cannam@76:                              int sec, int nsec);
cannam@76:     VampFeatureList *getRemainingFeatures(Plugin *plugin);
cannam@76:     VampFeatureList *convertFeatures(Plugin *plugin,
cannam@76:                                      const Plugin::FeatureSet &features);
cannam@76:     
cannam@76:     // maps both plugins and descriptors to adapters
cannam@76:     typedef std::map<const void *, Impl *> AdapterMap;
cannam@76:     static AdapterMap *m_adapterMap;
cannam@76:     static Impl *lookupAdapter(VampPluginHandle);
cannam@76: 
cannam@76:     bool m_populated;
cannam@76:     VampPluginDescriptor m_descriptor;
cannam@76:     Plugin::ParameterList m_parameters;
cannam@76:     Plugin::ProgramList m_programs;
cannam@76:     
cannam@76:     typedef std::map<Plugin *, Plugin::OutputList *> OutputMap;
cannam@76:     OutputMap m_pluginOutputs;
cannam@76: 
cannam@76:     std::map<Plugin *, VampFeatureList *> m_fs;
cannam@76:     std::map<Plugin *, std::vector<size_t> > m_fsizes;
cannam@76:     std::map<Plugin *, std::vector<std::vector<size_t> > > m_fvsizes;
cannam@76:     void resizeFS(Plugin *plugin, int n);
cannam@76:     void resizeFL(Plugin *plugin, int n, size_t sz);
cannam@76:     void resizeFV(Plugin *plugin, int n, int j, size_t sz);
cannam@76: };
cannam@76: 
cannam@76: PluginAdapterBase::PluginAdapterBase()
cannam@76: {
cannam@76:     m_impl = new Impl(this);
cannam@76: }
cannam@76: 
cannam@76: PluginAdapterBase::~PluginAdapterBase()
cannam@76: {
cannam@76:     delete m_impl;
cannam@3: }
cannam@3: 
cannam@3: const VampPluginDescriptor *
cannam@3: PluginAdapterBase::getDescriptor()
cannam@3: {
cannam@76:     return m_impl->getDescriptor();
cannam@76: }
cannam@76: 
cannam@76: PluginAdapterBase::Impl::Impl(PluginAdapterBase *base) :
cannam@76:     m_base(base),
cannam@76:     m_populated(false)
cannam@76: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl[" << this << "]::Impl" << std::endl;
cannam@76: #endif
cannam@76: }
cannam@76: 
cannam@76: const VampPluginDescriptor *
cannam@76: PluginAdapterBase::Impl::getDescriptor()
cannam@76: {
cannam@76: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl[" << this << "]::getDescriptor" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@3:     if (m_populated) return &m_descriptor;
cannam@3: 
cannam@76:     Plugin *plugin = m_base->createPlugin(48000);
cannam@3: 
cannam@50:     if (plugin->getVampApiVersion() != VAMP_API_VERSION) {
cannam@76:         std::cerr << "Vamp::PluginAdapterBase::Impl::getDescriptor: ERROR: "
cannam@50:                   << "Plugin object API version "
cannam@50:                   << plugin->getVampApiVersion()
cannam@50:                   << " does not match actual API version "
cannam@50:                   << VAMP_API_VERSION << std::endl;
cannam@50:         delete plugin;
cannam@50:         return 0;
cannam@50:     }
cannam@50: 
cannam@3:     m_parameters = plugin->getParameterDescriptors();
cannam@3:     m_programs = plugin->getPrograms();
cannam@50: 
cannam@50:     m_descriptor.vampApiVersion = plugin->getVampApiVersion();
cannam@49:     m_descriptor.identifier = strdup(plugin->getIdentifier().c_str());
cannam@3:     m_descriptor.name = strdup(plugin->getName().c_str());
cannam@3:     m_descriptor.description = strdup(plugin->getDescription().c_str());
cannam@3:     m_descriptor.maker = strdup(plugin->getMaker().c_str());
cannam@3:     m_descriptor.pluginVersion = plugin->getPluginVersion();
cannam@3:     m_descriptor.copyright = strdup(plugin->getCopyright().c_str());
cannam@3:     
cannam@3:     m_descriptor.parameterCount = m_parameters.size();
cannam@3:     m_descriptor.parameters = (const VampParameterDescriptor **)
cannam@3:         malloc(m_parameters.size() * sizeof(VampParameterDescriptor));
cannam@7: 
cannam@7:     unsigned int i;
cannam@3:     
cannam@7:     for (i = 0; i < m_parameters.size(); ++i) {
cannam@3:         VampParameterDescriptor *desc = (VampParameterDescriptor *)
cannam@3:             malloc(sizeof(VampParameterDescriptor));
cannam@49:         desc->identifier = strdup(m_parameters[i].identifier.c_str());
cannam@3:         desc->name = strdup(m_parameters[i].name.c_str());
cannam@3:         desc->description = strdup(m_parameters[i].description.c_str());
cannam@3:         desc->unit = strdup(m_parameters[i].unit.c_str());
cannam@3:         desc->minValue = m_parameters[i].minValue;
cannam@3:         desc->maxValue = m_parameters[i].maxValue;
cannam@3:         desc->defaultValue = m_parameters[i].defaultValue;
cannam@3:         desc->isQuantized = m_parameters[i].isQuantized;
cannam@3:         desc->quantizeStep = m_parameters[i].quantizeStep;
cannam@9:         desc->valueNames = 0;
cannam@9:         if (desc->isQuantized && !m_parameters[i].valueNames.empty()) {
cannam@9:             desc->valueNames = (const char **)
cannam@9:                 malloc((m_parameters[i].valueNames.size()+1) * sizeof(char *));
cannam@9:             for (unsigned int j = 0; j < m_parameters[i].valueNames.size(); ++j) {
cannam@9:                 desc->valueNames[j] = strdup(m_parameters[i].valueNames[j].c_str());
cannam@9:             }
cannam@9:             desc->valueNames[m_parameters[i].valueNames.size()] = 0;
cannam@9:         }
cannam@3:         m_descriptor.parameters[i] = desc;
cannam@3:     }
cannam@3:     
cannam@3:     m_descriptor.programCount = m_programs.size();
cannam@3:     m_descriptor.programs = (const char **)
cannam@3:         malloc(m_programs.size() * sizeof(const char *));
cannam@3:     
cannam@7:     for (i = 0; i < m_programs.size(); ++i) {
cannam@3:         m_descriptor.programs[i] = strdup(m_programs[i].c_str());
cannam@3:     }
cannam@3:     
cannam@3:     if (plugin->getInputDomain() == Plugin::FrequencyDomain) {
cannam@3:         m_descriptor.inputDomain = vampFrequencyDomain;
cannam@3:     } else {
cannam@3:         m_descriptor.inputDomain = vampTimeDomain;
cannam@3:     }
cannam@3: 
cannam@3:     m_descriptor.instantiate = vampInstantiate;
cannam@3:     m_descriptor.cleanup = vampCleanup;
cannam@3:     m_descriptor.initialise = vampInitialise;
cannam@3:     m_descriptor.reset = vampReset;
cannam@3:     m_descriptor.getParameter = vampGetParameter;
cannam@3:     m_descriptor.setParameter = vampSetParameter;
cannam@3:     m_descriptor.getCurrentProgram = vampGetCurrentProgram;
cannam@3:     m_descriptor.selectProgram = vampSelectProgram;
cannam@3:     m_descriptor.getPreferredStepSize = vampGetPreferredStepSize;
cannam@3:     m_descriptor.getPreferredBlockSize = vampGetPreferredBlockSize;
cannam@3:     m_descriptor.getMinChannelCount = vampGetMinChannelCount;
cannam@3:     m_descriptor.getMaxChannelCount = vampGetMaxChannelCount;
cannam@3:     m_descriptor.getOutputCount = vampGetOutputCount;
cannam@3:     m_descriptor.getOutputDescriptor = vampGetOutputDescriptor;
cannam@3:     m_descriptor.releaseOutputDescriptor = vampReleaseOutputDescriptor;
cannam@3:     m_descriptor.process = vampProcess;
cannam@3:     m_descriptor.getRemainingFeatures = vampGetRemainingFeatures;
cannam@3:     m_descriptor.releaseFeatureSet = vampReleaseFeatureSet;
cannam@3:     
cannam@13:     if (!m_adapterMap) {
cannam@13:         m_adapterMap = new AdapterMap;
cannam@13:     }
cannam@15:     (*m_adapterMap)[&m_descriptor] = this;
cannam@3: 
cannam@3:     delete plugin;
cannam@3: 
cannam@3:     m_populated = true;
cannam@3:     return &m_descriptor;
cannam@3: }
cannam@3: 
cannam@76: PluginAdapterBase::Impl::~Impl()
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl[" << this << "]::~Impl" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@3:     if (!m_populated) return;
cannam@3: 
cannam@49:     free((void *)m_descriptor.identifier);
cannam@3:     free((void *)m_descriptor.name);
cannam@3:     free((void *)m_descriptor.description);
cannam@3:     free((void *)m_descriptor.maker);
cannam@3:     free((void *)m_descriptor.copyright);
cannam@3:         
cannam@3:     for (unsigned int i = 0; i < m_descriptor.parameterCount; ++i) {
cannam@3:         const VampParameterDescriptor *desc = m_descriptor.parameters[i];
cannam@49:         free((void *)desc->identifier);
cannam@3:         free((void *)desc->name);
cannam@3:         free((void *)desc->description);
cannam@3:         free((void *)desc->unit);
cannam@9:         if (desc->valueNames) {
cannam@9:             for (unsigned int j = 0; desc->valueNames[j]; ++j) {
cannam@9:                 free((void *)desc->valueNames[j]);
cannam@9:             }
cannam@9:             free((void *)desc->valueNames);
cannam@9:         }
cannam@3:     }
cannam@3:     free((void *)m_descriptor.parameters);
cannam@3: 
cannam@3:     for (unsigned int i = 0; i < m_descriptor.programCount; ++i) {
cannam@3:         free((void *)m_descriptor.programs[i]);
cannam@3:     }
cannam@3:     free((void *)m_descriptor.programs);
cannam@3: 
cannam@13:     if (m_adapterMap) {
cannam@13:         
cannam@13:         m_adapterMap->erase(&m_descriptor);
cannam@13: 
cannam@13:         if (m_adapterMap->empty()) {
cannam@13:             delete m_adapterMap;
cannam@13:             m_adapterMap = 0;
cannam@13:         }
cannam@13:     }
cannam@3: }
cannam@3: 
cannam@76: PluginAdapterBase::Impl *
cannam@76: PluginAdapterBase::Impl::lookupAdapter(VampPluginHandle handle)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::lookupAdapter(" << handle << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@13:     if (!m_adapterMap) return 0;
cannam@13:     AdapterMap::const_iterator i = m_adapterMap->find(handle);
cannam@13:     if (i == m_adapterMap->end()) return 0;
cannam@3:     return i->second;
cannam@3: }
cannam@3: 
cannam@3: VampPluginHandle
cannam@76: PluginAdapterBase::Impl::vampInstantiate(const VampPluginDescriptor *desc,
cannam@3:                                    float inputSampleRate)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampInstantiate(" << desc << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@15:     if (!m_adapterMap) {
cannam@15:         m_adapterMap = new AdapterMap();
cannam@15:     }
cannam@15: 
cannam@15:     if (m_adapterMap->find(desc) == m_adapterMap->end()) {
cannam@76:         std::cerr << "WARNING: PluginAdapterBase::Impl::vampInstantiate: Descriptor " << desc << " not in adapter map" << std::endl;
cannam@15:         return 0;
cannam@15:     }
cannam@15: 
cannam@76:     Impl *adapter = (*m_adapterMap)[desc];
cannam@3:     if (desc != &adapter->m_descriptor) return 0;
cannam@3: 
cannam@76:     Plugin *plugin = adapter->m_base->createPlugin(inputSampleRate);
cannam@3:     if (plugin) {
cannam@13:         (*m_adapterMap)[plugin] = adapter;
cannam@3:     }
cannam@3: 
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampInstantiate(" << desc << "): returning handle " << plugin << std::endl;
cannam@22: #endif
cannam@22: 
cannam@3:     return plugin;
cannam@3: }
cannam@3: 
cannam@3: void
cannam@76: PluginAdapterBase::Impl::vampCleanup(VampPluginHandle handle)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampCleanup(" << handle << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@76:     Impl *adapter = lookupAdapter(handle);
cannam@3:     if (!adapter) {
cannam@3:         delete ((Plugin *)handle);
cannam@3:         return;
cannam@3:     }
cannam@3:     adapter->cleanup(((Plugin *)handle));
cannam@3: }
cannam@3: 
cannam@3: int
cannam@76: PluginAdapterBase::Impl::vampInitialise(VampPluginHandle handle,
cannam@3:                                   unsigned int channels,
cannam@3:                                   unsigned int stepSize,
cannam@3:                                   unsigned int blockSize)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampInitialise(" << handle << ", " << channels << ", " << stepSize << ", " << blockSize << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@3:     bool result = ((Plugin *)handle)->initialise
cannam@3:         (channels, stepSize, blockSize);
cannam@3:     return result ? 1 : 0;
cannam@3: }
cannam@3: 
cannam@3: void
cannam@76: PluginAdapterBase::Impl::vampReset(VampPluginHandle handle) 
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampReset(" << handle << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@3:     ((Plugin *)handle)->reset();
cannam@3: }
cannam@3: 
cannam@3: float
cannam@76: PluginAdapterBase::Impl::vampGetParameter(VampPluginHandle handle,
cannam@3:                                     int param) 
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampGetParameter(" << handle << ", " << param << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@76:     Impl *adapter = lookupAdapter(handle);
cannam@3:     if (!adapter) return 0.0;
cannam@3:     Plugin::ParameterList &list = adapter->m_parameters;
cannam@49:     return ((Plugin *)handle)->getParameter(list[param].identifier);
cannam@3: }
cannam@3: 
cannam@3: void
cannam@76: PluginAdapterBase::Impl::vampSetParameter(VampPluginHandle handle,
cannam@3:                                     int param, float value)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampSetParameter(" << handle << ", " << param << ", " << value << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@76:     Impl *adapter = lookupAdapter(handle);
cannam@3:     if (!adapter) return;
cannam@3:     Plugin::ParameterList &list = adapter->m_parameters;
cannam@49:     ((Plugin *)handle)->setParameter(list[param].identifier, value);
cannam@3: }
cannam@3: 
cannam@3: unsigned int
cannam@76: PluginAdapterBase::Impl::vampGetCurrentProgram(VampPluginHandle handle)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampGetCurrentProgram(" << handle << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@76:     Impl *adapter = lookupAdapter(handle);
cannam@3:     if (!adapter) return 0;
cannam@3:     Plugin::ProgramList &list = adapter->m_programs;
cannam@3:     std::string program = ((Plugin *)handle)->getCurrentProgram();
cannam@3:     for (unsigned int i = 0; i < list.size(); ++i) {
cannam@3:         if (list[i] == program) return i;
cannam@3:     }
cannam@3:     return 0;
cannam@3: }
cannam@3: 
cannam@3: void
cannam@76: PluginAdapterBase::Impl::vampSelectProgram(VampPluginHandle handle,
cannam@3:                                      unsigned int program)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampSelectProgram(" << handle << ", " << program << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@76:     Impl *adapter = lookupAdapter(handle);
cannam@3:     if (!adapter) return;
cannam@3:     Plugin::ProgramList &list = adapter->m_programs;
cannam@3:     ((Plugin *)handle)->selectProgram(list[program]);
cannam@3: }
cannam@3: 
cannam@3: unsigned int
cannam@76: PluginAdapterBase::Impl::vampGetPreferredStepSize(VampPluginHandle handle)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampGetPreferredStepSize(" << handle << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@3:     return ((Plugin *)handle)->getPreferredStepSize();
cannam@3: }
cannam@3: 
cannam@3: unsigned int
cannam@76: PluginAdapterBase::Impl::vampGetPreferredBlockSize(VampPluginHandle handle) 
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampGetPreferredBlockSize(" << handle << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@3:     return ((Plugin *)handle)->getPreferredBlockSize();
cannam@3: }
cannam@3: 
cannam@3: unsigned int
cannam@76: PluginAdapterBase::Impl::vampGetMinChannelCount(VampPluginHandle handle)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampGetMinChannelCount(" << handle << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@3:     return ((Plugin *)handle)->getMinChannelCount();
cannam@3: }
cannam@3: 
cannam@3: unsigned int
cannam@76: PluginAdapterBase::Impl::vampGetMaxChannelCount(VampPluginHandle handle)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampGetMaxChannelCount(" << handle << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@3:     return ((Plugin *)handle)->getMaxChannelCount();
cannam@3: }
cannam@3: 
cannam@3: unsigned int
cannam@76: PluginAdapterBase::Impl::vampGetOutputCount(VampPluginHandle handle)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampGetOutputCount(" << handle << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@76:     Impl *adapter = lookupAdapter(handle);
cannam@15: 
cannam@15: //    std::cerr << "vampGetOutputCount: handle " << handle << " -> adapter "<< adapter << std::endl;
cannam@15: 
cannam@3:     if (!adapter) return 0;
cannam@3:     return adapter->getOutputCount((Plugin *)handle);
cannam@3: }
cannam@3: 
cannam@3: VampOutputDescriptor *
cannam@76: PluginAdapterBase::Impl::vampGetOutputDescriptor(VampPluginHandle handle,
cannam@3:                                            unsigned int i)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampGetOutputDescriptor(" << handle << ", " << i << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@76:     Impl *adapter = lookupAdapter(handle);
cannam@15: 
cannam@15: //    std::cerr << "vampGetOutputDescriptor: handle " << handle << " -> adapter "<< adapter << std::endl;
cannam@15: 
cannam@3:     if (!adapter) return 0;
cannam@3:     return adapter->getOutputDescriptor((Plugin *)handle, i);
cannam@3: }
cannam@3: 
cannam@3: void
cannam@76: PluginAdapterBase::Impl::vampReleaseOutputDescriptor(VampOutputDescriptor *desc)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampReleaseOutputDescriptor(" << desc << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@49:     if (desc->identifier) free((void *)desc->identifier);
cannam@3:     if (desc->name) free((void *)desc->name);
cannam@3:     if (desc->description) free((void *)desc->description);
cannam@3:     if (desc->unit) free((void *)desc->unit);
cannam@40:     if (desc->hasFixedBinCount && desc->binNames) {
cannam@40:         for (unsigned int i = 0; i < desc->binCount; ++i) {
cannam@40:             if (desc->binNames[i]) {
cannam@40:                 free((void *)desc->binNames[i]);
cannam@40:             }
cannam@40:         }
cannam@3:     }
cannam@9:     if (desc->binNames) free((void *)desc->binNames);
cannam@3:     free((void *)desc);
cannam@3: }
cannam@3: 
cannam@12: VampFeatureList *
cannam@76: PluginAdapterBase::Impl::vampProcess(VampPluginHandle handle,
cannam@108:                                      const float *const *inputBuffers,
cannam@108:                                      int sec,
cannam@108:                                      int nsec)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampProcess(" << handle << ", " << sec << ", " << nsec << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@76:     Impl *adapter = lookupAdapter(handle);
cannam@3:     if (!adapter) return 0;
cannam@3:     return adapter->process((Plugin *)handle,
cannam@3:                             inputBuffers, sec, nsec);
cannam@3: }
cannam@3: 
cannam@12: VampFeatureList *
cannam@76: PluginAdapterBase::Impl::vampGetRemainingFeatures(VampPluginHandle handle)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampGetRemainingFeatures(" << handle << ")" << std::endl;
cannam@22: #endif
cannam@22: 
cannam@76:     Impl *adapter = lookupAdapter(handle);
cannam@3:     if (!adapter) return 0;
cannam@3:     return adapter->getRemainingFeatures((Plugin *)handle);
cannam@3: }
cannam@3: 
cannam@3: void
cannam@76: PluginAdapterBase::Impl::vampReleaseFeatureSet(VampFeatureList *fs)
cannam@3: {
cannam@22: #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76:     std::cerr << "PluginAdapterBase::Impl::vampReleaseFeatureSet" << std::endl;
cannam@22: #endif
cannam@3: }
cannam@3: 
cannam@3: void 
cannam@76: PluginAdapterBase::Impl::cleanup(Plugin *plugin)
cannam@3: {
cannam@12:     if (m_fs.find(plugin) != m_fs.end()) {
cannam@12:         size_t outputCount = 0;
cannam@12:         if (m_pluginOutputs[plugin]) {
cannam@12:             outputCount = m_pluginOutputs[plugin]->size();
cannam@12:         }
cannam@12:         VampFeatureList *list = m_fs[plugin];
cannam@12:         for (unsigned int i = 0; i < outputCount; ++i) {
cannam@12:             for (unsigned int j = 0; j < m_fsizes[plugin][i]; ++j) {
cannam@168:                 if (list[i].features[j].v1.label) {
cannam@168:                     free(list[i].features[j].v1.label);
cannam@12:                 }
cannam@168:                 if (list[i].features[j].v1.values) {
cannam@168:                     free(list[i].features[j].v1.values);
cannam@12:                 }
cannam@12:             }
cannam@12:             if (list[i].features) free(list[i].features);
cannam@12:         }
cannam@12:         m_fs.erase(plugin);
cannam@12:         m_fsizes.erase(plugin);
cannam@12:         m_fvsizes.erase(plugin);
cannam@12:     }
cannam@12: 
cannam@3:     if (m_pluginOutputs.find(plugin) != m_pluginOutputs.end()) {
cannam@3:         delete m_pluginOutputs[plugin];
cannam@3:         m_pluginOutputs.erase(plugin);
cannam@3:     }
cannam@13: 
cannam@13:     if (m_adapterMap) {
cannam@13:         m_adapterMap->erase(plugin);
cannam@13: 
cannam@13:         if (m_adapterMap->empty()) {
cannam@13:             delete m_adapterMap;
cannam@13:             m_adapterMap = 0;
cannam@13:         }
cannam@13:     }
cannam@13: 
cannam@3:     delete ((Plugin *)plugin);
cannam@3: }
cannam@3: 
cannam@3: void 
cannam@76: PluginAdapterBase::Impl::checkOutputMap(Plugin *plugin)
cannam@3: {
cannam@15:     if (m_pluginOutputs.find(plugin) == m_pluginOutputs.end() ||
cannam@15:         !m_pluginOutputs[plugin]) {
cannam@3:         m_pluginOutputs[plugin] = new Plugin::OutputList
cannam@3:             (plugin->getOutputDescriptors());
cannam@76: //        std::cerr << "PluginAdapterBase::Impl::checkOutputMap: Have " << m_pluginOutputs[plugin]->size() << " outputs for plugin " << plugin->getIdentifier() << std::endl;
cannam@3:     }
cannam@3: }
cannam@3: 
cannam@3: unsigned int 
cannam@76: PluginAdapterBase::Impl::getOutputCount(Plugin *plugin)
cannam@3: {
cannam@3:     checkOutputMap(plugin);
cannam@3:     return m_pluginOutputs[plugin]->size();
cannam@3: }
cannam@3: 
cannam@3: VampOutputDescriptor *
cannam@76: PluginAdapterBase::Impl::getOutputDescriptor(Plugin *plugin,
cannam@3:                                        unsigned int i)
cannam@3: {
cannam@3:     checkOutputMap(plugin);
cannam@3:     Plugin::OutputDescriptor &od =
cannam@3:         (*m_pluginOutputs[plugin])[i];
cannam@3: 
cannam@3:     VampOutputDescriptor *desc = (VampOutputDescriptor *)
cannam@3:         malloc(sizeof(VampOutputDescriptor));
cannam@3: 
cannam@49:     desc->identifier = strdup(od.identifier.c_str());
cannam@3:     desc->name = strdup(od.name.c_str());
cannam@3:     desc->description = strdup(od.description.c_str());
cannam@3:     desc->unit = strdup(od.unit.c_str());
cannam@9:     desc->hasFixedBinCount = od.hasFixedBinCount;
cannam@9:     desc->binCount = od.binCount;
cannam@3: 
cannam@9:     if (od.hasFixedBinCount && od.binCount > 0) {
cannam@9:         desc->binNames = (const char **)
cannam@9:             malloc(od.binCount * sizeof(const char *));
cannam@3:         
cannam@9:         for (unsigned int i = 0; i < od.binCount; ++i) {
cannam@9:             if (i < od.binNames.size()) {
cannam@9:                 desc->binNames[i] = strdup(od.binNames[i].c_str());
cannam@7:             } else {
cannam@9:                 desc->binNames[i] = 0;
cannam@7:             }
cannam@3:         }
cannam@7:     } else {
cannam@9:         desc->binNames = 0;
cannam@3:     }
cannam@3: 
cannam@3:     desc->hasKnownExtents = od.hasKnownExtents;
cannam@3:     desc->minValue = od.minValue;
cannam@3:     desc->maxValue = od.maxValue;
cannam@3:     desc->isQuantized = od.isQuantized;
cannam@3:     desc->quantizeStep = od.quantizeStep;
cannam@3: 
cannam@3:     switch (od.sampleType) {
cannam@3:     case Plugin::OutputDescriptor::OneSamplePerStep:
cannam@3:         desc->sampleType = vampOneSamplePerStep; break;
cannam@3:     case Plugin::OutputDescriptor::FixedSampleRate:
cannam@3:         desc->sampleType = vampFixedSampleRate; break;
cannam@3:     case Plugin::OutputDescriptor::VariableSampleRate:
cannam@3:         desc->sampleType = vampVariableSampleRate; break;
cannam@3:     }
cannam@3: 
cannam@3:     desc->sampleRate = od.sampleRate;
cannam@3: 
cannam@3:     return desc;
cannam@3: }
cannam@3:     
cannam@12: VampFeatureList *
cannam@76: PluginAdapterBase::Impl::process(Plugin *plugin,
cannam@108:                                  const float *const *inputBuffers,
cannam@108:                                  int sec, int nsec)
cannam@3: {
cannam@76: //    std::cerr << "PluginAdapterBase::Impl::process" << std::endl;
cannam@3:     RealTime rt(sec, nsec);
cannam@12:     checkOutputMap(plugin);
cannam@12:     return convertFeatures(plugin, plugin->process(inputBuffers, rt));
cannam@3: }
cannam@3:     
cannam@12: VampFeatureList *
cannam@76: PluginAdapterBase::Impl::getRemainingFeatures(Plugin *plugin)
cannam@3: {
cannam@76: //    std::cerr << "PluginAdapterBase::Impl::getRemainingFeatures" << std::endl;
cannam@12:     checkOutputMap(plugin);
cannam@12:     return convertFeatures(plugin, plugin->getRemainingFeatures());
cannam@3: }
cannam@3: 
cannam@12: VampFeatureList *
cannam@76: PluginAdapterBase::Impl::convertFeatures(Plugin *plugin,
cannam@167:                                          const Plugin::FeatureSet &features)
cannam@3: {
cannam@12:     int lastN = -1;
cannam@3: 
cannam@12:     int outputCount = 0;
cannam@12:     if (m_pluginOutputs[plugin]) outputCount = m_pluginOutputs[plugin]->size();
cannam@12:     
cannam@12:     resizeFS(plugin, outputCount);
cannam@12:     VampFeatureList *fs = m_fs[plugin];
cannam@3: 
cannam@168: //    std::cerr << "PluginAdapter(v2)::convertFeatures: NOTE: sizeof(Feature) == " << sizeof(Plugin::Feature) << ", sizeof(VampFeature) == " << sizeof(VampFeature) << ", sizeof(VampFeatureList) == " << sizeof(VampFeatureList) << std::endl;
cannam@168: 
cannam@12:     for (Plugin::FeatureSet::const_iterator fi = features.begin();
cannam@12:          fi != features.end(); ++fi) {
cannam@3: 
cannam@12:         int n = fi->first;
cannam@12:         
cannam@76: //        std::cerr << "PluginAdapterBase::Impl::convertFeatures: n = " << n << std::endl;
cannam@7: 
cannam@12:         if (n >= int(outputCount)) {
cannam@76:             std::cerr << "WARNING: PluginAdapterBase::Impl::convertFeatures: Too many outputs from plugin (" << n+1 << ", only should be " << outputCount << ")" << std::endl;
cannam@7:             continue;
cannam@7:         }
cannam@7: 
cannam@12:         if (n > lastN + 1) {
cannam@12:             for (int i = lastN + 1; i < n; ++i) {
cannam@12:                 fs[i].featureCount = 0;
cannam@12:             }
cannam@12:         }
cannam@7: 
cannam@7:         const Plugin::FeatureList &fl = fi->second;
cannam@7: 
cannam@12:         size_t sz = fl.size();
cannam@12:         if (sz > m_fsizes[plugin][n]) resizeFL(plugin, n, sz);
cannam@12:         fs[n].featureCount = sz;
cannam@12:         
cannam@12:         for (size_t j = 0; j < sz; ++j) {
cannam@7: 
cannam@76: //            std::cerr << "PluginAdapterBase::Impl::convertFeatures: j = " << j << std::endl;
cannam@7: 
cannam@168:             VampFeature *feature = &fs[n].features[j].v1;
cannam@7: 
cannam@7:             feature->hasTimestamp = fl[j].hasTimestamp;
cannam@7:             feature->sec = fl[j].timestamp.sec;
cannam@7:             feature->nsec = fl[j].timestamp.nsec;
cannam@7:             feature->valueCount = fl[j].values.size();
cannam@7: 
cannam@168:             VampFeatureV2 *v2 = &fs[n].features[j + sz].v2;
cannam@167:             
cannam@167:             v2->hasDuration = fl[j].hasDuration;
cannam@167:             v2->durationSec = fl[j].duration.sec;
cannam@167:             v2->durationNsec = fl[j].duration.nsec;
cannam@167: 
cannam@12:             if (feature->label) free(feature->label);
cannam@12: 
cannam@12:             if (fl[j].label.empty()) {
cannam@12:                 feature->label = 0;
cannam@12:             } else {
cannam@12:                 feature->label = strdup(fl[j].label.c_str());
cannam@7:             }
cannam@7: 
cannam@12:             if (feature->valueCount > m_fvsizes[plugin][n][j]) {
cannam@12:                 resizeFV(plugin, n, j, feature->valueCount);
cannam@12:             }
cannam@7: 
cannam@7:             for (unsigned int k = 0; k < feature->valueCount; ++k) {
cannam@76: //                std::cerr << "PluginAdapterBase::Impl::convertFeatures: k = " << k << std::endl;
cannam@7:                 feature->values[k] = fl[j].values[k];
cannam@3:             }
cannam@3:         }
cannam@12: 
cannam@12:         lastN = n;
cannam@3:     }
cannam@3: 
cannam@12:     if (lastN == -1) return 0;
cannam@12: 
cannam@12:     if (int(outputCount) > lastN + 1) {
cannam@12:         for (int i = lastN + 1; i < int(outputCount); ++i) {
cannam@12:             fs[i].featureCount = 0;
cannam@12:         }
cannam@12:     }
cannam@3: 
cannam@168: //    std::cerr << "PluginAdapter(v2)::convertFeatures: NOTE: have " << outputCount << " outputs" << std::endl;
cannam@168: //    for (int i = 0; i < outputCount; ++i) {
cannam@168: //        std::cerr << "PluginAdapter(v2)::convertFeatures: NOTE: output " << i << " has " << fs[i].featureCount << " features" << std::endl;
cannam@168: //    }
cannam@168: 
cannam@168: 
cannam@3:     return fs;
cannam@3: }
cannam@3: 
cannam@12: void
cannam@76: PluginAdapterBase::Impl::resizeFS(Plugin *plugin, int n)
cannam@12: {
cannam@76: //    std::cerr << "PluginAdapterBase::Impl::resizeFS(" << plugin << ", " << n << ")" << std::endl;
cannam@12: 
cannam@12:     int i = m_fsizes[plugin].size();
cannam@12:     if (i >= n) return;
cannam@12: 
cannam@16: //    std::cerr << "resizing from " << i << std::endl;
cannam@12: 
cannam@12:     m_fs[plugin] = (VampFeatureList *)realloc
cannam@12:         (m_fs[plugin], n * sizeof(VampFeatureList));
cannam@12: 
cannam@12:     while (i < n) {
cannam@12:         m_fs[plugin][i].featureCount = 0;
cannam@12:         m_fs[plugin][i].features = 0;
cannam@12:         m_fsizes[plugin].push_back(0);
cannam@12:         m_fvsizes[plugin].push_back(std::vector<size_t>());
cannam@12:         i++;
cannam@12:     }
cannam@12: }
cannam@12: 
cannam@12: void
cannam@76: PluginAdapterBase::Impl::resizeFL(Plugin *plugin, int n, size_t sz)
cannam@12: {
cannam@76: //    std::cerr << "PluginAdapterBase::Impl::resizeFL(" << plugin << ", " << n << ", "
cannam@16: //              << sz << ")" << std::endl;
cannam@12: 
cannam@12:     size_t i = m_fsizes[plugin][n];
cannam@12:     if (i >= sz) return;
cannam@12: 
cannam@16: //    std::cerr << "resizing from " << i << std::endl;
cannam@12: 
cannam@168:     m_fs[plugin][n].features = (VampFeatureUnion *)realloc
cannam@168:         (m_fs[plugin][n].features, 2 * sz * sizeof(VampFeatureUnion));
cannam@167: 
cannam@12:     while (m_fsizes[plugin][n] < sz) {
cannam@168:         m_fs[plugin][n].features[m_fsizes[plugin][n]].v1.hasTimestamp = 0;
cannam@168:         m_fs[plugin][n].features[m_fsizes[plugin][n]].v1.valueCount = 0;
cannam@168:         m_fs[plugin][n].features[m_fsizes[plugin][n]].v1.values = 0;
cannam@168:         m_fs[plugin][n].features[m_fsizes[plugin][n]].v1.label = 0;
cannam@168:         m_fs[plugin][n].features[m_fsizes[plugin][n + sz]].v2.hasDuration = 0;
cannam@12:         m_fvsizes[plugin][n].push_back(0);
cannam@12:         m_fsizes[plugin][n]++;
cannam@12:     }
cannam@12: }
cannam@12: 
cannam@12: void
cannam@76: PluginAdapterBase::Impl::resizeFV(Plugin *plugin, int n, int j, size_t sz)
cannam@12: {
cannam@76: //    std::cerr << "PluginAdapterBase::Impl::resizeFV(" << plugin << ", " << n << ", "
cannam@16: //              << j << ", " << sz << ")" << std::endl;
cannam@12: 
cannam@12:     size_t i = m_fvsizes[plugin][n][j];
cannam@12:     if (i >= sz) return;
cannam@12: 
cannam@16: //    std::cerr << "resizing from " << i << std::endl;
cannam@12: 
cannam@168:     m_fs[plugin][n].features[j].v1.values = (float *)realloc
cannam@168:         (m_fs[plugin][n].features[j].v1.values, sz * sizeof(float));
cannam@12: 
cannam@12:     m_fvsizes[plugin][n][j] = sz;
cannam@12: }
cannam@12:   
cannam@76: PluginAdapterBase::Impl::AdapterMap *
cannam@76: PluginAdapterBase::Impl::m_adapterMap = 0;
cannam@3: 
cannam@3: }
cannam@3: