root_queue.barrier();
lock.Unlock();
}
+ void _barrier() {
+ root_queue.barrier();
+ }
// ** blocking interface **
lock.Lock();
_submit_io(&bio);
- barrier(); // need this, to prevent starvation!
+ _barrier(); // need this, to prevent starvation!
while (!bio.done)
c.Wait(lock);
lock.Unlock();
lock.Lock();
_submit_io(&bio);
- barrier(); // need this, to prevent starvation!
+ _barrier(); // need this, to prevent starvation!
while (!bio.done)
c.Wait(lock);
lock.Unlock();