Lines Matching refs:Fiber
50 Fiber::toString(FIBER->state), Fiber::toString(STATE))
232 Scheduler::Fiber::Fiber(Allocator::unique_ptr<OSFiber>&& impl, uint32_t id) in Fiber() function in marl::Scheduler::Fiber
237 Scheduler::Fiber* Scheduler::Fiber::current() { in current()
242 void Scheduler::Fiber::notify() { in notify()
246 void Scheduler::Fiber::wait(marl::lock& lock, const Predicate& pred) { in wait()
253 void Scheduler::Fiber::switchTo(Fiber* to) { in switchTo()
262 Allocator::unique_ptr<Scheduler::Fiber> Scheduler::Fiber::create( in create()
267 return allocator->make_unique<Fiber>( in create()
271 Allocator::unique_ptr<Scheduler::Fiber>
272 Scheduler::Fiber::createFromCurrentThread(Allocator* allocator, uint32_t id) { in createFromCurrentThread()
273 return allocator->make_unique<Fiber>( in createFromCurrentThread()
277 const char* Scheduler::Fiber::toString(State state) { in toString()
304 Scheduler::Fiber* Scheduler::WaitingFibers::take(const TimePoint& timeout) { in take()
326 void Scheduler::WaitingFibers::add(const TimePoint& timeout, Fiber* fiber) { in add()
333 void Scheduler::WaitingFibers::erase(Fiber* fiber) { in erase()
344 bool Scheduler::WaitingFibers::contains(Fiber* fiber) const { in contains()
382 mainFiber = Fiber::createFromCurrentThread(scheduler->cfg.allocator, 0); in start()
395 mainFiber = Fiber::createFromCurrentThread(scheduler->cfg.allocator, 0); in start()
470 changeFiberState(currentFiber, Fiber::State::Running, in suspend()
471 Fiber::State::Waiting); in suspend()
474 changeFiberState(currentFiber, Fiber::State::Running, in suspend()
475 Fiber::State::Yielded); in suspend()
487 ASSERT_FIBER_STATE(to, Fiber::State::Queued); in suspend()
492 ASSERT_FIBER_STATE(to, Fiber::State::Idle); in suspend()
502 setFiberState(currentFiber, Fiber::State::Running); in suspend()
509 void Scheduler::Worker::enqueue(Fiber* fiber) { in enqueue()
514 Fiber::toString(fiber->state)); in enqueue()
516 case Fiber::State::Running: in enqueue()
517 case Fiber::State::Queued: in enqueue()
519 case Fiber::State::Waiting: in enqueue()
522 case Fiber::State::Idle: in enqueue()
523 case Fiber::State::Yielded: in enqueue()
530 setFiberState(fiber, Fiber::State::Queued); in enqueue()
573 MARL_NAME_THREAD("Thread<%.2d> Fiber<%.2d>", int(id), Fiber::current()->id); in run()
581 ASSERT_FIBER_STATE(currentFiber, Fiber::State::Running); in run()
618 changeFiberState(fiber, Fiber::State::Waiting, Fiber::State::Queued); in enqueueFiberTimeouts()
625 void Scheduler::Worker::changeFiberState(Fiber* fiber, in changeFiberState()
626 Fiber::State from, in changeFiberState()
627 Fiber::State to) const { in changeFiberState()
630 Fiber::toString(from), Fiber::toString(to)); in changeFiberState()
635 void Scheduler::Worker::setFiberState(Fiber* fiber, Fiber::State to) const { in setFiberState()
637 Fiber::toString(fiber->state), Fiber::toString(to)); in setFiberState()
673 ASSERT_FIBER_STATE(currentFiber, Fiber::State::Running); in runUntilIdle()
687 ASSERT_FIBER_STATE(fiber, Fiber::State::Queued); in runUntilIdle()
689 changeFiberState(currentFiber, Fiber::State::Running, Fiber::State::Idle); in runUntilIdle()
695 changeFiberState(currentFiber, Fiber::State::Idle, Fiber::State::Running); in runUntilIdle()
715 Scheduler::Fiber* Scheduler::Worker::createWorkerFiber() { in createWorkerFiber()
718 auto fiber = Fiber::create(scheduler->cfg.allocator, fiberId, in createWorkerFiber()
726 void Scheduler::Worker::switchToFiber(Fiber* to) { in switchToFiber()