AsyncAudioDebugger.h

Go to the documentation of this file.

 
#ifndef AUDIO_DEBUGGER_INCLUDED
#define AUDIO_DEBUGGER_INCLUDED
 
 
/****************************************************************************
 *
 * System Includes
 *
 ****************************************************************************/
 
#include <sys/time.h>
#include <iostream>
#include <string>
#include <stdint.h>
 
 
/****************************************************************************
 *
 * Project Includes
 *
 ****************************************************************************/
 
#include <AsyncAudioSink.h>
#include <AsyncAudioSource.h>
 
 
/****************************************************************************
 *
 * Local Includes
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Forward declarations
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Namespace
 *
 ****************************************************************************/
 
namespace Async
{
 
 
/****************************************************************************
 *
 * Forward declarations of classes inside of the declared namespace
 *
 ****************************************************************************/
 
  
 
/****************************************************************************
 *
 * Defines & typedefs
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Exported Global Variables
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Class definitions
 *
 ****************************************************************************/
 
class AudioDebugger : public AudioSink, public AudioSource
{
  public:
    AudioDebugger(Async::AudioSource *src=0,
                  const std::string& name="AudioDebugger")
      : name(name), sample_count(0)
    {
      gettimeofday(&start_time, 0);
      if (src != 0)
      {
        Async::AudioSink *sink = src->sink();
        if (sink != 0)
        {
          src->unregisterSink();
          registerSink(sink);
        }
        registerSource(src);
      }
    }
  
    virtual ~AudioDebugger(void) {}
  
    void setName(std::string debug_name) { name = debug_name; }
 
    virtual int writeSamples(const float *samples, int count)
    {
      int ret = sinkWriteSamples(samples, count);
      sample_count += ret;
 
      float max_samp = 0.0f;
      for (int i=0; i<count; ++i)
      {
        if (samples[i] > max_samp)
        {
          max_samp = samples[i];
        }
        if (-samples[i] > max_samp)
        {
          max_samp = -samples[i];
        }
      }
 
      struct timeval time, diff;
      gettimeofday(&time, 0);
 
      timersub(&time, &start_time, &diff);
      uint64_t diff_ms = diff.tv_sec * 1000 + diff.tv_usec / 1000;
 
      std::cout << name << "::writeSamples: count=" << count
                << " ret=" << ret << " sample_rate=";
      if (diff_ms > 0)
      {
        std::cout << sample_count * 1000 / diff_ms;
      }
      else
      {
        std::cout << "inf";
      }
      std::cout << " max=" << max_samp;
      std::cout << std::endl;
      return ret;
    }
    
    virtual void flushSamples(void)
    {
      std::cout << name << "::flushSamples\n";
      sinkFlushSamples();
    }
    
    virtual void resumeOutput(void)
    {
      std::cout << name << "::resumeOutput\n";
      sourceResumeOutput();
    }
    
    virtual void allSamplesFlushed(void)
    {
      std::cout << name << "::allSamplesFlushed\n";
      sourceAllSamplesFlushed();
    }
    
  protected:
    
  private:
    std::string name;
    struct timeval start_time;
    uint64_t sample_count;
    
    AudioDebugger(const AudioDebugger&);
    AudioDebugger& operator=(const AudioDebugger&);
    
}; /* AudioDebugger */
 
 
} /* namespace */
 
#endif /* AUDIO_DEBUGGER_INCLUDED */
 
 
 
/*
 * This file has not been truncated
 */