root/ossiedev/branches/ttsou/dist/components/_base_/_base_.cpp @ 8632

/****************************************************************************

Copyright 2007 Virginia Polytechnic Institute and State University

This file is part of the OSSIE _base_.

OSSIE _base_ is free software; you can redistribute it and/or _base_ify
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.

OSSIE _base_ is 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.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with OSSIE _base_; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

****************************************************************************/

#include <string>
#include <iostream>
#include "_base_.h"

_base__i::_base__i(const char *uuid, omni_condition *condition) : 
    Resource_impl(uuid), component_running(condition) 
{
    p_in = complexShort_p_sptr(new standardInterfaces_i::complexShort_p("samples_in"));
    p_out = complexShort_u_sptr(new standardInterfaces_i::complexShort_u("samples_out"));
}

CORBA::Object_ptr _base__i::getPort( const char* portName )
throw (CORBA::SystemException, CF::PortSupplier::UnknownPort)
{
    DEBUG(3, _base_, "getPort() invoked with " << portName)
    
    CORBA::Object_var p;

    p = p_in->getPort(portName);

    if (!CORBA::is_nil(p))
        return p._retn();

    p = p_out->getPort(portName);

    if (!CORBA::is_nil(p))
        return p._retn();

    /*exception*/
    throw CF::PortSupplier::UnknownPort();
}

void _base__i::start()
throw (CORBA::SystemException, CF::Resource::StartError)
{
    DEBUG(3, _base_, "start() invoked")

    if (!processing_active) {
        processing_thread = new omni_thread(process_data, (void*) this);
        processing_active = true;
        processing_thread->start();
    }
}

void _base__i::stop()
throw (CORBA::SystemException, CF::Resource::StopError) 
{  
    DEBUG(3, _base_, "stop() invoked")

    processing_active = false;
}

void _base__i::releaseObject()
throw (CORBA::SystemException, CF::LifeCycle::ReleaseError)
{
    DEBUG(3, _base_, "releaseObject() invoked")
    
    component_running->signal();
}

void _base__i::initialize()
throw (CF::LifeCycle::InitializeError, CORBA::SystemException)
{
    DEBUG(3, _base_, "initialize() invoked")
}

void _base__i::configure(const CF::Properties& props)
throw (CORBA::SystemException, CF::PropertySet::InvalidConfiguration,
    CF::PropertySet::PartialConfiguration)
{
    DEBUG(3, _base_, "configure() invoked")
    
    std::cout << "props length : " << props.length() << std::endl;

    for (unsigned int i = 0; i <props.length(); i++) {
        std::cout << "Property id : " << props[i].id << std::endl;
    }
}

_base__i::~_base__i(void)
{

}

void _base__i::process_data(void *data)
{
    DEBUG(3, _base_, "ProcessData() invoked")

    _base__i *_base_ = (_base__i *) data;

    PortTypes::ShortSequence i_out, q_out;
    PortTypes::ShortSequence *i_in(NULL), *q_in(NULL);

    while (_base_->processing_active) {
        _base_->p_in->getData(i_in, q_in);

        _base_->p_in->bufferEmptied();
        _base_->p_out->pushPacket(i_out, q_out);        
    }

    DEBUG(3, _base_, "ProcessData() exiting")
    _base_->processing_active = false;
    _base_->processing_thread->exit();
}