dao/src/Queue.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 QUEUE_H
#define QUEUE_H
#include <string>
#include <list>
#include <vector>
#include <iostream>

#include "Task.h"
#include "PGAgentInfo.h"

using namespace std;

class Queue
{
public:
 Queue(){}
 virtual ~Queue(){}

 virtual list<string> getInWaitTasks()=0;
 virtual list<string> getTerminatedTasks()=0;
 virtual list<string> getInUseTasks()=0;
 virtual list<string> getExpiredTasks()=0;

 virtual void saveTask(Task* aDescriptor)=0;
 virtual void updateAging()=0;

 virtual void changeStateToInWait(string& aIdTask)=0;
 virtual void changeStateToInUse(string& aIdTask)=0;
 virtual void changeStateToExpired(string& aIdTask)=0;
 virtual void changeStateToTerminated(string& aIdTask)=0;

 // TODO : create the interface of the agent
 //virtual void saveAgent(InfoAgent& aAgentInfo);

 virtual list<string> orderInWaitTasks()=0;

 virtual bool extractTaskToExec(PGAgentInfo * aAgent,Task * aDesc,string& aIp,string& aPort)=0;

 virtual void updateAdvanceTask(string& aTaskId,string& value)=0;

 virtual list<vector<string > > getInformations(string aTaskId)=0;

 virtual void addTaskAgentInUse(string aTask,string aAgent)=0;

 virtual void deleteTaskAgentInUse(string aAgent,bool aError)=0;

 virtual void checkTimeout()=0;

 virtual void eraseBase()=0;

};

#endif

---