baciTestUtils.h

Go to the documentation of this file.

#ifndef baciTestUtils_h
#define baciTestUtils_h

/*******************************************************************************
* ALMA - Atacama Large Millimiter Array
* (c) European Southern Observatory, 2004 
*
*This library is free software; you can redistribute it and/or
*modify it under the terms of the GNU Lesser General Public
*License as published by the Free Software Foundation; either
*version 2.1 of the License, or (at your option) any later version.
*
*This library 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
*Lesser General Public License for more details.
*
*You should have received a copy of the GNU Lesser General Public
*License along with this library; if not, write to the Free Software
*Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
*
* "@(#) $Id: baciTestUtils.h,v 1.104 2008/10/01 02:26:45 cparedes Exp $"
*
* who       when      what
* --------  --------  ----------------------------------------------
* bjeram 2003-06-06 added baciTestCBpattern
* msekoran 2002-02-07 Added ComponentAShutdown class.
* gchiozzi 2001-10-19 Created
*/

/************************************************************************
 *
 *----------------------------------------------------------------------
 */

#ifndef __cplusplus
#error This is a C++ include file and cannot be used from plain C
#endif

#include <tao/corba.h>
#include <ace/Read_Buffer.h>

#include <string>
#include <baci.h>

class baciTestCBvoid: public virtual POA_ACS::CBvoid
{
  public:
    baciTestCBvoid(std::string _prop) : prop(_prop) {}
 
    virtual void working (const ACSErr::Completion & c,
                  const ACS::CBDescOut & desc
                  )
        {
            ACS_SHORT_LOG((LM_INFO, "(%s::CBvoid::working)", prop.c_str()));
        }
 
    virtual void done (const ACSErr::Completion & c,
               const ACS::CBDescOut & desc
                )
        {
            ACS_SHORT_LOG ((LM_INFO, "(%s::CBvoid::done)", prop.c_str()));
        }
 
    virtual CORBA::Boolean negotiate (ACS::TimeInterval time_to_transmit,
                              const ACS::CBDescOut & desc
                              )
        {
            return true;
        }

  protected:
    std::string prop;
 
}; /* end baciTestCBvoid */ 

class baciTestCBdouble: public virtual POA_ACS::CBdouble 
{

  public:
    baciTestCBdouble(std::string _prop, int c=5, int dc=1) : prop(_prop), count(c), done_c(dc) {}

    virtual void working (
        CORBA::Double value,
        const ACSErr::Completion & c,
        const ACS::CBDescOut & desc
        )
        {
            if (count>0)
                {
                CompletionImpl completion(c);
                if (completion.isErrorFree())
                    {
                    ACS_SHORT_LOG((LM_INFO, "(%s::CBdouble::working) desc.id_tag: %u Value: %f TimeStamp: %s", 
                                   prop.c_str(), (unsigned)desc.id_tag, value, getStringifiedUTC(c.timeStamp).c_str()));
                    }
                else
                    {
                    ACS_SHORT_LOG((LM_INFO, "(%s::CBdouble::working) desc.id_tag: %u TimeStamp: %s containes an error", prop.c_str(), (unsigned)desc.id_tag, getStringifiedUTC(c.timeStamp).c_str()));
                    completion.log();
                    }//if-else
                }
            count--;
        }

    virtual void done (
        CORBA::Double value,
        const ACSErr::Completion & c,
        const ACS::CBDescOut & desc
        )
        {           
            if (done_c > 0 )
                {
            ACS_SHORT_LOG((LM_INFO, "(%s::CBdouble::done) desc.id_tag: %u Value: %f TimeStamp: %s", 
                           prop.c_str(), (unsigned)desc.id_tag, value, getStringifiedUTC(c.timeStamp).c_str()));
                }//if
            done_c--;
        }


    virtual CORBA::Boolean negotiate (
        ACS::TimeInterval time_to_transmit,
        const ACS::CBDescOut & desc
        )
        { 
            return 1; 
        }

    int getCount(){ return count+done_c;}
  protected:
    std::string prop;
    int count, done_c;

}; /* end baciTestCBdouble */ 

class baciTestCBfloat: public virtual POA_ACS::CBfloat
{

  public:
    baciTestCBfloat(std::string _prop, int c=5, int dc=1) : prop(_prop), count(c), done_c(dc) {}

    virtual void working (
        CORBA::Float value,
        const ACSErr::Completion & c,
        const ACS::CBDescOut & desc
        )
        {
            if (count>0)
                {
            ACS_SHORT_LOG((LM_INFO, "(%s::CBfloat::working) desc.id_tag: %u Value: %f TimeStamp: %s", 
                           prop.c_str(), (unsigned)desc.id_tag, value, getStringifiedUTC(c.timeStamp).c_str()));
                }
            count--;
        }

    virtual void done (
        CORBA::Float value,
        const ACSErr::Completion & c,
        const ACS::CBDescOut & desc
        )
        {           
            if (done_c > 0 )
                {
            ACS_SHORT_LOG((LM_INFO, "(%s::CBfloat::done) desc.id_tag: %u Value: %f TimeStamp: %s", 
                           prop.c_str(), (unsigned)desc.id_tag, value, getStringifiedUTC(c.timeStamp).c_str()));
                }//if
            done_c--;
        }


    virtual CORBA::Boolean negotiate (
        ACS::TimeInterval time_to_transmit,
        const ACS::CBDescOut & desc
        )
        { 
            return 1; 
        }

    int getCount(){ return count+done_c;}
  protected:
    std::string prop;
    int count, done_c;

}; /* end baciTestCBfloat */ 

class baciTestCBpattern: public virtual POA_ACS::CBpattern 
{

  public:
    baciTestCBpattern(std::string _prop, int c=5, int dc=1) : prop(_prop), count(c), done_c(dc) {}

    virtual void working (
        ACS::pattern value,
        const ACSErr::Completion & c,
        const ACS::CBDescOut & desc
        )
        {
            if (count>0)
                {
            ACS_SHORT_LOG((LM_INFO, "(%s::CBpattern::working) desc.id_tag: %u Value: %llu TimeStamp: %s", 
                           prop.c_str(), (unsigned)desc.id_tag, value, getStringifiedUTC(c.timeStamp).c_str()));
                }
            count--;
        }

    virtual void done (
        ACS::pattern value,
        const ACSErr::Completion & c,
        const ACS::CBDescOut & desc
        )
        {           
            if (done_c > 0 )
                {
            ACS_SHORT_LOG((LM_INFO, "(%s::CBpattern::done) desc.id_tag: %u Value: %llu TimeStamp: %s", 
                           prop.c_str(), (unsigned)desc.id_tag, value, getStringifiedUTC(c.timeStamp).c_str()));
                }//if
            done_c--;
        }


    virtual CORBA::Boolean negotiate (
        ACS::TimeInterval time_to_transmit,
        const ACS::CBDescOut & desc
        )
        { 
            return 1; 
        }

    int getCount(){ return count+done_c;}
  protected:
    std::string prop;
    int count, done_c;

}; /* end baciTestCBdouble */ 

int write_iors_to_file (const int count, 
                        CORBA::String_var name[], 
                        CORBA::String_var type[], 
                        CORBA::String_var ior[]);
int read_IOR_from_file (std::string device, std::string &readIOR);

class CORBAShutdown
{
  public:
    typedef void (*ShutdownFunction)();

    static void setShutdownFunction(ShutdownFunction function);
    static void shutdown();

  private:
    static ShutdownFunction m_func;
    
};

#endif   /* baciTestUtils_h */