cannam@111: /* -*- c-basic-offset: 4 indent-tabs-mode: nil -*-  vi:set ts=8 sts=4 sw=4: */
c@118: /*
c@118:   Piper C++
c@118: 
c@118:   An API for audio analysis and feature extraction plugins.
c@118: 
c@118:   Centre for Digital Music, Queen Mary, University of London.
c@118:   Copyright 2006-2016 Chris Cannam and QMUL.
c@118:   
c@118:   Permission is hereby granted, free of charge, to any person
c@118:   obtaining a copy of this software and associated documentation
c@118:   files (the "Software"), to deal in the Software without
c@118:   restriction, including without limitation the rights to use, copy,
c@118:   modify, merge, publish, distribute, sublicense, and/or sell copies
c@118:   of the Software, and to permit persons to whom the Software is
c@118:   furnished to do so, subject to the following conditions:
c@118: 
c@118:   The above copyright notice and this permission notice shall be
c@118:   included in all copies or substantial portions of the Software.
c@118: 
c@118:   THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
c@118:   EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
c@118:   MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
c@118:   NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS BE LIABLE FOR
c@118:   ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF
c@118:   CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
c@118:   WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
c@118: 
c@118:   Except as contained in this notice, the names of the Centre for
c@118:   Digital Music; Queen Mary, University of London; and Chris Cannam
c@118:   shall not be used in advertising or otherwise to promote the sale,
c@118:   use or other dealings in this Software without prior written
c@118:   authorization.
c@118: */
c@98: 
c@98: #ifndef PIPER_AUTO_PLUGIN_H
c@98: #define PIPER_AUTO_PLUGIN_H
c@98: 
c@98: #include "ProcessQtTransport.h"
c@98: #include "CapnpRRClient.h"
c@98: 
c@98: #include <cstdint>
c@98: 
c@98: namespace piper_vamp {
c@98: namespace client {
c@98: 
c@98: class AutoPlugin : public Vamp::Plugin
c@98: {
c@98: public:
c@101:     AutoPlugin(std::string serverName,
c@118:                std::string pluginKey,
c@118:                float inputSampleRate,
c@118:                int adapterFlags) :
c@118:         Vamp::Plugin(inputSampleRate),
c@119:         m_transport(serverName, "capnp"),
c@118:         m_client(&m_transport)
c@98:     {
c@118:         LoadRequest req;
c@118:         req.pluginKey = pluginKey;
c@118:         req.inputSampleRate = inputSampleRate;
c@118:         req.adapterFlags = adapterFlags;
c@121:         try {
c@121:             LoadResponse resp = m_client.loadPlugin(req);
c@121:             m_plugin = resp.plugin;
c@121:         } catch (ServerCrashed c) {
c@121:             std::cerr << c.what() << std::endl;
c@121:             m_plugin = 0;
c@121:         }
c@98:     }
c@98: 
c@98:     virtual ~AutoPlugin() {
c@118:         delete m_plugin;
c@98:     }
c@98: 
c@98:     bool isOK() const {
c@118:         return (m_plugin != nullptr);
c@98:     }
c@98:     
c@98:     virtual std::string getIdentifier() const {
c@118:         return getPlugin()->getIdentifier();
c@98:     }
c@98: 
c@98:     virtual std::string getName() const {
c@118:         return getPlugin()->getName();
c@98:     }
c@98: 
c@98:     virtual std::string getDescription() const {
c@118:         return getPlugin()->getDescription();
c@98:     }
c@98: 
c@98:     virtual std::string getMaker() const {
c@118:         return getPlugin()->getMaker();
c@98:     }
c@98: 
c@98:     virtual std::string getCopyright() const {
c@118:         return getPlugin()->getCopyright();
c@98:     }
c@98: 
c@98:     virtual int getPluginVersion() const {
c@98:         return getPlugin()->getPluginVersion();
c@98:     }
c@98: 
c@98:     virtual ParameterList getParameterDescriptors() const {
c@118:         return getPlugin()->getParameterDescriptors();
c@98:     }
c@98: 
c@98:     virtual float getParameter(std::string name) const {
c@118:         return getPlugin()->getParameter(name);
c@98:     }
c@98: 
c@98:     virtual void setParameter(std::string name, float value) {
c@118:         getPlugin()->setParameter(name, value);
c@98:     }
c@98: 
c@98:     virtual ProgramList getPrograms() const {
c@98:         return getPlugin()->getPrograms();
c@98:     }
c@98: 
c@98:     virtual std::string getCurrentProgram() const {
c@98:         return getPlugin()->getCurrentProgram();
c@98:     }
c@98:     
c@98:     virtual void selectProgram(std::string program) {
c@118:         getPlugin()->selectProgram(program);
c@98:     }
c@98: 
c@98:     virtual bool initialise(size_t inputChannels,
c@98:                             size_t stepSize,
c@98:                             size_t blockSize) {
c@118:         return getPlugin()->initialise(inputChannels, stepSize, blockSize);
c@98:     }
c@98: 
c@98:     virtual void reset() {
c@118:         getPlugin()->reset();
c@98:     }
c@98: 
c@98:     virtual InputDomain getInputDomain() const {
c@118:         return getPlugin()->getInputDomain();
c@98:     }
c@98: 
c@98:     virtual size_t getPreferredBlockSize() const {
c@118:         return getPlugin()->getPreferredBlockSize();
c@98:     }
c@98: 
c@98:     virtual size_t getPreferredStepSize() const {
c@118:         return getPlugin()->getPreferredStepSize();
c@98:     }
c@98: 
c@98:     virtual size_t getMinChannelCount() const {
c@118:         return getPlugin()->getMinChannelCount();
c@98:     }
c@98: 
c@98:     virtual size_t getMaxChannelCount() const {
c@118:         return getPlugin()->getMaxChannelCount();
c@98:     }
c@98: 
c@98:     virtual OutputList getOutputDescriptors() const {
c@118:         return getPlugin()->getOutputDescriptors();
c@98:     }
c@98: 
c@98:     virtual FeatureSet process(const float *const *inputBuffers,
c@118:                                Vamp::RealTime timestamp) {
c@118:         return getPlugin()->process(inputBuffers, timestamp);
c@98:     }
c@98: 
c@98:     virtual FeatureSet getRemainingFeatures() {
c@118:         return getPlugin()->getRemainingFeatures();
c@98:     }
c@98: 
c@98: private:
c@98:     ProcessQtTransport m_transport;
c@98:     CapnpRRClient m_client;
c@98:     Vamp::Plugin *m_plugin;
c@98:     Vamp::Plugin *getPlugin() const {
c@118:         if (!m_plugin) {
c@118:             throw std::logic_error
c@118:                 ("Plugin load failed (should have called AutoPlugin::isOK)");
c@118:         }
c@118:         return m_plugin;
c@98:     }
c@98: };
c@98: 
c@98: }
c@98: }
c@98: 
c@98: #endif
c@98: 
c@98: