memctl.H

Go to the documentation of this file.

/* memctl.H */
/* $Id: memctl.H,v 1.3 2003/03/17 10:03:16 vlad Exp $ */
#ifndef __memctl_H
#define __memctl_H

#include <csi/pep_defs.h>
#include <csi/pep_ipc.H>

class MemBlock
{
public:

  virtual ~MemBlock ();

  virtual size_t    size () = 0;

  virtual void  resize (size_t volume) = 0;

  virtual void* ptr () = 0;

  virtual void  operator= (MemBlock& mem_blk);

};


class LocalMem : public MemBlock
{
private:

  void      *address;   
  size_t    blk_size;   
public:

  LocalMem (size_t volume);
  LocalMem (size_t volume, void* p);

  virtual ~LocalMem ();

  virtual size_t    size ()
    {  return blk_size;  }

  virtual void  resize (size_t volume);

  virtual void* ptr ();

};


class SharedMem : public ObjectIPC, public MemBlock
{
private:

  void* address;    
  int   shm_id;     
protected:

#if !PEP_USE_SHM_SIZE

  void      coherency ();
#endif /* !SHM_SIZE */

public:

  SharedMem (size_t volume);            
  SharedMem (size_t volume, key_t shm_k);   
  virtual ~SharedMem ();

  virtual size_t    size ();

  virtual void  resize (size_t volume);

  virtual void* ptr ();

  virtual int   attach_cnt ();

};


enum MemPolicy {
  mpLocal,  
  mpShared  
};


class TableUDC;     /* forward declaration */

class UniMem : public MemBlock
{
  friend class  TableUDC;

private:

  TableUDC  *host;      
  int       udc_i;      
  MemBlock  *udc_mem;   
  UniMem (TableUDC *tbl, int index);
  UniMem (UniMem& unimem);

public:

  virtual ~UniMem ();

  virtual size_t    size ();

  virtual void  resize (size_t volume);

  virtual void* ptr ();

};


struct UniDataCell
{
  size_t    v_size;     
  union {
    key_t   k_ref;      
    void    *p_ref;     
    char    buf[PEP_UDC_FIXED_SIZE];    
  }     v;      
};


class TableUDC : public ObjectIPC
{
  friend class  UniMem;

private:

  /* *** are not changed after construction *** */
  MemPolicy policy;     
  UniDataCell   *cells;     
  int       ncells;     
  MemBlock  *cells_mem; 
  UniMem    **cell_mem; 
public:

  TableUDC (key_t k_udc);       
  TableUDC (int udc_cnt, MemPolicy mp); 
  virtual ~TableUDC ();

  int   udc_count ()
    {  return ncells;  }

  UniMem*   operator[] (int udc_i);

  virtual key_t key ();

  virtual int   attach_cnt ();

};


#endif /* memctl.H */