OutgoingAnalogMPIBufferSourcesSet.h

Go to the documentation of this file.

#ifndef OUTGOINGANALOGMPIBUFFERSOURCESSET_H_
#define OUTGOINGANALOGMPIBUFFERSOURCESSET_H_

#include <vector>
#include <string>
#include "pcsim_hash.h"
#include <boost/functional/hash.hpp>

#include "SimObject.h"
#include "hash_ext.h"

using std::vector;
using std::string;

class OutgoingAnalogMPIBufferSourcesSet
{
public:
        OutgoingAnalogMPIBufferSourcesSet();
        virtual ~OutgoingAnalogMPIBufferSourcesSet();

        bool exists(SimObject *obj, string fieldname);

        bool exists(SimObject *obj, unsigned int port);

        bool insert(SimObject *obj, unsigned int port);

        bool insert(SimObject *obj, string fieldname);

protected:
  typedef hash_set< SimObject *, PCSIM::hash<const SimObject *> > port_outgoing_msgs_inner_set_type;
  typedef vector< port_outgoing_msgs_inner_set_type > port_outgoing_msgs_set_type;
  port_outgoing_msgs_set_type port_outgoing_msgs_set;

  typedef hash_set< SimObject *, PCSIM::hash<const SimObject *> > field_outgoing_msgs_inner_set_type;
  typedef hash_map< string, field_outgoing_msgs_inner_set_type , PCSIM::hash<string> > field_outgoing_msgs_set_type;
  field_outgoing_msgs_set_type field_outgoing_msgs_set;

};

inline bool OutgoingAnalogMPIBufferSourcesSet::exists(SimObject *obj, unsigned int port)
{
        if (port_outgoing_msgs_set.size() > port) {
                if (port_outgoing_msgs_set[port].find(obj) != port_outgoing_msgs_set[port].end())
                        return true;
        }
        return false;
}

inline bool OutgoingAnalogMPIBufferSourcesSet::exists(SimObject *obj, string fieldname)
{
        field_outgoing_msgs_set_type::iterator find_iter_field;
        if ((find_iter_field = field_outgoing_msgs_set.find(fieldname)) != field_outgoing_msgs_set.end()) {
                if ((*find_iter_field).second.find(obj) != (*find_iter_field).second.end())
                        return true;
        }
        return false;
}

inline bool OutgoingAnalogMPIBufferSourcesSet::insert(SimObject *obj, unsigned int port)
{
        if (port >= port_outgoing_msgs_set.size())
                port_outgoing_msgs_set.resize(port + 1);
        return port_outgoing_msgs_set[port].insert(obj).second;
}

inline bool OutgoingAnalogMPIBufferSourcesSet::insert(SimObject *obj, string fieldname)
{
  return field_outgoing_msgs_set[fieldname].insert(obj).second;
}


#endif /*OUTGOINGANALOGMPIBUFFERSOURCESSET_H_*/

---