/home/breidi/Dropbox/signalserver/include/hardware/sine_generator_no_artificial_base.h

/*
    This file is part of the TOBI signal server.

    The TOBI signal server is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    The TOBI signal server 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 General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with Foobar.  If not, see <http://www.gnu.org/licenses/>.

    Copyright 2010 Christian Breitwieser
    Contact: c.breitwieser@tugraz.at
*/

#ifndef SINEGENERATOR_H
#define SINEGENERATOR_H

#include <vector>
#include <map>

#include <boost/asio.hpp>
#include <boost/thread/condition.hpp>  // for mutex and cond. variables
#include <boost/thread/shared_mutex.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/cstdint.hpp>

#include "hw_thread.h"
#include "hardware/hw_thread_builder.h"

namespace tobiss
{
//-----------------------------------------------------------------------------
class SineGenerator : public HWThread
{
  public:
    SineGenerator(boost::asio::io_service& io, const int sampling_rate, const int nr_ch, const int blocks)
      : HWThread(sampling_rate, nr_ch, blocks), step_(1/static_cast<float>(fs_)),   \
        cycle_dur_(1/static_cast<float>(fs_)), current_block_(0), td_(1000000/fs_), samples_(1,0)
    {
      t_ = new boost::asio::deadline_timer(io, td_);
      genSine();
    }
    SineGenerator(boost::asio::io_service& io, ticpp::Iterator<ticpp::Element> hw);

    virtual ~SineGenerator()    {  delete t_;  }

    virtual SampleBlock<double> getSyncData();
    virtual SampleBlock<double> getAsyncData();
    virtual void run();
    virtual void stop();

//-----------------------------------------------
  private:
    void setHardware(ticpp::Iterator<ticpp::Element>const &hw);
    void genSine();
    virtual void setDeviceSettings(ticpp::Iterator<ticpp::Element>const &father);
    virtual void setChannelSettings(ticpp::Iterator<ticpp::Element>const &father);

//-----------------------------------------------

  private:
    bool acquiring_;   
    boost::asio::deadline_timer* t_;   
    double step_;        
    double cycle_dur_;   
    boost::uint16_t current_block_;     
    boost::posix_time::microseconds td_;   

    boost::mutex sync_mut_;  
    boost::condition_variable_any cond_;   

    std::vector<double> samples_; 

    SampleBlock<double> buffer_;

    static const HWThreadBuilderTemplateRegistrator<SineGenerator> factory_registrator_;
};

} // Namespace tobiss

#endif // SINEGENERATOR_H

//-----------------------------------------------------------------------------