packet.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_PACKET_HH_
#define _GLASS_PACKET_HH_

#include <ostream>
#include <set>
#include <vector>
#include "types.h"
#include "chain.h"

namespace libglass {

const PluginId rootBaseId = PluginId("RootBase");

class Packet {
private:
        nodeId                  from;           
        chain                   data;           
        PluginId                pid;            
        bool                    reliable;       
        std::set<nodeId>        targetIds;      
        std::set<nodeFD>        targetFDs;      
protected:
        friend class Glass;
        friend class Protocol;

public:
        Packet();

        virtual ~Packet();

        void setData(unsigned char *data, unsigned int length);

        void setData(const char *data, unsigned int length);

        void setData(chain &s);

        void appendData(unsigned char *data, unsigned int length);

        void appendData(const char *data, unsigned int length);

        void appendData(string &s);

        void appendData(chain &s);

        unsigned int getDataLength(void) const;

#ifdef DEPRECATED

        unsigned char *getData(void) const;
#endif

        void getData(chain &s);

        void setPluginId(PluginId id);

        PluginId getPluginId(void) const;

        void setTargetNodes(nodeId id);

        void setTargetNodes(std::set<nodeId> &id_set);

        void setTargetNodes(std::vector<nodeId> &id_set);

        void addTargetNodes(nodeId id);

        void addTargetNodes(std::set<nodeId> &id_set);

        std::set<nodeId> &getTargetNodes(void);

        void clearTargetNodes(void);

        void setSenderNode(nodeId id);

        bool isReliable(void) const;

        void setReliable(bool reliable);

        nodeId getSenderNode(void) const;

        void setTargetFDs(nodeFD fd);

        void setTargetFDs(std::set<nodeFD> &fds);

        std::set<nodeFD> &getTargetFDs(void);

        virtual chain encode(unsigned int *len = NULL);

        bool decode(chain &s);

        bool decode(unsigned char *buffer, unsigned int length);

        bool decode(unsigned char *header, unsigned int headerlen,
                unsigned char *databuf, unsigned int datalen);

        virtual std::ostream& print(std::ostream &o);

        friend std::ostream& operator<<(std::ostream &o, Packet &p);
};

extern std::ostream& operator<<(std::ostream &o, Packet &p);

} //namespace

#endif

---