Changeset 1689 in Sophya for trunk/ArchTOIPipe/Kernel/toisegment.h

Timestamp:

Oct 14, 2001, 1:56:14 AM (24 years ago)

Author:

aubourg

Message:

segmented buffers...

File:

• trunk/ArchTOIPipe/Kernel/toisegment.h (modified) (7 diffs)

trunk/ArchTOIPipe/Kernel/toisegment.h

@@ -18 +18 @@
 class TOISegmented : public TOIRegular {
  public:
-  TOISegmented();
-  TOISegmented(string nm);
+  TOISegmented(int bufsz=256, int maxseg=20);
+  TOISegmented(string nm, int bufsz=256, int maxseg=20);
   ~TOISegmented();
+
+  virtual double        getData(int i);
+  virtual void          getData(int i, double& data,  uint_8& flag);
+  virtual void          putData(int i, double  value, uint_8  flag=0);
+  virtual void          wontNeedBefore(int i);
+  virtual void          putDone();
+
+
+  virtual DataStatus    isDataAvail(int iStart, int iEnd);
+  virtual DataStatus    isDataAvail(int i);
+  virtual DataStatus    isDataAvailNL(int iStart, int iEnd); // abstract
+  virtual void          waitForData(int iStart, int iEnd);
+  virtual void          waitForData(int i);
+  virtual void          waitForAnyData();
+  virtual int           nextDataAvail(int iAfter); // abstract
+  virtual bool          hasSomeData(); // abstract
+  virtual void          doGetData(int i, double& data, uint_8& flag); // abs
+  virtual void          doPutData(int i, double value, uint_8 flag=0); // abs
 
   
@@ -27 +45 @@
   class BufferView;
   class MasterView;
+
+  MasterView* master;
 
 
@@ -85 +105 @@
     double getData(int sn);
     uint_8 getFlag(int sn);
+    BufferView* getView(); // thread-specific
+    void putDone();
 
   protected:
@@ -90 +112 @@
     void removeFromWaitList(BufferView* bv);
 
-    BufferView* getView(); // thread-specific
 
     friend class BufferView;
-    void signalWaitingViews();
+    void signalWaitingViews(); // views are waiting on read
+    void signal(); // we are waiting on write
     void nextSegment();
+    void waitForCleaning();
     BufferView* createView();
     void updateView(BufferView*); // called on reader thread of the view
@@ -107 +130 @@
     pthread_mutex_t  views_mutex; // lock for master buffer list access
     pthread_mutex_t  write_mutex; // for write waiting
-    pthread_cond_t   condv; // waiting (read or write) (write only ?)
+    pthread_cond_t   condv; // waiting for cleaning (on writer thread)
     pthread_key_t    buffer_key; // thread-specific buffer view
     static void BufferDestroy(void *);
 
-    static const int NO_WAIT   = 0;
-    static const int WAIT_READ = 1;
-    static const int WAIT_WRITE= 2;
-    int  waitStatus;
+    bool   waitingOnWrite; // wait on writer thread
 
     set<BufferView*>  waitingBuffers;
@@ -130 +150 @@
     double getData(int sn);
     uint_8 getFlag(int sn);    
+
+    void wontNeedBefore(int sn);
     
   protected:
@@ -142 +164 @@
     int sn0; 
     int segmentSize;
+    int firstNeeded;
     pthread_mutex_t  mutex; // lock pour attente de segments
     pthread_cond_t   condv; // attente de segments (en lecture)