Context Navigation

Changes in / [f621e43f:a41e87b]

Files:

-              rf621e43f
+              ra41e87b
         // returns true if no blocking needed
+        bool P(BinaryBenaphore & this) {
+                return __atomic_fetch_sub(&this.counter, 1, __ATOMIC_SEQ_CST) > 0;
+        }
+        bool P(BinaryBenaphore & this) { return __atomic_fetch_sub(&this.counter, 1, __ATOMIC_SEQ_CST) > 0; }
         bool tryP(BinaryBenaphore & this) {
                 ssize_t c = this.counter;
 …
 static inline void ?{}(ThreadBenaphore & this, one_t ) { (this.ben){ 1 }; }
 static inline bool P(ThreadBenaphore & this)              { return P(this.ben) ? false : P(this.sem); }
 static inline bool P(ThreadBenaphore & this, $thread * t) { return P(this.ben) ? false : P(this.sem, t ); }
+static inline bool P(ThreadBenaphore & this)              { return /* P(this.ben) ? false : */ P(this.sem); }
+static inline bool P(ThreadBenaphore & this, $thread * t) { return /* P(this.ben) ? false : */ P(this.sem, t ); }
 static inline bool tryP(ThreadBenaphore & this)           { return tryP(this.ben); }
 static inline bool P(ThreadBenaphore & this, bool wait)   { return wait ? P(this) : tryP(this); }
 static inline $thread * V(ThreadBenaphore & this, const bool doUnpark = true) {
         if (V(this.ben)) return 0p;
+        // if (V(this.ben)) return 0p;
         return V(this.sem, doUnpark);
+}

-              rf621e43f
+              ra41e87b
         this.sum = 0;
         for(num_blocks) {
+                // sout | "b P" | me;
                 P(sem);
                 if(((thread&)this).seqable.next != 0p) sout | "Link not invalidated";
+                // sout | "a P" | me;
+        }
+}
 …
                 this.sum += (unsigned)b;
                 unpark(t);
+                // sout | "a V" | t;
                 yield(random(10));
+        }

Note: See TracChangeset for help on using the changeset viewer.