vconnectstand/src/corpusManager.cpp

/*
 * corpusManager.cpp
 * Copyright (C) 2010- HAL,
 * Copyright (C) 2011-2012 kbinani.
 *
 *  This files is a part of v.Connect.
 * corpusManager is a class that controls corpus based on UTAU.
 * This class convert UTAU WAVE corpus into WORLD specgrams.
 *
 * These files are 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.
 */
#include <tuple>
#include "Configuration.h"
#include "corpusManager.h"
#include "vConnectPhoneme.h"
#include "utau/UtauDB.h"
#include "vsq/Sequence.h"

using namespace vconnect;

corpusManager::corpusManager()
{
    mUtauDB = NULL;
    mBrightness = 64;
    mFrequency = 440.0;
}

void corpusManager::analyze( vector<tuple<string, int>> &phonemes )
{
    int size = phonemes.size();
    for( int i = 0; i < size; i++ ){
        string lyric = std::get<0>(phonemes[i]);
        int note_number = std::get<1>(phonemes[i]);
        getPhoneme(lyric, note_number);
        cout << "corpusManager::analyze; lyric=" << lyric << endl;
    }
    for( int i = 0; i < mAppendCorpus.size(); i++ ){
        if( mAppendCorpus[i] ){
            mAppendCorpus[i]->analyze(phonemes);
        }
    }

    mIsAppend = mEnableExtention = mEnableBrightness = mEnableFrequency = false;
}

corpusManager::~corpusManager()
{
    Map<string, phoneme *>::iterator i;
    for( i = objectMap.begin(); i != objectMap.end(); i++ ){
        if( i->second ){
            if( i->second->p ){
                delete i->second->p;
                i->second->p = NULL;
            }
            delete i->second;
            i->second = NULL;
        }
    }
    for( int j = 0; j < mAppendCorpus.size(); j++){
        delete mAppendCorpus[j];
    }

    // うーん…
    if(mIsAppend){
        delete mUtauDB;
    }
}

corpusManager::phoneme *corpusManager::getPhoneme(string const& lyric, int note_number)
{
    phoneme *ret = NULL;
    Map<string, phoneme *>::iterator i;
    string alphabet, vtd_path;

#ifdef STND_MULTI_THREAD
    if( hMutex ){
        hMutex->lock();
    }
#endif

    // まず vConnectPhoneme の有無をチェック．
    i = objectMap.find( lyric );

    if( i != objectMap.end() ){         // 希望のデータが存在するのでそれを返す．
#ifdef STND_MULTI_THREAD
        if( hMutex ){
            hMutex->unlock();
        }
        if( i->second->isProcessing ){        // あるにはあるけど分析中なので待機．
            if( i->second->waitHandle ){
                i->second->waitHandle->lock();
                // ロックが取得できたってことは分析終了なので即解放
                i->second->waitHandle->unlock();
                delete i->second->waitHandle;
            }
            i->second->waitHandle = NULL;
        }
#endif

        if( i->second->isValid ){
            // 有効性を見る．
            ret = i->second;
        }else{
            ret = NULL;
        }
    }else{                              // 希望するデータが存在しないので作成する．
        UtauParameter parameters;
        phoneme *target = new phoneme;  // ハッシュには先に突っ込んでしまう．
        objectMap.insert( make_pair( lyric, target ) );

#ifdef STND_MULTI_THREAD
        target->isProcessing = true;
        target->waitHandle = new Mutex();// CreateEvent(NULL,TRUE,FALSE,NULL);
        target->waitHandle->lock();
        if( hMutex ){
            hMutex->unlock();
        }
#endif

        // UTAU の原音設定が無ければ読み込みを行わない．
        if (mUtauDB->getParams(parameters, lyric, note_number)) {
            target->p = new vConnectPhoneme;
            string path = mDBPath + parameters.fileName;
            bool bResult = false;
            if( parameters.isWave ){
                double framePeriod = Configuration::getMilliSecondsPerFrame();
                bResult = target->p->readRawWave( mDBPath, &parameters, framePeriod );
            }else{
                bResult = target->p->readPhoneme( path.c_str() );
            }
            if( bResult ){
                target->isValid = true;
                target->fixedLength = parameters.msFixedLength;
                ret = target;
                target->brightness = mBrightness;
                target->frequency = mFrequency;
                target->enableBrightness = mEnableBrightness;
                target->enableFrequency = mEnableFrequency;
            }
        }
        target->isProcessing = false;

#ifdef STND_MULTI_THREAD
        if( target->waitHandle ){
            target->waitHandle->unlock();
        }
#endif
    }
    return ret;
}


corpusManager::phoneme *corpusManager::getPhoneme(string const& lyric, int note_number, list<phoneme*> &phonemeList)
{
    phoneme *p = NULL;

    // 有効な音素なら追加する．
    if((p = getPhoneme(lyric, note_number)) && p->isValid && p->p){
        p->enableBrightness = mEnableBrightness;
        p->enableFrequency = mEnableFrequency;
        phonemeList.push_back(p);
    }

    // アペンドがあるならそれを追加．
    for(int i = 0; i < mAppendCorpus.size(); i++){
        if(mAppendCorpus[i] && p){
            p->children = mAppendCorpus[i]->getPhoneme(lyric, note_number, phonemeList);
        }
    }
    return p;
}

void corpusManager::setUtauDB( UtauDB *p, RuntimeOption &options )
{
    string tmp;
    mUtauDB = p;
    if( p ){
        this->mDBPath = p->getOtoIniPath();
    }
    tmp = "vConnect.ini";
    mEnableExtention =  setting.readSetting( mDBPath, tmp, options.getEncodingOtoIni().c_str()); // 文字コード指定は暫定処置

    if(mEnableExtention){
        setCorpusSetting(setting.getLibrarySetting(SETTING_BASE));
        librarySetting *brightnessSetting = setting.getLibrarySetting(SETTING_BRIGHTNESS);
        if(mEnableBrightness && brightnessSetting){
            UtauDB *db = new UtauDB(
                Path::combine( brightnessSetting->path, "oto.ini" ),
                options.getEncodingOtoIni()
            );
            mAppendCorpus.resize(1, NULL);
            mAppendCorpus[0] = new corpusManager();
            mAppendCorpus[0]->setBrightness( brightnessSetting->brightness );
            mAppendCorpus[0]->setUtauDB( db, options );
            mAppendCorpus[0]->setIsAppend(true);
        }
    }
}

bool corpusManager::checkEnableExtention()
{
    return mEnableExtention;
}

void corpusManager::setCorpusSetting(librarySetting *setting)
{
    if(!setting){
        mEnableBrightness = mEnableFrequency = false;
        return;
    }
    mEnableBrightness = true;
    mBrightness = setting->brightness;

    // 暫定．
    mEnableFrequency = false;
    mFrequency = setting->frequency;
}