entity_defs.h

Go to the documentation of this file.

#ifndef ENTITY_DEFINITIONS_GROUP
#define ENTITY_DEFINITIONS_GROUP

/*****************************************************************************\
*                                                                             *
*  Name   : various definitions for octopus                                   *
*  Author : Chris Koeritz                                                     *
*                                                                             *
*******************************************************************************
* Copyright (c) 2002-$now By Author.  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 is online at:      *
*     http://www.fsf.org/copyleft/gpl.html                                    *
* Please send any updates to: fred@gruntose.com                               *
\*****************************************************************************/

#include "dll_octopus.h"
#include "infoton.h"

#include <basis/byte_array.h>
#include <basis/istring.h>
#include <basis/set.cpp>
#include <data_struct/amorph.h>
#include <data_struct/unique_id.h>
#include <mechanisms/time_stamp.h>


class OCTOPUS_CLASS_STYLE octopus_entity : public packable
{
public:
  octopus_entity();  

  octopus_entity(const istring &hostname, int process_id, int sequencer,
          int add_in);

  octopus_entity(const octopus_entity &to_copy);

  ~octopus_entity();

  octopus_entity &operator = (const octopus_entity &to_copy);

  bool blank() const;

  // comparison operators.
  bool operator == (const octopus_entity &that) const;
  bool operator != (const octopus_entity &that) const
          { return ! (*this == that); }

  istring hostname() const;  
  int process_id() const;   
  int sequencer() const;    
  int add_in() const;       

  void hostname(const istring &new_host);  
  void process_id(int id);  
  void sequencer(int seq);  
  void add_in(int add);  

  istring mangled_form() const;

  istring text_form() const;

  inline istring to_text() const { return mangled_form(); }
  static octopus_entity from_text(const istring &to_convert);

  static void breakout(const istring &mangled_form, istring &hostname,
          int &process_id, int &sequencer, int &add_in);

  int packed_size() const;

  virtual void pack(byte_array &packed_form) const;
  virtual bool unpack(byte_array &packed_form);

private:
  istring *_hostname;
  int _pid;
  int _sequencer;
  int _add_in;
};



class OCTOPUS_CLASS_STYLE octopus_request_id : public packable
{
public:
  octopus_entity _entity;  
  int _request_num;  

  inline octopus_request_id() : _entity(), _request_num(0) {}

  inline octopus_request_id(const octopus_entity &entity, int request_num)
      : _entity(entity), _request_num(request_num) {}

  static octopus_request_id randomized_id();

  inline bool operator == (const octopus_request_id &that) const
          { return (_entity == that._entity)
                && (_request_num == that._request_num); }
  inline bool operator != (const octopus_request_id &that) const
          { return (_entity != that._entity)
                || (_request_num != that._request_num); }

  bool blank() const;

  int packed_size() const;

  istring mangled_form() const;  
  
  istring text_form() const;  

  inline istring to_text() const { return mangled_form(); }
  static octopus_request_id from_text(const istring &to_convert);

  virtual void pack(byte_array &packed_form) const;
  virtual bool unpack(byte_array &packed_form);
};

class octopus_request_id_set : public basis::set<octopus_request_id>
{
public:
  octopus_request_id_set() {}

  octopus_request_id_set(const basis::set<octopus_request_id> &orig)
      : basis::set<octopus_request_id>(orig) {}
};



class infoton_id_pair
{
public:
  infoton *_data;
  octopus_request_id _id;

  infoton_id_pair(infoton *data, const octopus_request_id &id)
      : _data(data), _id(id) {}

  ~infoton_id_pair() {
    delete _data;
    _data = NIL;
  }
};

class infoton_list : public amorph<infoton_id_pair> {};

#endif

---