Lines Matching refs:MARL_ASSERT
48 MARL_ASSERT(FIBER->state == STATE, \
100 MARL_ASSERT(bound == nullptr, "Scheduler already bound"); in bind()
114 MARL_ASSERT(bound != nullptr, "No scheduler bound"); in unbind()
121 MARL_ASSERT(it != bound->singleThreadedWorkers.byTid.end(), in unbind()
123 MARL_ASSERT(it->second.get() == worker, "worker is not bound?"); in unbind()
234 MARL_ASSERT(worker != nullptr, "No Scheduler::Worker bound"); in Fiber()
247 MARL_ASSERT(worker == Worker::getCurrent(), in wait()
254 MARL_ASSERT(worker == Worker::getCurrent(), in switchTo()
290 MARL_ASSERT(false, "bad fiber state"); in toString()
316 MARL_ASSERT(deleted, "WaitingFibers::take() maps out of sync"); in take()
321 MARL_ASSERT(*this, in next()
330 MARL_ASSERT(added, "WaitingFibers::add() fiber already waiting"); in add()
339 MARL_ASSERT(erased, "WaitingFibers::erase() maps out of sync"); in erase()
400 MARL_ASSERT(false, "Unknown mode: %d", int(mode)); in start()
419 MARL_ASSERT(false, "Unknown mode: %d", int(mode)); in stop()
528 MARL_ASSERT(!work.waiting.contains(fiber), in enqueue()
594 MARL_ASSERT(work.num == work.fibers.size() + work.tasks.size(), in waitForWork()
674 MARL_ASSERT(work.num == work.fibers.size() + work.tasks.size(), in runUntilIdle()
685 MARL_ASSERT(idleFibers.count(fiber) == 0, "dequeued fiber is idle"); in runUntilIdle()
686 MARL_ASSERT(fiber != currentFiber, "dequeued fiber is currently running"); in runUntilIdle()
692 MARL_ASSERT(added, "fiber already idle"); in runUntilIdle()
728 MARL_ASSERT(to == mainFiber.get() || idleFibers.count(to) == 0, in switchToFiber()