src/Agent.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 AGENT_H
#define AGENT_H

#include <deque>

#include "TaskManager.h"
#include "SystemInformation.h"
#include "ScriptSystemInformation.h"
#include "NsprSystemInformation.h"
#include "Resource.h"

#include "AgentService.h"

// nspr
#include "prthread.h"

// dnssd
#include "RegistrationListener.h"
#include "Manager.h"
#include "Service.h"

using namespace net;

class Agent {
  friend void PR_CALLBACK dnssdProcess(void* aUserData);
private :
  SystemInformation* mSysInfo;
  ScriptSystemInformation* mScriptSysInfo;
  NsprSystemInformation* mNsprSysInfo;

  std::deque<SystemInformation*> mSystemInformations;
  std::map<std::string,int> mAvailableInformations;

  PRThread* mThread;

  dnssd::Service* mService;

  dnssd::Manager* mManager;

  std::map<std::string,std::string> mDnssdResources;

  bool mDnssd;

  std::string mIpAddress;

  int mBindPort;

  std::string mControllerIp;

  std::string mMountPoint;

  std::string mAgentPath;

  TaskManager* mTaskManager;

  AgentService* mSrv;

  void updateAvailableInformations();

  PRThread* Agent::createThread(PRThreadType type,
                                void (*start)(void *arg),
                                void *arg,
                                PRThreadPriority priority,
                                PRThreadScope scope,
                                PRThreadState state,
                                PRUint32 stackSize, PRInt32 index);

  void launchNetwork();

  bool checkDirectoryStructure();
  
public :

  Agent(char* aInterface, char* aPort, char* aControllerIp, char* aMountPoint);
  ~Agent();

  static const std::string kTMP_PATH;

  static const std::string kSCRIPT_PATH;

  static const std::string kSHARED_PATH;

  static const std::string kTASK_PATH;

  void updateDnssdInformations();

  void addSystemInformation(SystemInformation* aSysInfo);

  std::string getInformation(const std::string& aKey);


  bool isDnssd();

  void setSrv(AgentService* aSrv);

  AgentService* getSrv();
};

#endif //AGENT_H

---