annotate src/vamp-sdk/PluginAdapter.cpp @ 230:5ee166dccfff distinct-libraries

* Add include guards; make code compile!
author cannam
date Fri, 07 Nov 2008 14:11:39 +0000
parents 6b30e064cab7
children 521734d2b498
rev   line source
cannam@3 1 /* -*- c-basic-offset: 4 indent-tabs-mode: nil -*- vi:set ts=8 sts=4 sw=4: */
cannam@3 2
cannam@3 3 /*
cannam@3 4 Vamp
cannam@3 5
cannam@3 6 An API for audio analysis and feature extraction plugins.
cannam@3 7
cannam@3 8 Centre for Digital Music, Queen Mary, University of London.
cannam@3 9 Copyright 2006 Chris Cannam.
cannam@3 10
cannam@3 11 Permission is hereby granted, free of charge, to any person
cannam@3 12 obtaining a copy of this software and associated documentation
cannam@3 13 files (the "Software"), to deal in the Software without
cannam@3 14 restriction, including without limitation the rights to use, copy,
cannam@3 15 modify, merge, publish, distribute, sublicense, and/or sell copies
cannam@3 16 of the Software, and to permit persons to whom the Software is
cannam@3 17 furnished to do so, subject to the following conditions:
cannam@3 18
cannam@3 19 The above copyright notice and this permission notice shall be
cannam@3 20 included in all copies or substantial portions of the Software.
cannam@3 21
cannam@3 22 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
cannam@3 23 EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
cannam@3 24 MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
cannam@6 25 NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS BE LIABLE FOR
cannam@3 26 ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF
cannam@3 27 CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
cannam@3 28 WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
cannam@3 29
cannam@3 30 Except as contained in this notice, the names of the Centre for
cannam@3 31 Digital Music; Queen Mary, University of London; and Chris Cannam
cannam@3 32 shall not be used in advertising or otherwise to promote the sale,
cannam@3 33 use or other dealings in this Software without prior written
cannam@3 34 authorization.
cannam@3 35 */
cannam@3 36
cannam@230 37 #include <vamp-sdk/PluginAdapter.h>
cannam@3 38
cannam@130 39 #include <cstring>
cannam@130 40 #include <cstdlib>
cannam@130 41
cannam@23 42 //#define DEBUG_PLUGIN_ADAPTER 1
cannam@22 43
cannam@230 44 namespace _VampPlugin {
cannam@230 45
cannam@3 46 namespace Vamp {
cannam@3 47
cannam@76 48 class PluginAdapterBase::Impl
cannam@3 49 {
cannam@76 50 public:
cannam@76 51 Impl(PluginAdapterBase *);
cannam@76 52 ~Impl();
cannam@76 53
cannam@76 54 const VampPluginDescriptor *getDescriptor();
cannam@76 55
cannam@76 56 protected:
cannam@76 57 PluginAdapterBase *m_base;
cannam@76 58
cannam@76 59 static VampPluginHandle vampInstantiate(const VampPluginDescriptor *desc,
cannam@167 60 float inputSampleRate);
cannam@76 61
cannam@76 62 static void vampCleanup(VampPluginHandle handle);
cannam@76 63
cannam@76 64 static int vampInitialise(VampPluginHandle handle, unsigned int channels,
cannam@76 65 unsigned int stepSize, unsigned int blockSize);
cannam@76 66
cannam@76 67 static void vampReset(VampPluginHandle handle);
cannam@76 68
cannam@76 69 static float vampGetParameter(VampPluginHandle handle, int param);
cannam@76 70 static void vampSetParameter(VampPluginHandle handle, int param, float value);
cannam@76 71
cannam@76 72 static unsigned int vampGetCurrentProgram(VampPluginHandle handle);
cannam@76 73 static void vampSelectProgram(VampPluginHandle handle, unsigned int program);
cannam@76 74
cannam@76 75 static unsigned int vampGetPreferredStepSize(VampPluginHandle handle);
cannam@76 76 static unsigned int vampGetPreferredBlockSize(VampPluginHandle handle);
cannam@76 77 static unsigned int vampGetMinChannelCount(VampPluginHandle handle);
cannam@76 78 static unsigned int vampGetMaxChannelCount(VampPluginHandle handle);
cannam@76 79
cannam@76 80 static unsigned int vampGetOutputCount(VampPluginHandle handle);
cannam@76 81
cannam@76 82 static VampOutputDescriptor *vampGetOutputDescriptor(VampPluginHandle handle,
cannam@76 83 unsigned int i);
cannam@76 84
cannam@76 85 static void vampReleaseOutputDescriptor(VampOutputDescriptor *desc);
cannam@76 86
cannam@76 87 static VampFeatureList *vampProcess(VampPluginHandle handle,
cannam@76 88 const float *const *inputBuffers,
cannam@76 89 int sec,
cannam@76 90 int nsec);
cannam@76 91
cannam@76 92 static VampFeatureList *vampGetRemainingFeatures(VampPluginHandle handle);
cannam@76 93
cannam@76 94 static void vampReleaseFeatureSet(VampFeatureList *fs);
cannam@76 95
cannam@76 96 void cleanup(Plugin *plugin);
cannam@76 97 void checkOutputMap(Plugin *plugin);
cannam@76 98 unsigned int getOutputCount(Plugin *plugin);
cannam@76 99 VampOutputDescriptor *getOutputDescriptor(Plugin *plugin,
cannam@76 100 unsigned int i);
cannam@76 101 VampFeatureList *process(Plugin *plugin,
cannam@76 102 const float *const *inputBuffers,
cannam@76 103 int sec, int nsec);
cannam@76 104 VampFeatureList *getRemainingFeatures(Plugin *plugin);
cannam@76 105 VampFeatureList *convertFeatures(Plugin *plugin,
cannam@76 106 const Plugin::FeatureSet &features);
cannam@76 107
cannam@76 108 // maps both plugins and descriptors to adapters
cannam@76 109 typedef std::map<const void *, Impl *> AdapterMap;
cannam@76 110 static AdapterMap *m_adapterMap;
cannam@76 111 static Impl *lookupAdapter(VampPluginHandle);
cannam@76 112
cannam@76 113 bool m_populated;
cannam@76 114 VampPluginDescriptor m_descriptor;
cannam@76 115 Plugin::ParameterList m_parameters;
cannam@76 116 Plugin::ProgramList m_programs;
cannam@76 117
cannam@76 118 typedef std::map<Plugin *, Plugin::OutputList *> OutputMap;
cannam@76 119 OutputMap m_pluginOutputs;
cannam@76 120
cannam@76 121 std::map<Plugin *, VampFeatureList *> m_fs;
cannam@76 122 std::map<Plugin *, std::vector<size_t> > m_fsizes;
cannam@76 123 std::map<Plugin *, std::vector<std::vector<size_t> > > m_fvsizes;
cannam@76 124 void resizeFS(Plugin *plugin, int n);
cannam@76 125 void resizeFL(Plugin *plugin, int n, size_t sz);
cannam@76 126 void resizeFV(Plugin *plugin, int n, int j, size_t sz);
cannam@76 127 };
cannam@76 128
cannam@76 129 PluginAdapterBase::PluginAdapterBase()
cannam@76 130 {
cannam@76 131 m_impl = new Impl(this);
cannam@76 132 }
cannam@76 133
cannam@76 134 PluginAdapterBase::~PluginAdapterBase()
cannam@76 135 {
cannam@76 136 delete m_impl;
cannam@3 137 }
cannam@3 138
cannam@3 139 const VampPluginDescriptor *
cannam@3 140 PluginAdapterBase::getDescriptor()
cannam@3 141 {
cannam@76 142 return m_impl->getDescriptor();
cannam@76 143 }
cannam@76 144
cannam@76 145 PluginAdapterBase::Impl::Impl(PluginAdapterBase *base) :
cannam@76 146 m_base(base),
cannam@76 147 m_populated(false)
cannam@76 148 {
cannam@22 149 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 150 std::cerr << "PluginAdapterBase::Impl[" << this << "]::Impl" << std::endl;
cannam@76 151 #endif
cannam@76 152 }
cannam@76 153
cannam@76 154 const VampPluginDescriptor *
cannam@76 155 PluginAdapterBase::Impl::getDescriptor()
cannam@76 156 {
cannam@76 157 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 158 std::cerr << "PluginAdapterBase::Impl[" << this << "]::getDescriptor" << std::endl;
cannam@22 159 #endif
cannam@22 160
cannam@3 161 if (m_populated) return &m_descriptor;
cannam@3 162
cannam@76 163 Plugin *plugin = m_base->createPlugin(48000);
cannam@3 164
cannam@50 165 if (plugin->getVampApiVersion() != VAMP_API_VERSION) {
cannam@76 166 std::cerr << "Vamp::PluginAdapterBase::Impl::getDescriptor: ERROR: "
cannam@194 167 << "API version " << plugin->getVampApiVersion()
cannam@194 168 << " for\nplugin \"" << plugin->getIdentifier() << "\" "
cannam@194 169 << "differs from version "
cannam@194 170 << VAMP_API_VERSION << " for adapter.\n"
cannam@194 171 << "This plugin is probably linked against a different version of the Vamp SDK\n"
cannam@194 172 << "from the version it was compiled with. It will need to be re-linked correctly\n"
cannam@194 173 << "before it can be used." << std::endl;
cannam@50 174 delete plugin;
cannam@50 175 return 0;
cannam@50 176 }
cannam@50 177
cannam@3 178 m_parameters = plugin->getParameterDescriptors();
cannam@3 179 m_programs = plugin->getPrograms();
cannam@50 180
cannam@50 181 m_descriptor.vampApiVersion = plugin->getVampApiVersion();
cannam@49 182 m_descriptor.identifier = strdup(plugin->getIdentifier().c_str());
cannam@3 183 m_descriptor.name = strdup(plugin->getName().c_str());
cannam@3 184 m_descriptor.description = strdup(plugin->getDescription().c_str());
cannam@3 185 m_descriptor.maker = strdup(plugin->getMaker().c_str());
cannam@3 186 m_descriptor.pluginVersion = plugin->getPluginVersion();
cannam@3 187 m_descriptor.copyright = strdup(plugin->getCopyright().c_str());
cannam@3 188
cannam@3 189 m_descriptor.parameterCount = m_parameters.size();
cannam@3 190 m_descriptor.parameters = (const VampParameterDescriptor **)
cannam@3 191 malloc(m_parameters.size() * sizeof(VampParameterDescriptor));
cannam@7 192
cannam@7 193 unsigned int i;
cannam@3 194
cannam@7 195 for (i = 0; i < m_parameters.size(); ++i) {
cannam@3 196 VampParameterDescriptor *desc = (VampParameterDescriptor *)
cannam@3 197 malloc(sizeof(VampParameterDescriptor));
cannam@49 198 desc->identifier = strdup(m_parameters[i].identifier.c_str());
cannam@3 199 desc->name = strdup(m_parameters[i].name.c_str());
cannam@3 200 desc->description = strdup(m_parameters[i].description.c_str());
cannam@3 201 desc->unit = strdup(m_parameters[i].unit.c_str());
cannam@3 202 desc->minValue = m_parameters[i].minValue;
cannam@3 203 desc->maxValue = m_parameters[i].maxValue;
cannam@3 204 desc->defaultValue = m_parameters[i].defaultValue;
cannam@3 205 desc->isQuantized = m_parameters[i].isQuantized;
cannam@3 206 desc->quantizeStep = m_parameters[i].quantizeStep;
cannam@9 207 desc->valueNames = 0;
cannam@9 208 if (desc->isQuantized && !m_parameters[i].valueNames.empty()) {
cannam@9 209 desc->valueNames = (const char **)
cannam@9 210 malloc((m_parameters[i].valueNames.size()+1) * sizeof(char *));
cannam@9 211 for (unsigned int j = 0; j < m_parameters[i].valueNames.size(); ++j) {
cannam@9 212 desc->valueNames[j] = strdup(m_parameters[i].valueNames[j].c_str());
cannam@9 213 }
cannam@9 214 desc->valueNames[m_parameters[i].valueNames.size()] = 0;
cannam@9 215 }
cannam@3 216 m_descriptor.parameters[i] = desc;
cannam@3 217 }
cannam@3 218
cannam@3 219 m_descriptor.programCount = m_programs.size();
cannam@3 220 m_descriptor.programs = (const char **)
cannam@3 221 malloc(m_programs.size() * sizeof(const char *));
cannam@3 222
cannam@7 223 for (i = 0; i < m_programs.size(); ++i) {
cannam@3 224 m_descriptor.programs[i] = strdup(m_programs[i].c_str());
cannam@3 225 }
cannam@3 226
cannam@3 227 if (plugin->getInputDomain() == Plugin::FrequencyDomain) {
cannam@3 228 m_descriptor.inputDomain = vampFrequencyDomain;
cannam@3 229 } else {
cannam@3 230 m_descriptor.inputDomain = vampTimeDomain;
cannam@3 231 }
cannam@3 232
cannam@3 233 m_descriptor.instantiate = vampInstantiate;
cannam@3 234 m_descriptor.cleanup = vampCleanup;
cannam@3 235 m_descriptor.initialise = vampInitialise;
cannam@3 236 m_descriptor.reset = vampReset;
cannam@3 237 m_descriptor.getParameter = vampGetParameter;
cannam@3 238 m_descriptor.setParameter = vampSetParameter;
cannam@3 239 m_descriptor.getCurrentProgram = vampGetCurrentProgram;
cannam@3 240 m_descriptor.selectProgram = vampSelectProgram;
cannam@3 241 m_descriptor.getPreferredStepSize = vampGetPreferredStepSize;
cannam@3 242 m_descriptor.getPreferredBlockSize = vampGetPreferredBlockSize;
cannam@3 243 m_descriptor.getMinChannelCount = vampGetMinChannelCount;
cannam@3 244 m_descriptor.getMaxChannelCount = vampGetMaxChannelCount;
cannam@3 245 m_descriptor.getOutputCount = vampGetOutputCount;
cannam@3 246 m_descriptor.getOutputDescriptor = vampGetOutputDescriptor;
cannam@3 247 m_descriptor.releaseOutputDescriptor = vampReleaseOutputDescriptor;
cannam@3 248 m_descriptor.process = vampProcess;
cannam@3 249 m_descriptor.getRemainingFeatures = vampGetRemainingFeatures;
cannam@3 250 m_descriptor.releaseFeatureSet = vampReleaseFeatureSet;
cannam@3 251
cannam@13 252 if (!m_adapterMap) {
cannam@13 253 m_adapterMap = new AdapterMap;
cannam@13 254 }
cannam@15 255 (*m_adapterMap)[&m_descriptor] = this;
cannam@3 256
cannam@3 257 delete plugin;
cannam@3 258
cannam@3 259 m_populated = true;
cannam@3 260 return &m_descriptor;
cannam@3 261 }
cannam@3 262
cannam@76 263 PluginAdapterBase::Impl::~Impl()
cannam@3 264 {
cannam@22 265 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 266 std::cerr << "PluginAdapterBase::Impl[" << this << "]::~Impl" << std::endl;
cannam@22 267 #endif
cannam@22 268
cannam@3 269 if (!m_populated) return;
cannam@3 270
cannam@49 271 free((void *)m_descriptor.identifier);
cannam@3 272 free((void *)m_descriptor.name);
cannam@3 273 free((void *)m_descriptor.description);
cannam@3 274 free((void *)m_descriptor.maker);
cannam@3 275 free((void *)m_descriptor.copyright);
cannam@3 276
cannam@3 277 for (unsigned int i = 0; i < m_descriptor.parameterCount; ++i) {
cannam@3 278 const VampParameterDescriptor *desc = m_descriptor.parameters[i];
cannam@49 279 free((void *)desc->identifier);
cannam@3 280 free((void *)desc->name);
cannam@3 281 free((void *)desc->description);
cannam@3 282 free((void *)desc->unit);
cannam@9 283 if (desc->valueNames) {
cannam@9 284 for (unsigned int j = 0; desc->valueNames[j]; ++j) {
cannam@9 285 free((void *)desc->valueNames[j]);
cannam@9 286 }
cannam@9 287 free((void *)desc->valueNames);
cannam@9 288 }
cannam@3 289 }
cannam@3 290 free((void *)m_descriptor.parameters);
cannam@3 291
cannam@3 292 for (unsigned int i = 0; i < m_descriptor.programCount; ++i) {
cannam@3 293 free((void *)m_descriptor.programs[i]);
cannam@3 294 }
cannam@3 295 free((void *)m_descriptor.programs);
cannam@3 296
cannam@13 297 if (m_adapterMap) {
cannam@13 298
cannam@13 299 m_adapterMap->erase(&m_descriptor);
cannam@13 300
cannam@13 301 if (m_adapterMap->empty()) {
cannam@13 302 delete m_adapterMap;
cannam@13 303 m_adapterMap = 0;
cannam@13 304 }
cannam@13 305 }
cannam@3 306 }
cannam@3 307
cannam@76 308 PluginAdapterBase::Impl *
cannam@76 309 PluginAdapterBase::Impl::lookupAdapter(VampPluginHandle handle)
cannam@3 310 {
cannam@22 311 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 312 std::cerr << "PluginAdapterBase::Impl::lookupAdapter(" << handle << ")" << std::endl;
cannam@22 313 #endif
cannam@22 314
cannam@13 315 if (!m_adapterMap) return 0;
cannam@13 316 AdapterMap::const_iterator i = m_adapterMap->find(handle);
cannam@13 317 if (i == m_adapterMap->end()) return 0;
cannam@3 318 return i->second;
cannam@3 319 }
cannam@3 320
cannam@3 321 VampPluginHandle
cannam@76 322 PluginAdapterBase::Impl::vampInstantiate(const VampPluginDescriptor *desc,
cannam@3 323 float inputSampleRate)
cannam@3 324 {
cannam@22 325 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 326 std::cerr << "PluginAdapterBase::Impl::vampInstantiate(" << desc << ")" << std::endl;
cannam@22 327 #endif
cannam@22 328
cannam@15 329 if (!m_adapterMap) {
cannam@15 330 m_adapterMap = new AdapterMap();
cannam@15 331 }
cannam@15 332
cannam@15 333 if (m_adapterMap->find(desc) == m_adapterMap->end()) {
cannam@76 334 std::cerr << "WARNING: PluginAdapterBase::Impl::vampInstantiate: Descriptor " << desc << " not in adapter map" << std::endl;
cannam@15 335 return 0;
cannam@15 336 }
cannam@15 337
cannam@76 338 Impl *adapter = (*m_adapterMap)[desc];
cannam@3 339 if (desc != &adapter->m_descriptor) return 0;
cannam@3 340
cannam@76 341 Plugin *plugin = adapter->m_base->createPlugin(inputSampleRate);
cannam@3 342 if (plugin) {
cannam@13 343 (*m_adapterMap)[plugin] = adapter;
cannam@3 344 }
cannam@3 345
cannam@22 346 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 347 std::cerr << "PluginAdapterBase::Impl::vampInstantiate(" << desc << "): returning handle " << plugin << std::endl;
cannam@22 348 #endif
cannam@22 349
cannam@3 350 return plugin;
cannam@3 351 }
cannam@3 352
cannam@3 353 void
cannam@76 354 PluginAdapterBase::Impl::vampCleanup(VampPluginHandle handle)
cannam@3 355 {
cannam@22 356 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 357 std::cerr << "PluginAdapterBase::Impl::vampCleanup(" << handle << ")" << std::endl;
cannam@22 358 #endif
cannam@22 359
cannam@76 360 Impl *adapter = lookupAdapter(handle);
cannam@3 361 if (!adapter) {
cannam@3 362 delete ((Plugin *)handle);
cannam@3 363 return;
cannam@3 364 }
cannam@3 365 adapter->cleanup(((Plugin *)handle));
cannam@3 366 }
cannam@3 367
cannam@3 368 int
cannam@76 369 PluginAdapterBase::Impl::vampInitialise(VampPluginHandle handle,
cannam@3 370 unsigned int channels,
cannam@3 371 unsigned int stepSize,
cannam@3 372 unsigned int blockSize)
cannam@3 373 {
cannam@22 374 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 375 std::cerr << "PluginAdapterBase::Impl::vampInitialise(" << handle << ", " << channels << ", " << stepSize << ", " << blockSize << ")" << std::endl;
cannam@22 376 #endif
cannam@22 377
cannam@3 378 bool result = ((Plugin *)handle)->initialise
cannam@3 379 (channels, stepSize, blockSize);
cannam@3 380 return result ? 1 : 0;
cannam@3 381 }
cannam@3 382
cannam@3 383 void
cannam@76 384 PluginAdapterBase::Impl::vampReset(VampPluginHandle handle)
cannam@3 385 {
cannam@22 386 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 387 std::cerr << "PluginAdapterBase::Impl::vampReset(" << handle << ")" << std::endl;
cannam@22 388 #endif
cannam@22 389
cannam@3 390 ((Plugin *)handle)->reset();
cannam@3 391 }
cannam@3 392
cannam@3 393 float
cannam@76 394 PluginAdapterBase::Impl::vampGetParameter(VampPluginHandle handle,
cannam@3 395 int param)
cannam@3 396 {
cannam@22 397 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 398 std::cerr << "PluginAdapterBase::Impl::vampGetParameter(" << handle << ", " << param << ")" << std::endl;
cannam@22 399 #endif
cannam@22 400
cannam@76 401 Impl *adapter = lookupAdapter(handle);
cannam@3 402 if (!adapter) return 0.0;
cannam@3 403 Plugin::ParameterList &list = adapter->m_parameters;
cannam@49 404 return ((Plugin *)handle)->getParameter(list[param].identifier);
cannam@3 405 }
cannam@3 406
cannam@3 407 void
cannam@76 408 PluginAdapterBase::Impl::vampSetParameter(VampPluginHandle handle,
cannam@3 409 int param, float value)
cannam@3 410 {
cannam@22 411 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 412 std::cerr << "PluginAdapterBase::Impl::vampSetParameter(" << handle << ", " << param << ", " << value << ")" << std::endl;
cannam@22 413 #endif
cannam@22 414
cannam@76 415 Impl *adapter = lookupAdapter(handle);
cannam@3 416 if (!adapter) return;
cannam@3 417 Plugin::ParameterList &list = adapter->m_parameters;
cannam@49 418 ((Plugin *)handle)->setParameter(list[param].identifier, value);
cannam@3 419 }
cannam@3 420
cannam@3 421 unsigned int
cannam@76 422 PluginAdapterBase::Impl::vampGetCurrentProgram(VampPluginHandle handle)
cannam@3 423 {
cannam@22 424 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 425 std::cerr << "PluginAdapterBase::Impl::vampGetCurrentProgram(" << handle << ")" << std::endl;
cannam@22 426 #endif
cannam@22 427
cannam@76 428 Impl *adapter = lookupAdapter(handle);
cannam@3 429 if (!adapter) return 0;
cannam@3 430 Plugin::ProgramList &list = adapter->m_programs;
cannam@3 431 std::string program = ((Plugin *)handle)->getCurrentProgram();
cannam@3 432 for (unsigned int i = 0; i < list.size(); ++i) {
cannam@3 433 if (list[i] == program) return i;
cannam@3 434 }
cannam@3 435 return 0;
cannam@3 436 }
cannam@3 437
cannam@3 438 void
cannam@76 439 PluginAdapterBase::Impl::vampSelectProgram(VampPluginHandle handle,
cannam@3 440 unsigned int program)
cannam@3 441 {
cannam@22 442 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 443 std::cerr << "PluginAdapterBase::Impl::vampSelectProgram(" << handle << ", " << program << ")" << std::endl;
cannam@22 444 #endif
cannam@22 445
cannam@76 446 Impl *adapter = lookupAdapter(handle);
cannam@3 447 if (!adapter) return;
cannam@3 448 Plugin::ProgramList &list = adapter->m_programs;
cannam@3 449 ((Plugin *)handle)->selectProgram(list[program]);
cannam@3 450 }
cannam@3 451
cannam@3 452 unsigned int
cannam@76 453 PluginAdapterBase::Impl::vampGetPreferredStepSize(VampPluginHandle handle)
cannam@3 454 {
cannam@22 455 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 456 std::cerr << "PluginAdapterBase::Impl::vampGetPreferredStepSize(" << handle << ")" << std::endl;
cannam@22 457 #endif
cannam@22 458
cannam@3 459 return ((Plugin *)handle)->getPreferredStepSize();
cannam@3 460 }
cannam@3 461
cannam@3 462 unsigned int
cannam@76 463 PluginAdapterBase::Impl::vampGetPreferredBlockSize(VampPluginHandle handle)
cannam@3 464 {
cannam@22 465 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 466 std::cerr << "PluginAdapterBase::Impl::vampGetPreferredBlockSize(" << handle << ")" << std::endl;
cannam@22 467 #endif
cannam@22 468
cannam@3 469 return ((Plugin *)handle)->getPreferredBlockSize();
cannam@3 470 }
cannam@3 471
cannam@3 472 unsigned int
cannam@76 473 PluginAdapterBase::Impl::vampGetMinChannelCount(VampPluginHandle handle)
cannam@3 474 {
cannam@22 475 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 476 std::cerr << "PluginAdapterBase::Impl::vampGetMinChannelCount(" << handle << ")" << std::endl;
cannam@22 477 #endif
cannam@22 478
cannam@3 479 return ((Plugin *)handle)->getMinChannelCount();
cannam@3 480 }
cannam@3 481
cannam@3 482 unsigned int
cannam@76 483 PluginAdapterBase::Impl::vampGetMaxChannelCount(VampPluginHandle handle)
cannam@3 484 {
cannam@22 485 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 486 std::cerr << "PluginAdapterBase::Impl::vampGetMaxChannelCount(" << handle << ")" << std::endl;
cannam@22 487 #endif
cannam@22 488
cannam@3 489 return ((Plugin *)handle)->getMaxChannelCount();
cannam@3 490 }
cannam@3 491
cannam@3 492 unsigned int
cannam@76 493 PluginAdapterBase::Impl::vampGetOutputCount(VampPluginHandle handle)
cannam@3 494 {
cannam@22 495 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 496 std::cerr << "PluginAdapterBase::Impl::vampGetOutputCount(" << handle << ")" << std::endl;
cannam@22 497 #endif
cannam@22 498
cannam@76 499 Impl *adapter = lookupAdapter(handle);
cannam@15 500
cannam@15 501 // std::cerr << "vampGetOutputCount: handle " << handle << " -> adapter "<< adapter << std::endl;
cannam@15 502
cannam@3 503 if (!adapter) return 0;
cannam@3 504 return adapter->getOutputCount((Plugin *)handle);
cannam@3 505 }
cannam@3 506
cannam@3 507 VampOutputDescriptor *
cannam@76 508 PluginAdapterBase::Impl::vampGetOutputDescriptor(VampPluginHandle handle,
cannam@3 509 unsigned int i)
cannam@3 510 {
cannam@22 511 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 512 std::cerr << "PluginAdapterBase::Impl::vampGetOutputDescriptor(" << handle << ", " << i << ")" << std::endl;
cannam@22 513 #endif
cannam@22 514
cannam@76 515 Impl *adapter = lookupAdapter(handle);
cannam@15 516
cannam@15 517 // std::cerr << "vampGetOutputDescriptor: handle " << handle << " -> adapter "<< adapter << std::endl;
cannam@15 518
cannam@3 519 if (!adapter) return 0;
cannam@3 520 return adapter->getOutputDescriptor((Plugin *)handle, i);
cannam@3 521 }
cannam@3 522
cannam@3 523 void
cannam@76 524 PluginAdapterBase::Impl::vampReleaseOutputDescriptor(VampOutputDescriptor *desc)
cannam@3 525 {
cannam@22 526 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 527 std::cerr << "PluginAdapterBase::Impl::vampReleaseOutputDescriptor(" << desc << ")" << std::endl;
cannam@22 528 #endif
cannam@22 529
cannam@49 530 if (desc->identifier) free((void *)desc->identifier);
cannam@3 531 if (desc->name) free((void *)desc->name);
cannam@3 532 if (desc->description) free((void *)desc->description);
cannam@3 533 if (desc->unit) free((void *)desc->unit);
cannam@40 534 if (desc->hasFixedBinCount && desc->binNames) {
cannam@40 535 for (unsigned int i = 0; i < desc->binCount; ++i) {
cannam@40 536 if (desc->binNames[i]) {
cannam@40 537 free((void *)desc->binNames[i]);
cannam@40 538 }
cannam@40 539 }
cannam@3 540 }
cannam@9 541 if (desc->binNames) free((void *)desc->binNames);
cannam@3 542 free((void *)desc);
cannam@3 543 }
cannam@3 544
cannam@12 545 VampFeatureList *
cannam@76 546 PluginAdapterBase::Impl::vampProcess(VampPluginHandle handle,
cannam@108 547 const float *const *inputBuffers,
cannam@108 548 int sec,
cannam@108 549 int nsec)
cannam@3 550 {
cannam@22 551 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 552 std::cerr << "PluginAdapterBase::Impl::vampProcess(" << handle << ", " << sec << ", " << nsec << ")" << std::endl;
cannam@22 553 #endif
cannam@22 554
cannam@76 555 Impl *adapter = lookupAdapter(handle);
cannam@3 556 if (!adapter) return 0;
cannam@3 557 return adapter->process((Plugin *)handle,
cannam@3 558 inputBuffers, sec, nsec);
cannam@3 559 }
cannam@3 560
cannam@12 561 VampFeatureList *
cannam@76 562 PluginAdapterBase::Impl::vampGetRemainingFeatures(VampPluginHandle handle)
cannam@3 563 {
cannam@22 564 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 565 std::cerr << "PluginAdapterBase::Impl::vampGetRemainingFeatures(" << handle << ")" << std::endl;
cannam@22 566 #endif
cannam@22 567
cannam@76 568 Impl *adapter = lookupAdapter(handle);
cannam@3 569 if (!adapter) return 0;
cannam@3 570 return adapter->getRemainingFeatures((Plugin *)handle);
cannam@3 571 }
cannam@3 572
cannam@3 573 void
cannam@76 574 PluginAdapterBase::Impl::vampReleaseFeatureSet(VampFeatureList *fs)
cannam@3 575 {
cannam@22 576 #ifdef DEBUG_PLUGIN_ADAPTER
cannam@76 577 std::cerr << "PluginAdapterBase::Impl::vampReleaseFeatureSet" << std::endl;
cannam@22 578 #endif
cannam@3 579 }
cannam@3 580
cannam@3 581 void
cannam@76 582 PluginAdapterBase::Impl::cleanup(Plugin *plugin)
cannam@3 583 {
cannam@12 584 if (m_fs.find(plugin) != m_fs.end()) {
cannam@12 585 size_t outputCount = 0;
cannam@12 586 if (m_pluginOutputs[plugin]) {
cannam@12 587 outputCount = m_pluginOutputs[plugin]->size();
cannam@12 588 }
cannam@12 589 VampFeatureList *list = m_fs[plugin];
cannam@12 590 for (unsigned int i = 0; i < outputCount; ++i) {
cannam@12 591 for (unsigned int j = 0; j < m_fsizes[plugin][i]; ++j) {
cannam@168 592 if (list[i].features[j].v1.label) {
cannam@168 593 free(list[i].features[j].v1.label);
cannam@12 594 }
cannam@168 595 if (list[i].features[j].v1.values) {
cannam@168 596 free(list[i].features[j].v1.values);
cannam@12 597 }
cannam@12 598 }
cannam@12 599 if (list[i].features) free(list[i].features);
cannam@12 600 }
cannam@12 601 m_fs.erase(plugin);
cannam@12 602 m_fsizes.erase(plugin);
cannam@12 603 m_fvsizes.erase(plugin);
cannam@12 604 }
cannam@12 605
cannam@3 606 if (m_pluginOutputs.find(plugin) != m_pluginOutputs.end()) {
cannam@3 607 delete m_pluginOutputs[plugin];
cannam@3 608 m_pluginOutputs.erase(plugin);
cannam@3 609 }
cannam@13 610
cannam@13 611 if (m_adapterMap) {
cannam@13 612 m_adapterMap->erase(plugin);
cannam@13 613
cannam@13 614 if (m_adapterMap->empty()) {
cannam@13 615 delete m_adapterMap;
cannam@13 616 m_adapterMap = 0;
cannam@13 617 }
cannam@13 618 }
cannam@13 619
cannam@3 620 delete ((Plugin *)plugin);
cannam@3 621 }
cannam@3 622
cannam@3 623 void
cannam@76 624 PluginAdapterBase::Impl::checkOutputMap(Plugin *plugin)
cannam@3 625 {
cannam@15 626 if (m_pluginOutputs.find(plugin) == m_pluginOutputs.end() ||
cannam@15 627 !m_pluginOutputs[plugin]) {
cannam@3 628 m_pluginOutputs[plugin] = new Plugin::OutputList
cannam@3 629 (plugin->getOutputDescriptors());
cannam@76 630 // std::cerr << "PluginAdapterBase::Impl::checkOutputMap: Have " << m_pluginOutputs[plugin]->size() << " outputs for plugin " << plugin->getIdentifier() << std::endl;
cannam@3 631 }
cannam@3 632 }
cannam@3 633
cannam@3 634 unsigned int
cannam@76 635 PluginAdapterBase::Impl::getOutputCount(Plugin *plugin)
cannam@3 636 {
cannam@3 637 checkOutputMap(plugin);
cannam@3 638 return m_pluginOutputs[plugin]->size();
cannam@3 639 }
cannam@3 640
cannam@3 641 VampOutputDescriptor *
cannam@76 642 PluginAdapterBase::Impl::getOutputDescriptor(Plugin *plugin,
cannam@3 643 unsigned int i)
cannam@3 644 {
cannam@3 645 checkOutputMap(plugin);
cannam@3 646 Plugin::OutputDescriptor &od =
cannam@3 647 (*m_pluginOutputs[plugin])[i];
cannam@3 648
cannam@3 649 VampOutputDescriptor *desc = (VampOutputDescriptor *)
cannam@3 650 malloc(sizeof(VampOutputDescriptor));
cannam@3 651
cannam@49 652 desc->identifier = strdup(od.identifier.c_str());
cannam@3 653 desc->name = strdup(od.name.c_str());
cannam@3 654 desc->description = strdup(od.description.c_str());
cannam@3 655 desc->unit = strdup(od.unit.c_str());
cannam@9 656 desc->hasFixedBinCount = od.hasFixedBinCount;
cannam@9 657 desc->binCount = od.binCount;
cannam@3 658
cannam@9 659 if (od.hasFixedBinCount && od.binCount > 0) {
cannam@9 660 desc->binNames = (const char **)
cannam@9 661 malloc(od.binCount * sizeof(const char *));
cannam@3 662
cannam@9 663 for (unsigned int i = 0; i < od.binCount; ++i) {
cannam@9 664 if (i < od.binNames.size()) {
cannam@9 665 desc->binNames[i] = strdup(od.binNames[i].c_str());
cannam@7 666 } else {
cannam@9 667 desc->binNames[i] = 0;
cannam@7 668 }
cannam@3 669 }
cannam@7 670 } else {
cannam@9 671 desc->binNames = 0;
cannam@3 672 }
cannam@3 673
cannam@3 674 desc->hasKnownExtents = od.hasKnownExtents;
cannam@3 675 desc->minValue = od.minValue;
cannam@3 676 desc->maxValue = od.maxValue;
cannam@3 677 desc->isQuantized = od.isQuantized;
cannam@3 678 desc->quantizeStep = od.quantizeStep;
cannam@3 679
cannam@3 680 switch (od.sampleType) {
cannam@3 681 case Plugin::OutputDescriptor::OneSamplePerStep:
cannam@3 682 desc->sampleType = vampOneSamplePerStep; break;
cannam@3 683 case Plugin::OutputDescriptor::FixedSampleRate:
cannam@3 684 desc->sampleType = vampFixedSampleRate; break;
cannam@3 685 case Plugin::OutputDescriptor::VariableSampleRate:
cannam@3 686 desc->sampleType = vampVariableSampleRate; break;
cannam@3 687 }
cannam@3 688
cannam@3 689 desc->sampleRate = od.sampleRate;
cannam@192 690 desc->hasDuration = od.hasDuration;
cannam@3 691
cannam@3 692 return desc;
cannam@3 693 }
cannam@3 694
cannam@12 695 VampFeatureList *
cannam@76 696 PluginAdapterBase::Impl::process(Plugin *plugin,
cannam@108 697 const float *const *inputBuffers,
cannam@108 698 int sec, int nsec)
cannam@3 699 {
cannam@76 700 // std::cerr << "PluginAdapterBase::Impl::process" << std::endl;
cannam@3 701 RealTime rt(sec, nsec);
cannam@12 702 checkOutputMap(plugin);
cannam@12 703 return convertFeatures(plugin, plugin->process(inputBuffers, rt));
cannam@3 704 }
cannam@3 705
cannam@12 706 VampFeatureList *
cannam@76 707 PluginAdapterBase::Impl::getRemainingFeatures(Plugin *plugin)
cannam@3 708 {
cannam@76 709 // std::cerr << "PluginAdapterBase::Impl::getRemainingFeatures" << std::endl;
cannam@12 710 checkOutputMap(plugin);
cannam@12 711 return convertFeatures(plugin, plugin->getRemainingFeatures());
cannam@3 712 }
cannam@3 713
cannam@12 714 VampFeatureList *
cannam@76 715 PluginAdapterBase::Impl::convertFeatures(Plugin *plugin,
cannam@167 716 const Plugin::FeatureSet &features)
cannam@3 717 {
cannam@12 718 int lastN = -1;
cannam@3 719
cannam@12 720 int outputCount = 0;
cannam@12 721 if (m_pluginOutputs[plugin]) outputCount = m_pluginOutputs[plugin]->size();
cannam@12 722
cannam@12 723 resizeFS(plugin, outputCount);
cannam@12 724 VampFeatureList *fs = m_fs[plugin];
cannam@3 725
cannam@168 726 // std::cerr << "PluginAdapter(v2)::convertFeatures: NOTE: sizeof(Feature) == " << sizeof(Plugin::Feature) << ", sizeof(VampFeature) == " << sizeof(VampFeature) << ", sizeof(VampFeatureList) == " << sizeof(VampFeatureList) << std::endl;
cannam@168 727
cannam@12 728 for (Plugin::FeatureSet::const_iterator fi = features.begin();
cannam@12 729 fi != features.end(); ++fi) {
cannam@3 730
cannam@12 731 int n = fi->first;
cannam@12 732
cannam@76 733 // std::cerr << "PluginAdapterBase::Impl::convertFeatures: n = " << n << std::endl;
cannam@7 734
cannam@12 735 if (n >= int(outputCount)) {
cannam@76 736 std::cerr << "WARNING: PluginAdapterBase::Impl::convertFeatures: Too many outputs from plugin (" << n+1 << ", only should be " << outputCount << ")" << std::endl;
cannam@7 737 continue;
cannam@7 738 }
cannam@7 739
cannam@12 740 if (n > lastN + 1) {
cannam@12 741 for (int i = lastN + 1; i < n; ++i) {
cannam@12 742 fs[i].featureCount = 0;
cannam@12 743 }
cannam@12 744 }
cannam@7 745
cannam@7 746 const Plugin::FeatureList &fl = fi->second;
cannam@7 747
cannam@12 748 size_t sz = fl.size();
cannam@12 749 if (sz > m_fsizes[plugin][n]) resizeFL(plugin, n, sz);
cannam@12 750 fs[n].featureCount = sz;
cannam@12 751
cannam@12 752 for (size_t j = 0; j < sz; ++j) {
cannam@7 753
cannam@76 754 // std::cerr << "PluginAdapterBase::Impl::convertFeatures: j = " << j << std::endl;
cannam@7 755
cannam@168 756 VampFeature *feature = &fs[n].features[j].v1;
cannam@7 757
cannam@7 758 feature->hasTimestamp = fl[j].hasTimestamp;
cannam@7 759 feature->sec = fl[j].timestamp.sec;
cannam@7 760 feature->nsec = fl[j].timestamp.nsec;
cannam@7 761 feature->valueCount = fl[j].values.size();
cannam@7 762
cannam@168 763 VampFeatureV2 *v2 = &fs[n].features[j + sz].v2;
cannam@167 764
cannam@167 765 v2->hasDuration = fl[j].hasDuration;
cannam@167 766 v2->durationSec = fl[j].duration.sec;
cannam@167 767 v2->durationNsec = fl[j].duration.nsec;
cannam@167 768
cannam@12 769 if (feature->label) free(feature->label);
cannam@12 770
cannam@12 771 if (fl[j].label.empty()) {
cannam@12 772 feature->label = 0;
cannam@12 773 } else {
cannam@12 774 feature->label = strdup(fl[j].label.c_str());
cannam@7 775 }
cannam@7 776
cannam@12 777 if (feature->valueCount > m_fvsizes[plugin][n][j]) {
cannam@12 778 resizeFV(plugin, n, j, feature->valueCount);
cannam@12 779 }
cannam@7 780
cannam@7 781 for (unsigned int k = 0; k < feature->valueCount; ++k) {
cannam@76 782 // std::cerr << "PluginAdapterBase::Impl::convertFeatures: k = " << k << std::endl;
cannam@7 783 feature->values[k] = fl[j].values[k];
cannam@3 784 }
cannam@3 785 }
cannam@12 786
cannam@12 787 lastN = n;
cannam@3 788 }
cannam@3 789
cannam@12 790 if (lastN == -1) return 0;
cannam@12 791
cannam@12 792 if (int(outputCount) > lastN + 1) {
cannam@12 793 for (int i = lastN + 1; i < int(outputCount); ++i) {
cannam@12 794 fs[i].featureCount = 0;
cannam@12 795 }
cannam@12 796 }
cannam@3 797
cannam@168 798 // std::cerr << "PluginAdapter(v2)::convertFeatures: NOTE: have " << outputCount << " outputs" << std::endl;
cannam@168 799 // for (int i = 0; i < outputCount; ++i) {
cannam@168 800 // std::cerr << "PluginAdapter(v2)::convertFeatures: NOTE: output " << i << " has " << fs[i].featureCount << " features" << std::endl;
cannam@168 801 // }
cannam@168 802
cannam@168 803
cannam@3 804 return fs;
cannam@3 805 }
cannam@3 806
cannam@12 807 void
cannam@76 808 PluginAdapterBase::Impl::resizeFS(Plugin *plugin, int n)
cannam@12 809 {
cannam@76 810 // std::cerr << "PluginAdapterBase::Impl::resizeFS(" << plugin << ", " << n << ")" << std::endl;
cannam@12 811
cannam@12 812 int i = m_fsizes[plugin].size();
cannam@12 813 if (i >= n) return;
cannam@12 814
cannam@16 815 // std::cerr << "resizing from " << i << std::endl;
cannam@12 816
cannam@12 817 m_fs[plugin] = (VampFeatureList *)realloc
cannam@12 818 (m_fs[plugin], n * sizeof(VampFeatureList));
cannam@12 819
cannam@12 820 while (i < n) {
cannam@12 821 m_fs[plugin][i].featureCount = 0;
cannam@12 822 m_fs[plugin][i].features = 0;
cannam@12 823 m_fsizes[plugin].push_back(0);
cannam@12 824 m_fvsizes[plugin].push_back(std::vector<size_t>());
cannam@12 825 i++;
cannam@12 826 }
cannam@12 827 }
cannam@12 828
cannam@12 829 void
cannam@76 830 PluginAdapterBase::Impl::resizeFL(Plugin *plugin, int n, size_t sz)
cannam@12 831 {
cannam@76 832 // std::cerr << "PluginAdapterBase::Impl::resizeFL(" << plugin << ", " << n << ", "
cannam@16 833 // << sz << ")" << std::endl;
cannam@12 834
cannam@12 835 size_t i = m_fsizes[plugin][n];
cannam@12 836 if (i >= sz) return;
cannam@12 837
cannam@16 838 // std::cerr << "resizing from " << i << std::endl;
cannam@12 839
cannam@168 840 m_fs[plugin][n].features = (VampFeatureUnion *)realloc
cannam@168 841 (m_fs[plugin][n].features, 2 * sz * sizeof(VampFeatureUnion));
cannam@167 842
cannam@12 843 while (m_fsizes[plugin][n] < sz) {
cannam@168 844 m_fs[plugin][n].features[m_fsizes[plugin][n]].v1.hasTimestamp = 0;
cannam@168 845 m_fs[plugin][n].features[m_fsizes[plugin][n]].v1.valueCount = 0;
cannam@168 846 m_fs[plugin][n].features[m_fsizes[plugin][n]].v1.values = 0;
cannam@168 847 m_fs[plugin][n].features[m_fsizes[plugin][n]].v1.label = 0;
cannam@189 848 m_fs[plugin][n].features[m_fsizes[plugin][n] + sz].v2.hasDuration = 0;
cannam@12 849 m_fvsizes[plugin][n].push_back(0);
cannam@12 850 m_fsizes[plugin][n]++;
cannam@12 851 }
cannam@12 852 }
cannam@12 853
cannam@12 854 void
cannam@76 855 PluginAdapterBase::Impl::resizeFV(Plugin *plugin, int n, int j, size_t sz)
cannam@12 856 {
cannam@76 857 // std::cerr << "PluginAdapterBase::Impl::resizeFV(" << plugin << ", " << n << ", "
cannam@16 858 // << j << ", " << sz << ")" << std::endl;
cannam@12 859
cannam@12 860 size_t i = m_fvsizes[plugin][n][j];
cannam@12 861 if (i >= sz) return;
cannam@12 862
cannam@16 863 // std::cerr << "resizing from " << i << std::endl;
cannam@12 864
cannam@168 865 m_fs[plugin][n].features[j].v1.values = (float *)realloc
cannam@168 866 (m_fs[plugin][n].features[j].v1.values, sz * sizeof(float));
cannam@12 867
cannam@12 868 m_fvsizes[plugin][n][j] = sz;
cannam@12 869 }
cannam@12 870
cannam@76 871 PluginAdapterBase::Impl::AdapterMap *
cannam@76 872 PluginAdapterBase::Impl::m_adapterMap = 0;
cannam@3 873
cannam@3 874 }
cannam@3 875
cannam@230 876 }
cannam@230 877