LrmImpl.hpp

Go to the documentation of this file.

#ifndef LRMIMPL_HPP
#define LRMIMPL_HPP

#include <string>
#include <map>

#include "utils/c++/GuardedVariable.hpp"
#include "AppInfoHolder.hpp"

using std::string;
using std::map;


class LocStaticInfo;
class LocDynamicInfo;
class ExecutionSpecs;
class OfferSpecs;
class Config;

#include <iostream> //FIXME: Remove

using std::cerr;
using std::endl;

class LrmImpl{

 private:

  string grmIor;                    
  string appReposIor;               
  GuardedVariable<long> sampleInterval;    
  GuardedVariable<long> keepAliveInterval; 
  float threshold;                  
  string orbPath;                   
  string appReposIdlPath;           
  string resourceManagementIdlPath; 
  GuardedVariable<int> appId;       
  struct lua_State * clientSideState; 
  map<string, AppInfoHolder> launchedAppsInfo;
    map<string, AppInfoHolder> finishedAppsInfo;



  pthread_mutex_t launchedAppsInfoLock;
  pthread_mutex_t finishedAppsInfoLock;


  
  void copyFile(const string & srcPath, const string & dstPath);

  static void * notifyStatus(void * ptr);

  LrmImpl(const Config & config);

  static LrmImpl * singleInstance_;

  void notifyStatus();

  static void * notifyStatusWrapper(void * ptr);

  //TODO: COMMENT ME
  void cleanup();

 public:

   //TODO: COMMENT ME
   static LrmImpl & init(const Config & config);

  void updateLoop();


  void setSampleInterval(long seconds){ sampleInterval.set(seconds); }

  void setKeepAliveInterval(long seconds) { keepAliveInterval.set(seconds); }


   void remoteExecutionRequest(ExecutionSpecs execSpecs);

  //TODO: COMMENT ME
  AppInfoHolder appInfo(const string & appId){
    pthread_mutex_lock(&finishedAppsInfoLock);
      AppInfoHolder appInfo = finishedAppsInfo[appId];
    pthread_mutex_unlock(&finishedAppsInfoLock);
     return appInfo;
  }

  //TODO: COMMENT ME
  void removeAppInfo(const string & appId){
    pthread_mutex_lock(&finishedAppsInfoLock);
      if(! (finishedAppsInfo.erase(appId) == 1))
        assert(false);
    pthread_mutex_unlock(&finishedAppsInfoLock);
  }

  //TODO: COMMENT ME
  void kill(const string & appId);


};
#endif//LRMIMPL_HPP

---