---

/home/vlg/develop/gwavmerger/src/LoadProgress.cpp

Go to the documentation of this file.

// -*- c++ -*-
//------------------------------------------------------------------------------
//                              LoadProgress.cpp
//------------------------------------------------------------------------------
// $Id: LoadProgress.cpp,v 1.6 2003/02/09 23:32:35 vlg Exp $
//------------------------------------------------------------------------------
//  Copyright (c) 2002 by Vladislav Grinchenko
//
//  This program 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
//  2 of the License, or (at your option) any later version.
//------------------------------------------------------------------------------
#ifdef HAVE_CONFIG_H
#    include "config.h"
#endif

#include <libgnomeui/gnome-dialog.h>

#include <gtkmm/buttonbox.h>
#include <gtkmm/box.h>
#include <gtkmm/label.h>

#include <vector>
#include <algorithm>

#include <assa/CmdLineOpts.h>
#include <assa/Fork.h>
#include <assa/SigHandlers.h>

#include "LoadProgress.h"
#include "MainWindow.h"

using namespace ASSA;


LoadProgress::LoadProgress () 
    : m_dialog (NULL), Message (NULL), Progress (NULL),
      m_dp (0), m_max_val (0), m_entries (0), m_count (0)
{  
    trace ("LoadProgress::LoadProgress");

    m_dialog = this;
    Gtk::Button* cancel_button = m_dialog->add_button(Gtk::Stock::CANCEL, 0);

    Gtk::Label *InfoLabel = 
        manage(new class Gtk::Label("Processing File :"));   
    Message = manage(new class Gtk::Label());

    Gtk::HBox *hbox1 = manage(new class Gtk::HBox(false, 0));
    Progress = manage(new class Gtk::ProgressBar());

    Gtk::VBox *vbox1 = manage(new class Gtk::VBox(false, 4));
//    cancel_button->set_flags(GTK_CAN_FOCUS);
    InfoLabel->set_alignment(0.5, 0.5);
    InfoLabel->set_padding(0, 0);
    InfoLabel->set_justify(Gtk::JUSTIFY_LEFT);
    Message->set_alignment(0.5, 0.5);
    Message->set_padding(0, 0);
    hbox1->pack_start(*InfoLabel, false, false, 6);
    hbox1->pack_start(*Message, false, false, 0);
    Progress->set_size_request (235, 23);
    vbox1->pack_start(*hbox1, false, false, 0);
    vbox1->pack_start(*Progress, false, false, 0);
    m_dialog->get_vbox()->set_spacing(8);
    m_dialog->get_vbox()->pack_start(*vbox1);
//    m_dialog->set_policy(false, false, false);

    Gtk::HButtonBox *dialog_action_area1 = m_dialog->get_action_area ();
    dialog_action_area1->set_spacing(8); 
    InfoLabel->show();
    Message->show();
    hbox1->show();
    Progress->show();
    vbox1->show();
    m_dialog->show();
    cancel_button->signal_clicked ().connect(
        SigC::slot(*(static_cast<class LoadProgress*>(this)), 
                   &LoadProgress::on_cancel_clicked));
}

//==============================================================================
// Set up iteration loop. The iteration loop is a re-entrant function
// process_file ().
//------------------------------------------------------------------------------
int

LoadProgress::init (const string& subdir_, const string& prefix_, const string& proj_path_)
{
    trace ("LoadProgress::init");

    string name;        // absolute file name
    m_dir = proj_path_ + "/" + subdir_;
    m_prefix = prefix_;

    if ((m_dp = opendir (m_dir.c_str ())) == NULL) {
        string msg ("Can't open directory\n\"");
        msg += m_dir + string ("\"");
        Gtk::MessageDialog emsg (msg, MESSAGE_ERROR);
        emsg.run ();
        return -1;
    }
    struct dirent* dirp = 0;
    while ((dirp = readdir (m_dp)) != NULL) {
        m_entries++;
    }
    rewinddir (m_dp);
    
    /* Setup idle work callback */
    Glib::signal_idle ().connect ((slot (*this, &LoadProgress::process_file)));
    dump ();
    return 0;
}

//==============================================================================
// Idle work - called by Gtk+ event loop periodically.
// Execute one iteration by processing a single WAV file.
// Then, advance the progress dialog and change progress label
//------------------------------------------------------------------------------
bool

LoadProgress::process_file (void)
{
    trace ("LoadProgress::process_file");

    struct dirent* dirp = 0;
    string name;
    string wavinfo_args;
    string::size_type idx;
    
 skip:
    if (m_dp == NULL || (dirp = readdir (m_dp)) == NULL) {
        /*
         * We are at the end of the list; 
         * cancel dialog and idle work callback
         */
        closedir (m_dp);
        m_dp = NULL;
        sort (m_file_list.begin (), m_file_list.end ());
        // cause_close ();
        response (Gtk::RESPONSE_NONE);
        return false;
    }
    m_count++;
    name = dirp->d_name;

    if (name == "." || name == ".." ||
        name.find ("_pause.wav") != std::string::npos)
    {
        DL((TRACE,"Skiping \"%s\"\n", name.c_str ()));
        goto skip;          
    }
    wavinfo_args = "--silent " + m_dir + "/" + name;

    DL((TRACE,"Processing file \"%s\"\n", name.c_str ()));
    Message->set_text (name.c_str ());
    DL((TRACE,"Progress: %d / %d : %5.2f\n", m_count, m_entries,
        gfloat (m_count) / m_entries));

    Progress->set_fraction (gfloat (m_count) / m_entries);

    DL((TRACE,"Call fork_exec(wavinfo, \"%s\")\n",
        wavinfo_args.c_str ()));

    if (Fork::fork_exec ("wavinfo", wavinfo_args, true) != 0) {
        DL((APP,"Not a WAV file! Skipping \"%s\"\n", name.c_str ()));
        goto skip;
    }

    /* File name is of the format: [prefix][number].wav.
       For example, ru25_04.wav : prefix = "ru25_", number = 4,
       extension = ".wav".
       Remove prefix and extension, adjust maximun seen number and
       add number to the file list.
    */
    DL((APP,"Parsing file name \"%s\"\n", name.c_str ()));
    DL((APP,"Removing prefix \"%s\"\n", m_prefix.c_str ()));

    if ((idx = name.find (m_prefix)) == 0) {         // remove [prefix]
        DL((APP,"Prefix found in position = %d\n",idx));

        name.replace (0, m_prefix.size (), "");
        idx = name.find ('.');                      // remove '.wav' portion
        if (idx != string::npos) {
            DL((APP,"Found '.' in pos = %d\n", idx));
            if (name.substr (idx) != ".wav") {
                DL((APP,"Extension \"%s\" != \".wav\"\n", 
                    name.substr(idx).c_str ()));
                DL((APP,"Skipping file\n"));
                goto skip;
            }
            DL((APP,"Removing extension; name = \"%s\"\n", name.c_str ()));
            name.replace (idx, name.size (), "");
        }
        DL((APP,"And the number is: %d\n", atoi (name.c_str ())));
        m_max_val = max2 (m_max_val, atoi (name.c_str ()));
        DL((APP,"New max_val = %d\n", m_max_val));
        m_file_list.push_back (name);
        DL((APP,"Added \"%s\" to the file list\n", name.c_str ()));
    }
    else {
        DL((APP, "Prefix is not found!\n"));
    }
    return true;        // continue processing
}

//==============================================================================
// Run the dialog: show progress as files are tested
//------------------------------------------------------------------------------
int

LoadProgress::run_load (const string&   subdir_,
          const string&   prefix_,
          const string&   proj_path_,
          vector<string>& file_list_)
{
    trace ("LoadProgress::run");

    if (init (subdir_, prefix_, proj_path_) == -1) {
        return -1;
    }

    run ();
    file_list_ = m_file_list;   // copy the result
    return m_max_val;
}

void 

LoadProgress::dump (void) const
{
    trace("LoadProgress::dump");

    DL((TRACE,"m_dir     : \"%s\"\n", m_dir.c_str ()));
    DL((TRACE,"m_prefix  : \"%s\"\n", m_prefix.c_str ()));
    DL((TRACE,"m_entries : %d\n",     m_entries));
    DL((TRACE,"m_count   : %d\n",     m_count));

}

---