---

cluster_shmem2evt.H

Go to the documentation of this file.

#ifndef _CLUSTER_SHMEM2EVT_H_
#define _CLUSTER_SHMEM2EVT_H_

#include <dev/polled.H>

enum { SHMEM_TERM_FLAG=0,
       SHMEM_GLUE_ATTACHED_FLAG,

       SHMEM_READY_FOR_DATA_FLAG,
       SHMEM_ALL_READY_FOR_DATA_FLAG,
       SHMEM_PROCESSED_DATA_FLAG,
       SHMEM_ALL_PROCESSED_DATA_FLAG,

       SHMEM_NUM_FLAGS };

const int SHORT_SLEEP = 100;  // microseconds

class SimpleSHMEM;
class SimpleSemaphore;

class Cluster_shmem2evt : public DEVpolled
{
protected:
  SimpleSHMEM     *_shmem_device_data;
  SimpleSHMEM     *_shmem_flags;
  SimpleSemaphore *_semaphore_device_data;

  // So, in term, we don't block on our own shmem lock
  bool             _shmem_lock_is_mine;
  bool             _has_terminated;

  int              _event_buffer_size;
  char            *_event_buffer;



public:
  Cluster_shmem2evt( Cstr_ptr &name = "Cluster_shmem2evt" );
  virtual ~Cluster_shmem2evt();

  void do_poll();
  void terminate();

  int _stale_data_cnt;

};


#endif

---