hlrc

/*

* This file is part of hlrc_server

*

* Copyright(c) sschulz <AT> techfak.uni-bielefeld.de

* http://opensource.cit-ec.de/projects/hlrc_server

*

* This file may be licensed under the terms of the

* GNU General Public License Version 3 (the ``GPL''),

* or (at your option) any later version.

*

* Software distributed under the License is distributed

* on an ``AS IS'' basis, WITHOUT WARRANTY OF ANY KIND, either

* express or implied. See the GPL for the specific language

* governing rights and limitations.

*

* You should have received a copy of the GPL along with this

* program. If not, go to http://www.gnu.org/licenses/gpl.html

* or write to the Free Software Foundation, Inc.,

* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

*

* The development of this software was supported by the

* Excellence Cluster EXC 277 Cognitive Interaction Technology.

* The Excellence Cluster EXC 277 is a grant of the Deutsche

* Forschungsgemeinschaft (DFG) in the context of the German

* Excellence Initiative.

*

*/

#include "Arbiter.h"

#include "AudioPlayerLibAO.h"

#include "AudioPlayerRSB.h"

#include <boost/algorithm/string/predicate.hpp>

using namespace boost;

using namespace std;

Arbiter::Arbiter(std::string audio_output){

    //initialize audio player:

    if (iequals(audio_output, "none")){

        //allow none for no sound output

        audio_player = NULL;

    }else if (iequals(audio_output.substr(0,3), "rsb")){

        #ifdef RSB_SUPPORT

            audio_player = new AudioPlayerRSB(audio_output);

        #else

            printf("> ERROR: hlc is compiled without RSB support, RSB audio transport not available, defaulting to libao (default output!)\n");

            audio_player = new AudioPlayerLibAO("");

        #endif

    }else{

        audio_player = new AudioPlayerLibAO(audio_output);

    }

    //set default emotion:

    emotion_config_current.init_sad();

    emotion_config_current.set_duration(2000);

    emotion_config_default.init_neutral();

    utterance = boost::shared_ptr<Utterance>(new Utterance());

}

Arbiter::~Arbiter(){

}

void Arbiter::set_default_emotion(EmotionState e){

    //lock access

    mutex::scoped_lock scoped_lock(emotion_config_default_mutex);

    //update our config, ignore duration as this is the default emotion

    emotion_config_default.select_config(e.value);

    printf("> stored default emotion\n");

}

void Arbiter::set_current_emotion(EmotionState e){

    //lock access

    mutex::scoped_lock scoped_lock(emotion_config_current_mutex);

    //this will set a emotion override for a given time, after the timeout

    //we will return to the default emotion state:

    emotion_config_current.select_config(e.value);

    emotion_config_current.set_duration(e.duration);

    printf("> stored current emotion (val=%d, duration = %dms)\n",e.value, e.duration);

}

void Arbiter::set_mouth_config(MouthConfig m){

    //lock access

    mutex::scoped_lock scoped_lock(mouth_config_override_mutex);

    mouth_config = m;

}

void Arbiter::set_gaze_target(humotion::GazeState target){

    //lock access

    mutex::scoped_lock scoped_lock(requested_gaze_state_mutex);

    requested_gaze_state = target;

}

void Arbiter::set_mouth_target(humotion::MouthState target){

    //lock access

    mutex::scoped_lock scoped_lock(requested_mouth_state_mutex);

    requested_mouth_state = target;

}

//! note: this is blocking!

void Arbiter::play_animation(boost::shared_ptr<Animation> incoming_animation){

    //incoming animation, check if this would conflict with any pending animations:

    //lock access & iterate over vector:

    mutex::scoped_lock lock_av(active_animation_vector_mutex);

    active_animation_vector_t::iterator it;

    for(it = active_animation_vector.begin(); it<active_animation_vector.end(); it++){

        boost::shared_ptr<Animation> current_ani = *it;

        //check if the running animation collides with the incoming animation:

        if (current_ani->collides_with(incoming_animation.get())){

            //this would fail, we can not play this animation right now!

            throw runtime_error("incoming animation collides with unfinished active animation");

            return;

        }

    }

    //ok, fine. no other animations are active that would collide with the new request

    //thus it is safe to enqueue this item:

    active_animation_vector.push_back(incoming_animation);

    //unlock mutex

    lock_av.unlock();

    //start playback!

    incoming_animation->start();

    //block until ani was played back

    while(incoming_animation->is_active()){

        //printf("A"); fflush(stdout);

        usleep(1*1000); //1ms, save cpu cycles

    }

    //ok, it finished. we can safely remove it now:

    lock_av.lock();

    for(it = active_animation_vector.begin(); it<active_animation_vector.end();){

        boost::shared_ptr<Animation> current_ani = *it;

        if (*it == incoming_animation){

            //printf(">match -> remove incoming ani again\n");

            it = active_animation_vector.erase(it);

          }else{

            ++it;

          }

    }

}

void Arbiter::speak(boost::shared_ptr<Utterance> u){ //, ao_sample_format audio_format, char *audio_data, unsigned int audio_len){

    //lock audio playback as such:

    mutex::scoped_lock scoped_lock_audio(audio_player_mutex);

    //lock utterance & store data:

    mutex::scoped_lock scoped_lock(utterance_mutex);

    utterance = u;

    scoped_lock.unlock();

    //start audio playback, this function returns once we started playback

    if (audio_player == NULL){

        printf("> audio_player disabled, not speaking '%s'\n", u.get()->get_text().c_str());

    }else{

        audio_player->play(utterance->get_audio_data());

    }

    utterance->start_playback();

    //wait until audio playback was finished:

    if (audio_player != NULL){

        while(audio_player->is_playing()){

            //save some cpu cycles:

            usleep(1*1000); //1ms

        }

    }

    //in case the audio output fails, we end up here before the utterance is finished.

    //so check now if the utterance finished as well:

    while (utterance->is_playing()){

        //save some cpu cycles:

        usleep(1*1000); //1ms

    }

}

bool Arbiter::speak_active(){

    if (audio_player == NULL){

        return false;

    }else{

        return audio_player->is_playing();

    }

}

void Arbiter::arbitrate(){

    //handle arbitration, DO NOT RE-ORDER these calls!

    //try to process all incoming requests

    override_by_emotion();

    //overwrite with mouth targets from outside:

    override_by_mouth();

    //lip animation

    override_by_utterance();

    //animations

    override_by_animation();

    //gaze target is set by requested_gaze_target

    override_by_gaze();

}

void Arbiter::override_by_utterance(){

    //fetch MouthState by utterance:

    if (!utterance->is_playing()){

        //not playing -> return

        return;

    }

    //fetch symbol

    string symbol = utterance->currently_active_phoneme();

    if ((symbol.empty()) || (symbol == "")){

        return;

    }

    //fetch config

    mouth_config.init_by_symbol(symbol);

    //overwrite mouth with offsets from utterance player

    mouth_config.apply_on_mouth_state(&mouth_state);

}

void Arbiter::override_by_mouth(){

    //external mouth requests can overwrite the mouth targets!

    if ((requested_mouth_state.position_center + requested_mouth_state.position_left + requested_mouth_state.position_right) > 0.0){

        //values given -> override emotion data

        mouth_state = requested_mouth_state;

    }

    //requested_mouth_state.dump();

    //mouth_state.dump();

}

void Arbiter::override_by_gaze(){

    //copy from requested target:

    gaze_state.pan   = requested_gaze_state.pan;

    gaze_state.tilt  = requested_gaze_state.tilt;

    gaze_state.roll  = requested_gaze_state.roll;

    gaze_state.gaze_type = requested_gaze_state.gaze_type;

    gaze_state.timestamp = requested_gaze_state.timestamp;

    gaze_state.vergence  = requested_gaze_state.vergence;

    //add offset values from user:

    gaze_state.pan_offset  += requested_gaze_state.pan_offset;

    gaze_state.tilt_offset += requested_gaze_state.tilt_offset;

}

void Arbiter::override_by_emotion(){

    //lock access

    mutex::scoped_lock scoped_lock1(emotion_config_default_mutex);

    mutex::scoped_lock scoped_lock2(emotion_config_current_mutex);

    EmotionConfig *emotion_target = &emotion_config_default;

    //which emotion is active?

    if (emotion_config_current.is_active()){

        //current emotion is not timed out, override default

        emotion_target = &emotion_config_current;

    }

    //emotions will set the mouth state here (will be overwritten by speak)

    mouth_state = emotion_target->mouth_override;

    //emotions will add an offset to the gaze state:

    //pan,tilt,roll will be overwritten by override_by_gaze() we only keep the offset values from this!

    //FIXME: change to eyelid opening  upper/lower once humotion supports it

    //eyebrow angles come from this

    gaze_state = emotion_target->gaze_override;

    //gaze_state.dump();

    //IMPORTANT: clear request from emotion target:

    emotion_target->gaze_override.eyeblink_request_left = 0;

    emotion_target->gaze_override.eyeblink_request_right = 0;

}

void Arbiter::override_by_animation(){

    //lock access & iterate over vector:

    mutex::scoped_lock lock_av(active_animation_vector_mutex);

    active_animation_vector_t::iterator it;

    for(it = active_animation_vector.begin(); it<active_animation_vector.end(); it++){

        boost::shared_ptr<Animation> current_ani = *it;

        //gaze_state.dump();

        current_ani->apply_on_gazestate(&gaze_state);

        //gaze_state.dump();

    }

}

humotion::GazeState Arbiter::get_gaze_state(){

    return gaze_state;

}

humotion::MouthState Arbiter::get_mouth_state(){

    return mouth_state;

}