ngcdcsSHM_IPC.hpp

Go to the documentation of this file.

#ifndef ngcdcsSHM_IPC_H
#define ngcdcsSHM_IPC_H
 
 
#ifndef __cplusplus
#error This is a C++ include file and cannot be used from plain C
#endif
 
 
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <errno.h>
#include <sys/shm.h>
 
#include <ngc/core/ngcb.h>
#include <ngc/core/ngcbSHM.hpp>
#include <ngc/core/ngcdcsSHM.hpp>
 

struct ngcdcs_shm_t {
  int id;

  int locked;

  void *mem;

  ngcdcs_shm_t() {id = -1; locked = 0; mem = NULL;}
};

class ngcdcsSHM_IPC: public ngcdcsSHM
{
public:
  ngcdcsSHM_IPC();

  explicit ngcdcsSHM_IPC(FILE *wd);

  ngcdcsSHM_IPC(FILE *wd, int n);

  ngcdcsSHM_IPC(FILE *wd, const char *s);      

  ngcdcsSHM_IPC(FILE *wd, const char *s, int n);      
 
  // Destructor 
  virtual ~ngcdcsSHM_IPC();     

  void *Alloc(size_t size); 

  void Free(); 

  int SetName(const char *newName);
 
protected: 
  void InvalidateEvent();

  void BufferWait(int idx);

  int BufferLocked(int idx);

  int BufferLock(int idx);

  int BufferTryLock(int idx);

  void BufferUnlock(int idx);

  int Publish(int idx, const ngcdcs_finfo_t &finfo, int endian, int fullFrame);
 
private:
  void Init_();
  
  ngcdcs_shm_t *shm_;

  ngcbSHM *evt_;

  void Free_(); 

  int Sem_(int idx);

  int WrLock_(int idx);

  void WrUnlock_(int idx);
};
 
#endif