src/TaskManager.h

/*
K-10 Distributed Processing - Lium, Le Mans
Copyright (C) 2006 Vincent JOUSSE

This program is free software; you can redistribute it and/or
modify 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.

This program 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 this program; if not, write to the Free Software
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
*/

#ifndef TASKMANAGER_H
#define TASKMANAGER_H

#include "Task.h"
#include "TaskDataInfo.h"

#include <prio.h>

#include <sys/shm.h>

typedef struct 
{
        int running;
        int returnVal;
} state_info;

class TaskManager {

private :
  int mShmid;

  struct share_mem* sharedMem();
  char* taskName(struct share_mem* aShared);
  state_info* stateInfo(struct share_mem* aShared);

  void setReturnValue(int aReturnValue);

  Task* mTask;

  std::string mTaskPath;

  std::string mIpAddr;

  std::string mAgentPath;

  std::string mMountPoint;

  int forkCommand(const std::string aCommand);

  std::string mHostName;

  std::string mStartTime;

  std::string mEndTime;

  std::string mArchiveName;

  void writeLine(PRFileDesc* fileDest,const char* data);

  static TaskManager* pinstance;

  TaskManager(std::string aIpAddr,std::string aAgentPath,std::string aMountPoint);

  bool copyDataInfo(TaskDataInfo* aData);

public :
  int getInfoShmid() { return mShmid; }
  
  static TaskManager* Instance(std::string aIpAddr,std::string aAgentPath,std::string aMountPoint);

  ~TaskManager();

  bool isTaskRunning();

  void setTaskRunning(bool isRunning);

  int getReturnValue();


  bool registerTask(Task* aTask);

  bool executeCurrentTask();

  bool createCurrentTaskSummary();


  bool archiveCurrentTask();

  bool copyCurrentTaskArchive();

  bool deleteCurrentTaskArchive();

  Task* getTask();

  char* getTaskName();

  static const std::string kLOGS_DIR;

};
#endif //TASKMANAGER_H

---