net/src/AgentHandler.h

/* 
* Version: GPL 2.0
*
* K-10 Distributed Processing - Lium, Le Mans
* Copyright (C) 2006 Laurent MOUTEL
*
* 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_HANDLER_H
#define AGENT_HANDLER_H

#include <string>
#include <prthread.h>
#include <prlog.h>

using namespace std;

namespace net
{

class AgentHandler
{
        
protected:
        
        int mIsBusy;
        PRThread *mTaskThread;
        string mTaskDescriptor;

protected:

        void SetBusyState(int aState) { mIsBusy = aState; }

public:

        void LaunchTaskThread();

        virtual int CheckDescriptor(string) = 0;
        
        virtual void HandleDescriptor(string) = 0;
        
        AgentHandler();

        int IsBusy() { return mIsBusy; }
        
        void SetTaskDescriptor(string aDesc) { mTaskDescriptor = aDesc; }
        
        string GetTaskDescriptor() { return mTaskDescriptor; }

        
        PRThread* createThread(PRThreadType type,
                                                   void (*start)(void *arg),
                                                   void *arg,
                                                   PRThreadPriority priority,
                                                   PRThreadScope scope,
                                                   PRThreadState state,
                                                   PRUint32 stackSize, PRInt32 index);
        
        friend void PR_CALLBACK net::task_thread(void *);
        
};

}


#endif

---