---

/root/src/subsynth/syn/Module/IStreamModule.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: IStreamModule.cpp,v $
 * Date modified: $Date: 2002/04/14 18:03:17 $
 * Version:       $Revision: 1.10 $
 * -----------------------------------------------------------------
 *
 ****************** <SYN heading END do not edit this line> ******************/
#include "syn/Stream/AudioIStream.h"
#include "syn/Core/SampleBufferRepos.h"
#include "syn/Module/IStreamModule.h"

namespace syn
{

   IStreamModule::IStreamModule(): Module(), mStream( NULL ), 
         mTrigger( false ), mWriteBuf( NULL )
   {
      mAmplitudeControlInput = this->createInput( "amplitude" );
      mPitchControlInput = this->createInput( "pitch" );
      mTriggerControlInput = this->createInput( "trigger" );
      mMonoAudioOutput = this->createOutput( "mono audio" );
   }
   
   IStreamModule::~IStreamModule()
   {
   }
      
   bool IStreamModule::isOpen() { return mStream->isOpen(); }
   bool IStreamModule::open()
   {
      if (mStream.get() == NULL)
         return false;
      
      // configure the output terminals
      mMonoAudioOutput->setHighMark( 2 ); 
      mMonoAudioOutput->setLowMark( 1 );
      
      mStream->open( AudioFormat( AudioFormat::FLOAT32, 1, 44100 ) );
      assert( mStream->isOpen() == true );
      return mStream->isOpen();
   }
   
   void IStreamModule::close()
   {
      if (mStream.get() != NULL)
      {
         mStream->close();
      }
   }
   
   void IStreamModule::setStream( AudioIStreamPtr& istream )
   {
      mStream = istream;
   }
   
   void IStreamModule::trigger( float t )
   {
      mTrigger = true;

      // restart the stream on a trigger.
      if (mStream.get() != NULL)
         mStream->seek( 0 );
   }
   void IStreamModule::release()
   {
      mTrigger = false;
   }

   void IStreamModule::update()
   {  
      this->setPutCount( 0 );
      
      // debug...
      if (mStream.get())
      {
      //   std::cout<<"[syn]ismod: state: strOpn:"<<mStream->isOpen()<<" eof:"<<mStream->eof()
      //            <<" con:"<<mMonoAudioOutput->isConnected()
      //            <<" thsOpn:"<<this->isOpen()<<" trig:"<<mTrigger<<std::endl;
      }
      
      // if no input, or no output, if we're not open or triggering,
      // then return.
      if (((mStream.get() != NULL && mStream->isOpen() && !mStream->eof()) &&
          this->isOpen() && mTrigger == true) == false)
      {
         mMonoAudioOutput->setDone( true );
         //std::cout<<"[syn]ismod: done\n"<<std::flush;
         return;
      }      
      
/*
      // get the control events for amplitude modulation
      SampleBufferQueuePtr queue;
      if (mAmplitudeControlInput->isConnected() && 
          mAmplitudeControlInput->getQueue( queue ) &&
          mAmplitudeControlInput->isDone() == false)
      {
         mTrigger = true;
         
         if (!queue->empty())
         {
            SampleBuffer& read_buf = queue->read();
            
            AudioFormat src_fmt = queue->format();
            src_fmt.channels == mFmt
            
            char buf[8];
            float control_param;
            read_buf.drain( buf, 1 );
            audio_format_convert( src_fmt, float_fmt, buf, 1, &control_param );
            
            read_buf.updateReadPointer( read_buf.size() ); // empty it
            queue->pop(); // pop the buffer away... we're done with it.

            // todo: set up the input terminal to be a bufsize of 1, queuesize of 2, and format of float.
         }
      }
*/
      // get the output queue
      if (mWriteBuf == NULL)
      {
         SampleBufferRepos::instance()->take( mWriteBuf );
         mStream->read( mWriteBuf->data(), mWriteBuf->size() );
         this->setPutCount( mStream->gcount() );
      }
      //std::cout<<"[syn]ismod: tried to read "<<mWriteBuf->free()<<" got "<<mStream->gcount()<<"\n"<<std::flush;
      //std::cout<<"[syn]ismod:  type:"<<mStream->format().datatype<<" chan:"<<mStream->format().channels<<" rate:"<<mStream->format().samplingRateHz<<"\n"<<std::flush;

      // if there is more data coming, then we need the readers to wait
      // if I don't provide, then I could starve them, so be careful....
      mMonoAudioOutput->setDone( mStream->eof() ); // if eof, then we're done...

      //std::cout<<"[syn]ismod: qhigh:"<<queue->high()<<" eof:"<<mStream->eof()<<" qsize:"<<queue->size()<<" qdone:"<<queue->done()<<" full:"<<mWriteBuf->full()<<"\n"<<std::flush;

      if (mWriteBuf != NULL && !mMonoAudioOutput->high())
      {
         mMonoAudioOutput->push( mWriteBuf );
         mWriteBuf = NULL;
      }
   }
}// end of namespace.

---