---

/root/src/subsynth/syn/Module/MixerModule.cpp

Go to the documentation of this file.

/****************** <SYN heading BEGIN do not edit this line> *****************
 *
 * subsynth - modular audio synthesizer
 * subsynth is (C) Copyright 2001-2002 by Kevin Meinert
 *
 * Original Author: Kevin Meinert
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Library General Public
 * License as published by the Free Software Foundation; either
 * version 2 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Library General Public License for more details.
 *
 * You should have received a copy of the GNU Library General Public
 * License along with this library; if not, write to the
 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
 * Boston, MA 02111-1307, USA.
 *
 * -----------------------------------------------------------------
 * File:          $RCSfile: MixerModule.cpp,v $
 * Date modified: $Date: 2002/04/14 19:52:05 $
 * Version:       $Revision: 1.14 $
 * -----------------------------------------------------------------
 *
 ****************** <SYN heading END do not edit this line> ******************/
#include "syn/Module/MixerModule.h"
#include <syn/Stream/SampleBufferIStream.h>

namespace syn
{
   MixerModule::MixerModule() : Module(), mIsOpen( false ), mWriteBuf( NULL )
   {
      this->createOutput( "output" );
      
      bool result = this->getOutput( "output", mTerminal );
      assert( result && "this isn't right" );
   }

   bool MixerModule::open()
   {
      mIsOpen = true;
      return mIsOpen;
   }
   
   void MixerModule::close()
   {
      mIsOpen = false;
   }
   
   bool MixerModule::areInputsDone()
   {
      std::map<std::string, TerminalPtr>::const_iterator input_itr;
      for (input_itr = this->inputs().begin(); input_itr != this->inputs().end(); ++input_itr)
      {
         // if any input is not done, then return false - inputs are not done.
         if (!(*input_itr).second->done())
            return false;
      }
         
      return true; // all inputs have a done state.
   }
  
   bool MixerModule::needToWait()
   {
      std::map<std::string, TerminalPtr>::const_iterator input_itr;
      for (input_itr = this->inputs().begin(); input_itr != this->inputs().end(); ++input_itr)
      {
         if ((*input_itr).second->empty() && !(*input_itr).second->done())
            return true;
      }
         
      return false; // all inputs have a done state.
   }
   
   void MixerModule::update()
   {
      mPutCount = 0;

      if (this->needToWait())
      {
         //std::cout<<"[syn]mix: waiting\n"<<std::flush;
         return;
      }
      
      // get a buffer to write to.
      if (mWriteBuf == NULL)
      {
         // find the terminals that are not empty 
         // (also ensure there is at least one term before we do anything)
         std::list<TerminalPtr> terms;
         {
            std::map<std::string, TerminalPtr>::iterator input_itr;
            for (input_itr = this->inputs().begin(); input_itr != this->inputs().end(); ++input_itr)
            {
               TerminalPtr input_term = (*input_itr).second;
               if (!input_term->empty())
               {
                  terms.push_back( (*input_itr).second );
                  //std::cout<<"[syn]mix: good term:\n"<<std::flush;
               }
            }
            if (terms.size() == 0)
               return;
         }
         
         // start combining all the terms into one...
         std::list<TerminalPtr>::iterator input_itr = terms.begin();
         
         // take the first buffer, then pop it, later we'll use this to 
         // accumulate the other inputs additively...
         mWriteBuf = (*input_itr)->front();
         (*input_itr)->pop();
         ++input_itr;
         
         // for now we assume all buffers are the same size, just read the size of the first one.
         mPutCount = mWriteBuf->size();
         //std::cout<<"[syn]mix: pc:"<<mPutCount<<"\n"<<std::flush;

         // mixdown each input terminal (additive)
         // accumulate the other inputs into mWriteBuf...
         for (; input_itr != terms.end(); ++input_itr)
         {
            TerminalPtr input_term = (*input_itr);
            if (!input_term->empty())
            {
               SampleBuffer1f* read_buf = input_term->front();

               // accumulate the readbuf values into the writebuf using addition.
               (*mWriteBuf) += (*read_buf);

               // if done with the buffer, get rid of it...
               SampleBufferRepos::instance()->putback( read_buf );
               input_term->pop();
            }
         }

         // clamp data
         //dfclamp( *mWriteBuf );
      }

      mTerminal->setDone( false );
      
      // nothing to do if the output queue is full
      if (!mTerminal->high())
      {
         mTerminal->push( mWriteBuf );
         mWriteBuf = NULL;
      }      
   }
}// end of namespace

---