source: tags/0.56/stopos_pool.cpp @ 9

#include "stopos_pool.h"
#include "stopos.h"
#include "wutils.h"
#include <iostream>
#include <string.h>
#include <stdlib.h>
int stopos_pool::get_status(void)
  // non-sense example implementation, you have to overwrite this in a derived class
{
  std::cerr << __FILE__<<":"<<__LINE__<<"stopos_pool::getstatus must be overwritten in a derived class"<<std::endl;
  this->status.next  = this->statuskey;
  this->status.first = this->statuskey;
  this->status.last  = this->statuskey;
  this->status.count = StringToNumber<longuint>(0);
  return NOTIMPLEMENTED;
}
#if 0
int stopos_pool::put_status(void)
  // non-sense example implementation, you have to overwrite this in a derived class
{
  std::cerr << __FILE__<<":"<<__LINE__<<"stopos_pool::putstatus must be overwritten in a derived class"<<std::endl;
  std::cout << this->status.next.str();
  std::cout << this->status.first.str();
  std::cout << this->status.last.str();
  std::cout << this->status.count;
  return NOTIMPLEMENTED;
}
#endif

int stopos_pool::get_record(std::string &r, const std::string &k)
  // non-sense example implementation, you have to overwrite this in a derived class
{
  std::cerr << __FILE__<<":"<<__LINE__<<"stopos_pool::get_record must be overwritten in a derived class"<<std::endl;
  return 0;
}

int stopos_pool::put_record(const std::string &r, const std::string &k)
  // non-sense example implementation, you have to overwrite this in a derived class
{
  std::cerr << __FILE__<<":"<<__LINE__<<"stopos_pool::put_record must be overwritten in a derived class"<<std::endl;
  std::cout <<r<<std::endl;
  return 0;
  //
  // record r must be stored such that get_record() retrieves it using k
  //
}

int stopos_pool::remove_record(const stopos_key &k)
  // non-sense example implementation, you have to overwrite this in a derived class
{
  std::cerr << __FILE__<<":"<<__LINE__<<"stopos_pool::remove_record must be overwritten in a derived class"<<std::endl;
  std::cout << "Please forget the existence of the record with the following key:"<<k.str()<<std::endl;
  return 0;
}

int stopos_pool::create_db(void)
  // non-sense example implementation, you have to overwrite this in a derived class
{
  std::cerr << __FILE__<<":"<<__LINE__<<"stopos_pool::create_db must be overwritten in a derived class"<<std::endl;
  std::cout << "Please create file " << this->db_name<< std::endl;
  return 0;
}

int stopos_pool::purge_db(void)
  // non-sense example implementation, you have to overwrite this in a derived class
{
  std::cerr << __FILE__<<":"<<__LINE__<<"stopos_pool::purge_db must be overwritten in a derived class"<<std::endl;
  std::cout << "Please purge file " << this->db_name<< std::endl;
  return 0;
}

int stopos_pool::open_db(void)
  // non-sense example implementation, you have to overwrite this in a derived class
{
  std::cerr << __FILE__<<":"<<__LINE__<<"stopos_pool::open_db must be overwritten in a derived class"<<std::endl;
  std::cout << "Please open file " << this->db_name<<" and assign the result to an handle in your class" << std::endl;

  this->db_open = 1;
  return 0;
}

int stopos_pool::close_db(void)
  // non-sense example implementation, you have to overwrite this in a derived class
{
  std::cerr << __FILE__<<":"<<__LINE__<<"stopos_pool::close_db must be overwritten in a derived class"<<std::endl;
  std::cout << "Please close file " << this->db_name<<std::endl;

  db_open = 0;
  return 0;
}

void stopos_pool::dump_db(void)
  // non-sense example implementation, you have to overwrite this in a derived class
{
  std::cerr << __FILE__<<":"<<__LINE__<<"stopos_pool::dump_db must be overwritten in a derived class"<<std::endl;
  std::cout << "Please dump file " << this->db_name<<std::endl;
}

// constructor:
stopos_pool::stopos_pool()
{
  this->kvp         = 0;
  this->statuskey   = stopos_key();  // full key
  this->db_name     = 0;
  this->db_open     = 0;
}

// destructor
stopos_pool::~stopos_pool()
{
  if(db_name)
    free (db_name);
}

int stopos_pool::get_record(datarecord &r,const stopos_key &k)
{
  std::string s;
  int rc;
  rc = this->get_record(s, k.str()); // wwvv full key
  if (rc != 0)
    return rc;
  r = datarecord(s,dbsep);
  return 0;
}

int stopos_pool::put_record(const datarecord &r,const stopos_key &k)
{
  std::string b;
  int rc;

  b = r.str(dbsep);

  rc = this->put_record(b,k.str());  // wwvv full key

  return rc;
}

void stopos_pool::set_db_name(std::string filename)
{
  this->sdb_name = filename;
  this->db_name = strdup(filename.c_str());
}

std::string stopos_pool::get_db_name(void)
{
  return this->sdb_name;
}

int stopos_pool::add_line(const std::string line, std::string &key)
{
  if (!this->db_open)
    return DBNOTOPEN;

  datarecord d;
  stopos_key dkey;
  int rc;
  rc = get_status();
  if (rc != 0)
    return rc;

  //dkey is the key of the inserted record
  //dkey = status.last;                     // wwvv full key
  dkey.set(status.count + 1,this->get_slot(dkey.get_key()));
  dkey.set(status.count + 1,this->get_slot(stopos_key::NumberToKey(status.count +1)));

  // if status.last != 0, modify 'next' of last record
  if (status.last != this->statuskey)
  {
    datarecord l;
    rc = this->get_record(l,this->status.last);
    if (rc != 0)
      return rc;
    l.next = dkey;  // wwvv full key
    rc = this->put_record(l,this->status.last);
    if (rc !=0)
      return rc;
  }

  // if status.next points to nothing
  //   or
  // if status.next points to a record that has been committed,
  //   then
  // status.next should point to the record just added

  // modify status record

  if (this->status.next == this->statuskey) // status.next points to nothing
    this->status.next = dkey;  // wwvv comp: value, dkey full key
  else  // look if status.next points to a record that has already been committed
  {
    datarecord r;
    int rc;

    rc = this->get_record(r,this->status.next);
    if (rc != 0)
      return FETCHERROR;

    if (r.retrieved != 0)
      this->status.next = dkey; // wwvv full key
  }

  if (this->status.first == this->statuskey)
    this->status.first = dkey; // wwvv full key

  d.prev            = status.last; 
  this->status.last = dkey; // wwvv full key

  this->status.count++;
  this->status.present++;
  this->status.present0++;

  rc = this->put_status();
  if (rc != 0)
    return this->STOREERROR;

  d.value     = zstrtohex(line);
  d.next      = this->statuskey;
  d.retrieved = 0;

  rc = put_record(d,dkey); // wwvv full key

  if (rc != 0)
    return this->STOREERROR;

  key = dkey.str();  // wwvv full key
  return 0;
}

int stopos_pool::get_line(std::string &line, longuint &retrieved, std::string &key)
{
  if (!this->db_open)
    return DBNOTOPEN;

  int rc;
  rc = this->get_status();
  if (rc != 0)
    return FETCHERROR;

  if (this->status.next == this->statuskey)  // wwvv value
  {
    if (!this->kvp)
      return  NOTFOUND;
    // wrapping around ...
    status.next = status.first;

    if (this->status.next == this->statuskey) // wwvv value
      return NOTFOUND;
  }

  datarecord r;
  
  rc = this->get_record(r,this->status.next);
  if (rc != 0)
    return FETCHERROR;

  retrieved = r.retrieved;
  if (!this->kvp)
    if (r.retrieved !=0)
      return NOTFOUND;
  key = this->status.next.str();  // wwvv full key

  line = zhextostr(r.value);

  // adjust the 'retrieved' field of r, and write it

  r.retrieved++;

  rc = this->put_record(r,status.next);
  if (rc != 0)
    return STOREERROR;

  // adjust the 'next' field of status. this must be equal
  // to the 'next' field of r

  this->status.next = r.next;

  if (r.retrieved == 1)
    this->status.present0--;

  this->put_status();

  return 0;
}

int stopos_pool::remove_line(const std::string &k)
{
  if (!this->db_open)
    return DBNOTOPEN;

  int rc;
  datarecord r;
  stopos_key key(k);

  rc = this->get_record(r,key);
  if (rc !=0)
    return rc;

  // remove this record from the linked lists.

  rc=this->get_status();
  if (rc != 0)
    return rc;

  //
  //remove_line

  // r = record to remove
  // 
  // situations we have to deal with:
  // 
  // r.next = 0  ( = key to status)
  // r.next = data ( = key to data)
  // 
  // r.prev = 0
  // r.prev = data
  // 
  // if (r.prev != 0)
  //    get p(r.prev)
  // 
  // if (r.next != 0)
  //    get n(r.next)
  // 
  // if (r.next = 0)    //r is last record
  //   {
  //      if r.prev = data
  //      {
  //          p.next = r.next     (=0)
  //          if (key == s.next)
  //             s.next = r.next  ( = 0)
  //          if (key == s.last)     // must be true, r is last record
  //             s.last = r.prev
  //          if (key == s.first)
  //             impossible, because there is a previous record
  //      }
  //      else  // r.prev = 0 // this is the only record
  //      {
  //          s.next = r.next ( =r.prev =0)
  //          s.first = r.prev ( = r.next =0)
  //          s.last  = r.prev ( = r.next = 0)
  //      }
  //   }
  // else    // r has a follower
  //  {
  //      if r.prev = datarecord
  //      {
  //          p.next = r.next
  //          n.prev = r.prev
  //          if (key == s.next)
  //             s.next = r.next
  //          if (key == s.last)
  //             impossible, there is a follower
  //          if (key == s.first)
  //             impossible, there is a predecessor
  //      }
  //      else  // r.prev = 0: r is the first record
  //      {
  //          n.prev = r.prev (=0)
  //          if (key == s.next)
  //             s.next = r.next
  //          if (key == s.last)
  //             impossible, there is a follower
  //          if (key == s.first)  // must be
  //             s.first = r.next
  //      }
  //  }

  // remove record r
  //

  this->get_record(r,key); 
  // 
  // situations we have to deal with:
  // 
  // r.next = 0  ( = key to status)
  // r.next = data ( = key to data)
  // 
  // r.prev = 0
  // r.prev = data
  // 

  datarecord p,n;

  if (r.prev != this->statuskey)  // wwvv value
    this->get_record(p,r.prev);
  
  if (r.next != this->statuskey)  // wwvv value
    this->get_record(n,r.next);
//
// and what to do if the next record to be dumped is
// exactly this record?
//
// I think, status.nextd should become r.next,
// whatever r.next is pointing to
// However, if r.next is pointing to nothing,
// we should give status.nextd an impossible value
//
  
  if (this->status.nextd == key)  // wwvv value
  {
    if (r.next == this->statuskey)  // wwvv value
      this->status.nextd.impossible();
    else
      this->status.nextd = r.next;
  }

  if (r.next == this->statuskey)  // r is last record
  {
    if (r.prev != this->statuskey)  // r is last record and has a predecessor
      {
        p.next = r.next;
        this->put_record(p,r.prev);

        if (key == status.next)
          status.next = r.next;

        // if (key == status.last)  // always the case here
        status.last = r.prev;

        // if (key == status.first)
        //   impossible, because there is a previous record
      }
    else  // r is the only record
    {
      status.next  = r.next;
      status.first = r.prev;
      status.last  = r.prev;
    }
  }
  else   // r has a follower
  {
    if (r.prev != this->statuskey)  // r has a predecessor and a follower
    {
      p.next = r.next;
      this->put_record(p,r.prev);

      n.prev = r.prev;
      this->put_record(n,r.next);

      if (key == status.next)
        status.next = r.next;
      // if (key == status.last) 
      //   impossible, r has a follower
      // if (key == s.first)
      //   impossible, r has a predecessor
    }
    else  // r is first record and has a follower
    {
      n.prev = r.prev;
      this->put_record(n,r.next);

      if (key == status.next)
        status.next = r.next;

      // if (key == status.last)
      //   impossible, r has a follower
      
      // if (key == status.first)  // always true here
      status.first = r.next;
    }
  }

  // finally, remove the record


  rc = this->remove_record(key);
  if (rc != 0)
    return rc;

  // and rewrite status

  this->status.present--;
  if (r.retrieved == 0) 
    this->status.present0--;

  rc = this->put_status();
  if (rc != 0)
    return rc;

  return 0;
}

void stopos_pool::set_kvp(bool v)
{
  this->kvp = v;
}

bool stopos_pool::get_kvp(void)
{
  return this->kvp;
}

int stopos_pool::get_counts(longuint &count, 
               longuint &present, 
               longuint &present0)
{
  int rc = get_status();
  if (rc != 0) 
    return rc;

  count    = status.count;
  present  = status.present;
  present0 = status.present0;
  return 0;
}

int stopos_pool::dump_line(std::string  &line, 
                           longuint     &retrieved, 
                           std::string  &key)
{
  if (!this->db_open)
    return DBNOTOPEN;

  int rc;
  rc = this->get_status();
  if (rc != 0)
    return FETCHERROR;

  //
  // if status.nextd is pointing to nothing,
  // we assume that one is starting the dump,
  // and let nextd point to the first record
  //

  if (this->status.nextd == this->statuskey)
    this->status.nextd = this->status.first;

  datarecord r;

  rc = this->get_record(r,this->status.nextd);
  if (rc != 0)
  {
    this->status.nextd = this->status.first;
    this->put_status();
    return NOTFOUND;
  }

  key = this->status.nextd.str();  // full key

  line = zhextostr(r.value);

  this->status.nextd = r.next;

  if (this->status.nextd == this->statuskey) // we signal that we reached eoi
    this->status.nextd.impossible();         // at the next call

  this->put_status();

  return 0;
}
 
datarecord::datarecord()
{
  this->retrieved = 0;
}

datarecord::datarecord(const std::string &s,char sep)
{
  std::vector <std::string> v;
  split(v,s,sep);

  this->prev      = stopos_key(v[0]);
  this->next      = stopos_key(v[1]);
  this->retrieved = StringToNumber<longuint>(v[2]);
  this->value     = v[3];
}

std::string datarecord::str(char sep) const
{
  std::string r;
  r = this->prev.str()                + sep  // wwvv full key
    + this->next.str()                + sep // wwvv full key
    + NumberToString(this->retrieved) + sep
    + this->value
    ;

  return r;
}

statusrecord::statusrecord(void)
{
  this->init();
}

statusrecord::statusrecord(const std::string & s, char sep)
{
  std:: vector <std::string> v;

  split(v,s,sep);
  this->next     = stopos_key(v[0]);
  this->first    = stopos_key(v[1]);
  this->last     = stopos_key(v[2]);
  this->nextd    = stopos_key(v[3]);
  this->count    = StringToNumber<longuint>(v[4]);
  this->present  = StringToNumber<longuint>(v[5]);
  this->present0 = StringToNumber<longuint>(v[6]);

}
void statusrecord::init(void)
{
  this->next     = stopos_key();
  this->first    = stopos_key();
  this->last     = stopos_key();
  this->nextd    = stopos_key();
  this->count    = 0;
  this->present  = 0;
  this->present0 = 0;
}

std::string statusrecord::str(char sep)
{
  std::string r;
  r = this->next.str()              + sep // wwvv full key
    + this->first.str()             + sep // wwvv full key
    + this->last.str()              + sep // wwvv full key
    + this->nextd.str()             + sep // wwvv full key
    + NumberToString(this->count)   + sep
    + NumberToString(this->present) + sep
    + NumberToString(this->present0)
    ;
  return r;
}