source: benchmark/io/http/channel.cfa @ d3b8752

#include <assert.h>
#include <stdlib.hfa>

#include "channel.hfa"

// forall(otype T) {
      void  ?{}( channel & this, int _size ) with(this) {
                buffer = anew( _size );
                front = 0;
                back = 0;
                count = 0;
                size = _size;

                (lock){};
                (prods){};
                (cons){};
        }

      void ^?{}( channel & this ) {
            delete( this.buffer );
      }

        void put( channel & this, int elem ) with( this ) {
                lock( this.lock );
                while( count ==  size) {
                        wait( prods, this.lock );
                }

                /* paranoid */ assert( count < size );
                buffer[back] = elem;
                count ++;
                back = (back + 1) % size;

                notify_one( cons );
                unlock( this.lock );
        }

        int take( channel & this ) with( this ) {
                lock( this.lock );
                while( count == 0 ) {
                        wait( cons, this.lock );
                }

                /* paranoid */ assert( count > 0 );
                int temp = buffer[front];
                count --;
                front = (front + 1) % size;

                notify_one( prods );
                unlock( this.lock );
                return temp;
        }
// }