src/Controller.h

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

  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 CONTROLLER_H
#define CONTROLLER_H

#ifdef XP_UNIX
#include <sys/mman.h>
#endif
#if defined(_PR_PTHREADS) && !defined(_PR_DCETHREADS)
#include <pthread.h>
#endif

#ifdef WIN32
#include <process.h>
#endif

#ifdef XP_MAC
#include "prsem.h"
#else
#include "obsolete/prsem.h"
#endif

#ifdef XP_PC
#define mode_t int
#endif

#include "PGQueue.h"
#include "PGAgentInfo.h"
#include "prthread.h"
#include "prerror.h"
#include "prnetdb.h"
#include "prlog.h"
#include "prmon.h"
#include "prmem.h"
#include "prio.h"
#include "plgetopt.h"

#include <iostream>
#include <string>
#include <map>

#include "Manager.h"
#include "Service.h"
#include <stdio.h>

#include "ControllerService.h"

using namespace std;
using namespace dnssd;
using namespace net;

#define TIME_AGING 10

class Controller
{
protected:
  string mIp;//ip address of the controller
  int mPort; //port of the controller
  PRThread* mDnssdThread;
  PRThread* mNetworkThread;
  PGQueue * mQueue;
  ControllerService* mSrv;
  string mMailServerIp;

public:
  Controller(string aBdName, string aUserName, string aUserPassword, string aServerIp, string aIpController, int aPortController,string aMailServerIp);

  PGQueue* getPGQueue();

  void setPGQueue(PGQueue* aPGQueue);

  void setSrv(ControllerService* aSrv);

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

  void sendTask();

  friend void PR_CALLBACK networkThread(void* aController);


  ~Controller();
};

class ControllerAgentListener:public BrowseListener {
private:
  PGQueue * mQueue;
  string mMailServerIp;

public:
  ControllerAgentListener(PGQueue * aQueue,string aMailServerIp) {
    mQueue = aQueue; 
    mMailServerIp = aMailServerIp;
  }
  ~ControllerAgentListener() {delete(mQueue); }

  void serviceFound(Manager* aManager, 
                    Service* aService);

};

#endif

---