CP.h

Go to the documentation of this file.

#ifndef CP_H
#define CP_H

#include "CPStorage.h"
#include "CPViewDescription.h"
#include "TupleQueue.h"
#include "CPView.h"
#include <vector>
#include <map>
#include "common.h"

BOREALIS_NAMESPACE_BEGIN;

#define MAX_ENQUEUED 1000

class CPView;

class CP
{

  //  friend class CPView; 
 
 public:

  struct ltstr
  {
    bool operator()(string s1, string s2) const
    {
      return strcmp(s1.c_str(), s2.c_str()) < 0;
    }
  };

    
  CP(ptr<CPViewDescription> cp_desc);

  ~CP() {};

  void setStartPointer(string view_id, char* start);

  void setEndPointer(string view_id, char* end);

  void setPointers(string view_id, char* start, char* end);

  ptr<CPView> createImplictView(string base_view_id);

  ptr<CPView> createExplicitView(ptr<CPViewDescription> desc);

  void enqueue(const void *tuple);
  
  vector<char*> extract(char* first, char* last);
  vector<char*> extract(char* first, char* last, vector<ptr<Expression> > keys); 

  char* extract(string tuple_key, vector<ptr<Expression> > keys);   

  // NEW -- SINCE TUPLE_IDs ARE IN HEADER
  char* extract(int tuple_id);   

  vector<char*> extract(int start_order_by, int end_order_by, ptr<Expression> order_by_field, bool revisions);

  ptr<CPStorage> getStorage();
  
  ptr<CPView> getCPView(string view_id);

  map<string, ptr<CPView>, ltstr> getAllCPViews() { return _my_cp_views; } 
 
  void removeCPView(string view_id);

  char* findFirstPointerToVal(int val, ptr<Expression> order_by);

  char* findLastPointerToVal(int val, ptr<Expression> order_by);

  // TODO stuff
  // 1. how is bulk copying of tuples to storage done? The listener is supposed to
  // copy the TupleQueue to CP's storage. How's that done???

  //adds a view to its list of views
  void setView(string view_id); 

  void addView(string view_id, ptr<CPView> cp_view);

  //discards tuples that are not used by any views
  void discardTuples();  

  string as_string() const
  { 
    return string() + "CP{num_views=" + _my_cp_views.size() + ",num_tuples=" + _cp_storage->getNumTuples() + "}";
  }

  bool isLater(char* p1, char* p2);

 private:
  // maps CPView's view_ids to start pointers
  typedef map<string, char*, ltstr> StartPointers;
  StartPointers _start_pointers;

  // maps CPView's view_ids to end pointers
  typedef map<string, char*, ltstr> EndPointers;
  EndPointers _end_pointers;

  // all views current on "this" CP
  typedef map<string, ptr<CPView>, ltstr> CPViewMap;
  CPViewMap _my_cp_views;

  // where do I store tuples? => here
  ptr<CPStorage> _cp_storage;

  //  int32 MAX_QUEUED;
  int32 _enqueued_count;

  //just for testing replaySince(), should be removed afterwards
  char* replaySinceTuple;
};

BOREALIS_NAMESPACE_END;

#endif                         // CP_H

---