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

Timestamp:

Oct 6, 2001, 1:46:35 AM (24 years ago)

Author:

aubourg

Message:

* empty log message *

File:

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

trunk/ArchTOIPipe/Kernel/toisegment.h

@@ -2 +2 @@
 #ifndef TOISEGMENT_H
 #define TOISEGMENT_H
+
+#include <vector>
+#include <set>
 
 #include "toi.h"
@@ -21 +24 @@
   
  protected:
+  class BufferSegment;
+  class BufferView;
+  class MasterView;
+
+
   class BufferSegment {
   public:
@@ -26 +34 @@
     ~BufferSegment();
     static const int NEW = 0;
-    static const int WRITE = 1;
-    static const int COMMITTED = 2;
+    static const int WRITE = 1;     // single-thread write access
+    static const int COMMITTED = 2; // multiple read without lock are ok
     
     int getStatus() {return status;}
-
-
+    void incRefCount();
+    void decRefCount();
+    int  getRefCount();
+    
     void putData(int sn, double data, uint_8 flag);
     inline double getData(int sn);
     inline uint_8 getFlag(int sn);
+
+    bool isPastEnd(int sn) {
+      return sn >= sn+bufferSize;
+    }
     
   private:
@@ -59 +73 @@
   };
   
-  // Master view, gere le lock...
+  // Master view, gere le lock, et l'ecriture
   class MasterView {
   public:
-    MasterView();
+    MasterView(int bufsz=256, int maxseg=20);
     ~MasterView();
 
+    void putData(int sn, double data, uint_8 flag);
+    void addToWaitList(BufferView* bv);
+
+    BufferView* getView(); // thread-specific
+
   protected:
-    int s0;
+    friend class BufferView;
+    void signalWaitingViews();
+    void nextSegment();
+    BufferView* createView();
+    void updateView(BufferView*); // called on reader thread of the view
+    
+    BufferSegment*   currentSegment;
+
+    int maxSegments;
+    int bufferSize;
+    int sn0;                // First sn in first buffer
+    vector<BufferSegment*> segments; // Committed
     
     pthread_mutex_t  mutex; // lock for master buffer list access
-    pthread_cond_t   condv; // waiting for new buffer
+    pthread_cond_t   condv; // waiting (read or write)
+
+    static const int NO_WAIT   = 0;
+    static const int WAIT_READ = 1;
+    static const int WAIT_WRITE= 2;
+    int  waitStatus;
+
+    set<BufferView*>  waitingBuffers;
   };
 
@@ -76 +113 @@
   class BufferView {
   public:
+    BufferView();
+    ~BufferView();
     
-    void sync();
+    void sync();  // recupere les nouveaux segments, resync avec master
+    void wait();  // Passe en attente d'un nouveau segment
   protected:
-    MasterView master;
+    friend class MasterView;
+    MasterView* master;
+    vector<BufferSegment*> segments; // Committed
+    pthread_mutex_t  mutex; // lock pour attente de segments
+    pthread_cond_t   condv; // attente de segments
   };  
+
+  
+  
 };