hrpEC.h

Go to the documentation of this file.

// -*- C++ -*-
#ifndef hrpEC_h
#define hrpEC_h

#include <rtm/RTC.h>

#include <coil/Mutex.h>
#include <coil/Condition.h>
#include <coil/Task.h>

#include <rtm/Manager.h>
#include <rtm/PeriodicExecutionContext.h>

#include "hrpsys/idl/ExecutionProfileService.hh"

#ifdef __QNX__
using std::fprintf;
#endif

namespace RTC
{
  class hrpExecutionContext
#ifndef OPENRTM_VERSION_TRUNK
      : public virtual PeriodicExecutionContext,
#else
      : public virtual RTC_exp::PeriodicExecutionContext,
#endif
        public virtual POA_OpenHRP::ExecutionProfileService,
        public virtual PortableServer::RefCountServantBase
  {
  public:
    hrpExecutionContext();
    virtual ~hrpExecutionContext();
    virtual int svc(void);
#ifdef OPENRTM_VERSION_TRUNK
    virtual void tick(){}
#endif
    void activate ();

    OpenHRP::ExecutionProfileService::Profile *getProfile();
    OpenHRP::ExecutionProfileService::ComponentProfile getComponentProfile(RTC::LightweightRTObject_ptr obj);
    void resetProfile();
    //
    bool enterRT();
    bool exitRT();
    bool waitForNextPeriod();
  private:
    template <class T>
    void getProperty(coil::Properties& prop, const char* key, T& value)
    {
    if (prop.findNode(key) != 0)
      {
        T tmp;
        if (coil::stringTo(tmp, prop[key].c_str()))
          {
            value = tmp;
          }
      }
    }
    void printRTCProcessingTime (std::vector<double>& processes)
    {
      fprintf(stderr, "[hrpEC] ");
      for (unsigned int i=0; i< processes.size(); i++){
        fprintf(stderr, "%s(%4.2f), ", rtc_names[i].c_str(),processes[i]*1e3);
      }
      fprintf(stderr, "[ms]\n");
    };
    int svc_wrapped (void);

    OpenHRP::ExecutionProfileService::Profile m_profile;
    struct timeval m_tv;
    int m_priority;
    int m_cpu;
    std::vector<std::string> rtc_names;
    volatile bool m_thread_pending;
  };
};

extern "C"
{
  void hrpExecutionContextInit(RTC::Manager* manager);
};

#endif // hrpEC_h