---

/home/vlg/develop/gwavmerger/raven/WavPause.cpp

Go to the documentation of this file.

// -*- c++ -*-
// Generated by assa-genesis
//------------------------------------------------------------------------------
// $Id: WavPause.cpp,v 1.4 2003/02/07 05:15:08 vlg Exp $
//------------------------------------------------------------------------------
//                            WavPause.cpp
//------------------------------------------------------------------------------
//
// Author : Vladislav Grinchenko
// Date   : Sun Dec  9 17:14:29 2001
//
//------------------------------------------------------------------------------

#include <iostream>
#include <limits.h>

#include "WavPause-main.h"
#include "WavPause.h"

using ASSA::APP;
using ASSA::ERROR;
using ASSA::TRACE;

// Static declarations mandated by Singleton class

WavPause* ASSA::Singleton<WavPause>::m_instance;
ASSA::Destroyer<WavPause> ASSA::Singleton<WavPause>::m_destroyer;

const unsigned short int WavPause::FRAME_BUFFER_SIZE = USHRT_MAX;

//------------------------------------------------------------------------------
// class info member functions
//------------------------------------------------------------------------------
void 

info::dump () const 
{
    trace("info::dump");

    DL((APP,"in_file_format = %d\n", in_file_format));
    DL((APP,"version        = %d\n", version));
    DL((APP,"sample_format  = %d\n", sample_format));
    DL((APP,"sample_width   = %d\n", sample_width));
    DL((APP,"channel_count  = %d\n", channel_count));
    DL((APP,"frame_size     = %d\n", frame_size));
    DL((APP,"sample_rate    = %f\n", sample_rate));
    DL((APP,"total_frames   = %d\n", total_frames));
}

//------------------------------------------------------------------------------
// class WavPause member functions
//------------------------------------------------------------------------------

WavPause::WavPause ()
    : m_exit_value (0),
      m_percent (false),
      m_duration (-1),
      m_multiplier (2),     // default
      m_relative (true)     // default
{
    // ---Configuration---
    rm_opt ('f', "config-file"  );
    rm_opt ('n', "instance"     );
    rm_opt ('p', "port"         );

    // ---Process bookkeeping---
    rm_opt ('b', "daemon"       );
    rm_opt ('l', "pidfile"      );
    rm_opt ('L', "ommit-pidfile");

    // Default debugging is total silence
    m_log_file = "/dev/null";
    m_debug_mask = 0;

    // ---Project-specific---
    add_opt ('o', "output-file", &m_output_file);
    add_opt ('i', "input-file",  &m_input_file);
    add_opt ('l', "duration",    &m_duration);
    add_opt ('M', "multiplier",  &m_multiplier);

    add_flag_opt ('p', "percent", &m_percent);
}

void
WavPause::initServer ()
{
    trace("WavPause::initServer");
    ASSA::Log::disable_timestamp ();

    if (m_duration > 0) {
        m_relative = false; // absolute
        DL((TRACE,"Absolute mode is enabled\n"));
        DL((TRACE,"Duration = %5.2f seconds\n", m_duration));
    }
    else {
        DL((TRACE,"Relative mode is enabled\n"));
        DL((TRACE,"Multiplier = %dx\n", m_multiplier));
    }
    DL((APP,"Service has been initialized\n"));
}

void
WavPause::processServer ()
{
    trace("WavPause::processServer");

    if (stopServer ()) {
        return;
    }

    /*------------------------------------------------------------------------
     * Initialize audio parameters
     *------------------------------------------------------------------------*/
    if (m_relative) {
        if (read_input_file () == -1) {
            DL((APP,"Failed reading input file\n"));
            set_exit_value (1);
            return;
        }
    }
    /*------------------------------------------------------------------------
     * Setup audio parameters for output stream
     *------------------------------------------------------------------------*/
    AFfilesetup out_file_setup = afNewFileSetup ();

    // Configure the file format parameter in an AFfilesetup.
    // AF_FILE_WAV: Waveform RIFF.

    afInitFileFormat (out_file_setup, m_info.in_file_format);

    // Mine is  2-bit integer (2's compliment) little endian
    afInitSampleFormat (out_file_setup, AF_DEFAULT_TRACK, 
                        m_info.sample_format, m_info.sample_width);

    // Number of channels: 2-stereo
    afInitChannels (out_file_setup, AF_DEFAULT_TRACK, m_info.channel_count);

    // Rate: 44100 Hz
    afInitRate (out_file_setup, AF_DEFAULT_TRACK, m_info.sample_rate);

    // Use default name if it is not specified with --output option
    if (m_output_file.size () == 0) {
        m_output_file = m_input_file;
        m_output_file.replace (m_output_file.find ('.'), 
                               m_output_file.size (), 
                               "_pause.wav");
    }

    /*------------------------------------------------------------------------
     * Generate pause file
     *------------------------------------------------------------------------*/

    DL((APP,"Output file: \"%s\"\n", m_output_file.c_str ()));
    unlink (m_output_file.c_str ());

    AFfilehandle out_file;

    out_file = afOpenFile (m_output_file.c_str (), "w", out_file_setup);

    if (out_file == AF_NULL_FILEHANDLE) {
        EL((ERROR,"Could not open file \"%s\" for writing\n",
            m_output_file.c_str ()));
        set_exit_value (1);
        return;
    }
    // Set the output file's virtual audio format parameters

    afSetVirtualChannels     (out_file, AF_DEFAULT_TRACK, 
                              m_info.channel_count);
    afSetVirtualSampleFormat (out_file, AF_DEFAULT_TRACK, 
                              m_info.sample_format, m_info.sample_width);
    afFreeFileSetup (out_file_setup);

    char* frame_buffer = new char [m_info.frame_size * FRAME_BUFFER_SIZE];
    memset (frame_buffer, 0, m_info.frame_size * FRAME_BUFFER_SIZE);

    DL((APP,"frame_size   = %d\n", m_info.frame_size));
    DL((APP,"total_frames = %d\n", m_info.total_frames));

    int frames_count = 0;
    int frames_write = 0;
    int frames_written = 0;
    bool aborted = false;

    if (m_relative) {       // Output lenght is a multiple of input
        m_info.total_frames *= m_multiplier; 
    }
    else {          // Output lenght is in seconds
        m_info.total_frames = long (m_info.sample_rate * m_duration);
    }

    DL((APP,"Recalculated total_frames = %d\n", m_info.total_frames));

    frames_write = m_info.total_frames > FRAME_BUFFER_SIZE ?
        FRAME_BUFFER_SIZE : m_info.total_frames;

    while (frames_count < m_info.total_frames) {
        frames_written = afWriteFrames (out_file, AF_DEFAULT_TRACK, 
                                        frame_buffer, frames_write);
        if (frames_written < 0) {
            aborted = true;
            break;
        }
        frames_count += frames_written;
        if (m_info.total_frames - frames_count < FRAME_BUFFER_SIZE) {
            frames_write = m_info.total_frames - frames_count;
        }
        if (m_percent) {    // Report percentage completed so far
            std::cout << long (frames_count * 100 / m_info.total_frames) 
                      << std::endl;
        }
    }
    if (aborted) {
        DL((APP,"afWriteFrames() failed\n"));
        set_exit_value (1);
    }

    delete [] frame_buffer;
    afCloseFile (out_file);

    m_reactor.stopReactor ();
    DL((APP,"Service stopped!\n"));
}

int

WavPause::read_input_file ()
{
    trace("WavPause::read_input_file");

    AFfilehandle in_file;

    in_file = afOpenFile (m_input_file.c_str (), "r", NULL);

    if (in_file == NULL) {
        EL((ERROR,"File \"%s\" open error\n", m_input_file.c_str ()));
        set_exit_value (1);
        return -1;
    }

    afGetSampleFormat(in_file, AF_DEFAULT_TRACK, 
                      &m_info.sample_format, &m_info.sample_width);

    m_info.in_file_format = afGetFileFormat (in_file, &m_info.version);
    m_info.channel_count  = afGetChannels   (in_file, AF_DEFAULT_TRACK);
    m_info.sample_rate    = afGetRate       (in_file, AF_DEFAULT_TRACK);
    m_info.total_frames   = afGetFrameCount (in_file, AF_DEFAULT_TRACK); 
    m_info.frame_size     = 
        (int) afGetVirtualFrameSize (in_file, AF_DEFAULT_TRACK, 1);
    
    DL((APP,"== Input File info ==\n"));
    m_info.dump ();

    afCloseFile (in_file);
    return 0;
}

---