dao/src/PGQueue.h

/* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/*
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 PGQUEUE_H
#define PGQUEUE_H

#include "Queue.h"
#include "Task.h"
#include "PGAgentInfo.h"
#include "PGConnection.h"
#include <map>
#include <list>
//#include "PGDistributionStrategy.h"

using namespace std;

class PGQueue:public Queue
{
private:
 //get the path for connection to a database
 string mPathDb;
 //get the path for connection to a database
 //PGDistributionStrategy * mStrategy;

  string mMailServerIp;

public:
  PGQueue(string aDbName,string aUser,string aPass,string aHostAddr,string aPort,string aMailServerIp);
 ~PGQueue();

 list<string> getInWaitTasks();
 list<string> getTerminatedTasks();
 list<string> getInUseTasks();
 list<string> getExpiredTasks();

 /* States match with numbers :
    0 : in wait
    1 : in use
    2 : terminated
    3 : expired
 */
 void changeStateToInWait(string& aIdTask);
 void changeStateToInUse(string& aIdTask);
 void changeStateToExpired(string& aIdTask);
 void changeStateToTerminated(string& aIdTask);
 
 void saveTask(Task* aDescriptor);

 void addTaskAgentInUse(string aTask,string aAgent);

 void deleteTaskAgentInUse(string aAgent,bool aError);

 void updateAging();

 // don't forget to put it in private after tests
 void addTask(  string& aId,
                string& aCreationDate,// YYYY-MM-DD
                int aExpiration,
                int aPriority,
                string& aTaskName,
                string& aUserName,
                string& aUserMail,
                list<vector<string > > aFilters,//list of filters
                list<vector<string > > aDatas,//list of datas
                string& aResultLocalPath,
                string& aResultStoragePath,
                string& aBinSourcePath,
                string& aResultCommand
                );

 // TODO : create the interface of the agent
 //virtual void saveAgent(Agent& aAgent);
 
 bool extractTaskToExec(PGAgentInfo * aAgent,Task * aDesc,string& aIp,string& aPort);

 list<string> orderInWaitTasks();

 void updateAdvanceTask(string& aTaskId,string& value);

 list<vector<string > > getInformations(string aTaskId);

 void checkTimeout();

 string getPath();

 void deleteErrorTask(string aTask,string aAgent);

 void eraseBase();

 bool getTaskInUse(string aAgent,string aTask);

string getMail(string aTask);

string getResultStorage(string aTask);

string getName(string aTask);

};

#endif

---