glassclient.h

Go to the documentation of this file.

/*  Glass - a distributed computing library
    Copyright (C) 2003-2009 Bruno Barberi Gnecco
    Copyright (C) 2009-2010 Corollarium Technologies


    This library is free software; you can redistribute it and/or
    modify it under the terms of the GNU Lesser General Public
    License as published by the Free Software Foundation; either
    version 2 of the License, or (at your option) any later version.

    This library 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
    Lesser General Public License for more details.

    You should have received a copy of the GNU Lesser General Public
    License along with this library; if not, write to the Free Software
    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

#ifndef _GLASS_CLIENT_HH_
#define _GLASS_CLIENT_HH_

#include <set>

#include "glass.h"
#include "types.h"
#include "exception.h"
#include "thread.h"

namespace libglass {

class Protocol;

class LIBGLASS_API GlassClient : public Glass, protected GlassThread {
private:
        bool                    initialized;    
        bool                    quitting;       
        unsigned int            totalnodes;     
        std::set<nodeId>        clientlist;     
        bool                    ismaster;       
protected:
        string                  server;         
        boost::condition_variable cond; 
        boost::mutex mut;               
        nodeId                  serverId;       
        void execute(void);

        void cleanup(void);

        bool sendPacket(Packet &p);

        virtual bool rootPacket(Packet &p);

        virtual nodeId registerNode(nodeFD fd);

#ifdef TODO
        virtual bool unregisterNode(nodeId id);
        virtual bool unregisterNode(nodeFD fd);
#endif

public:
        GlassClient(Protocol *p, const char *server) throw(Exception);

        ~GlassClient();
        
        unsigned int getTotalNodes(void);

        std::set<nodeId> getClientList(void);

        bool isMaster(void);

        
        void killAll(void);
        
};

} // namespace

#endif // _GLASS_CLIENT_HH_

---