scheduler.hh revision 13176
112953Sgabeblack@google.com/*
212953Sgabeblack@google.com * Copyright 2018 Google, Inc.
312953Sgabeblack@google.com *
412953Sgabeblack@google.com * Redistribution and use in source and binary forms, with or without
512953Sgabeblack@google.com * modification, are permitted provided that the following conditions are
612953Sgabeblack@google.com * met: redistributions of source code must retain the above copyright
712953Sgabeblack@google.com * notice, this list of conditions and the following disclaimer;
812953Sgabeblack@google.com * redistributions in binary form must reproduce the above copyright
912953Sgabeblack@google.com * notice, this list of conditions and the following disclaimer in the
1012953Sgabeblack@google.com * documentation and/or other materials provided with the distribution;
1112953Sgabeblack@google.com * neither the name of the copyright holders nor the names of its
1212953Sgabeblack@google.com * contributors may be used to endorse or promote products derived from
1312953Sgabeblack@google.com * this software without specific prior written permission.
1412953Sgabeblack@google.com *
1512953Sgabeblack@google.com * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
1612953Sgabeblack@google.com * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
1712953Sgabeblack@google.com * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
1812953Sgabeblack@google.com * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
1912953Sgabeblack@google.com * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
2012953Sgabeblack@google.com * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
2112953Sgabeblack@google.com * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
2212953Sgabeblack@google.com * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
2312953Sgabeblack@google.com * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
2412953Sgabeblack@google.com * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
2512953Sgabeblack@google.com * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
2612953Sgabeblack@google.com *
2712953Sgabeblack@google.com * Authors: Gabe Black
2812953Sgabeblack@google.com */
2912953Sgabeblack@google.com
3012953Sgabeblack@google.com#ifndef __SYSTEMC_CORE_SCHEDULER_HH__
3112953Sgabeblack@google.com#define __SYSTEMC_CORE_SCHEDULER_HH__
3212953Sgabeblack@google.com
3313063Sgabeblack@google.com#include <functional>
3413063Sgabeblack@google.com#include <map>
3513063Sgabeblack@google.com#include <set>
3612957Sgabeblack@google.com#include <vector>
3712957Sgabeblack@google.com
3812961Sgabeblack@google.com#include "base/logging.hh"
3913063Sgabeblack@google.com#include "sim/core.hh"
4012954Sgabeblack@google.com#include "sim/eventq.hh"
4112954Sgabeblack@google.com#include "systemc/core/channel.hh"
4212953Sgabeblack@google.com#include "systemc/core/list.hh"
4312953Sgabeblack@google.com#include "systemc/core/process.hh"
4413063Sgabeblack@google.com#include "systemc/core/sched_event.hh"
4512953Sgabeblack@google.com
4612961Sgabeblack@google.comclass Fiber;
4712961Sgabeblack@google.com
4812953Sgabeblack@google.comnamespace sc_gem5
4912953Sgabeblack@google.com{
5012953Sgabeblack@google.com
5112953Sgabeblack@google.comtypedef NodeList<Process> ProcessList;
5212954Sgabeblack@google.comtypedef NodeList<Channel> ChannelList;
5312954Sgabeblack@google.com
5412954Sgabeblack@google.com/*
5512954Sgabeblack@google.com * The scheduler supports three different mechanisms, the initialization phase,
5612954Sgabeblack@google.com * delta cycles, and timed notifications.
5712954Sgabeblack@google.com *
5812954Sgabeblack@google.com * INITIALIZATION PHASE
5912954Sgabeblack@google.com *
6012954Sgabeblack@google.com * The initialization phase has three parts:
6112954Sgabeblack@google.com * 1. Run requested channel updates.
6212954Sgabeblack@google.com * 2. Make processes which need to initialize runnable (methods and threads
6312954Sgabeblack@google.com *    which didn't have dont_initialize called on them).
6412954Sgabeblack@google.com * 3. Process delta notifications.
6512954Sgabeblack@google.com *
6612954Sgabeblack@google.com * First, the Kernel SimObject calls the update() method during its startup()
6712954Sgabeblack@google.com * callback which handles the requested channel updates. The Kernel also
6812954Sgabeblack@google.com * schedules an event to be run at time 0 with a slightly elevated priority
6912954Sgabeblack@google.com * so that it happens before any "normal" event.
7012954Sgabeblack@google.com *
7112957Sgabeblack@google.com * When that t0 event happens, it calls the schedulers prepareForInit method
7212954Sgabeblack@google.com * which performs step 2 above. That indirectly causes the scheduler's
7312954Sgabeblack@google.com * readyEvent to be scheduled with slightly lowered priority, ensuring it
7412954Sgabeblack@google.com * happens after any "normal" event.
7512954Sgabeblack@google.com *
7612954Sgabeblack@google.com * Because delta notifications are scheduled at the standard priority, all
7712954Sgabeblack@google.com * of those events will happen next, performing step 3 above. Once they finish,
7812954Sgabeblack@google.com * if the readyEvent was scheduled above, there shouldn't be any higher
7912954Sgabeblack@google.com * priority events in front of it. When it runs, it will start the first
8012954Sgabeblack@google.com * evaluate phase of the first delta cycle.
8112954Sgabeblack@google.com *
8212954Sgabeblack@google.com * DELTA CYCLE
8312954Sgabeblack@google.com *
8412954Sgabeblack@google.com * A delta cycle has three phases within it.
8512954Sgabeblack@google.com * 1. The evaluate phase where runnable processes are allowed to run.
8612954Sgabeblack@google.com * 2. The update phase where requested channel updates hapen.
8712954Sgabeblack@google.com * 3. The delta notification phase where delta notifications happen.
8812954Sgabeblack@google.com *
8913063Sgabeblack@google.com * The readyEvent runs all three steps of the delta cycle. It first goes
9012954Sgabeblack@google.com * through the list of runnable processes and executes them until the set is
9112954Sgabeblack@google.com * empty, and then immediately runs the update phase. Since these are all part
9212954Sgabeblack@google.com * of the same event, there's no chance for other events to intervene and
9312954Sgabeblack@google.com * break the required order above.
9412954Sgabeblack@google.com *
9512954Sgabeblack@google.com * During the update phase above, the spec forbids any action which would make
9612954Sgabeblack@google.com * a process runnable. That means that once the update phase finishes, the set
9712954Sgabeblack@google.com * of runnable processes will be empty. There may, however, have been some
9812954Sgabeblack@google.com * delta notifications/timeouts which will have been scheduled during either
9913063Sgabeblack@google.com * the evaluate or update phase above. Those will have been accumulated in the
10013063Sgabeblack@google.com * scheduler, and are now all executed.
10112954Sgabeblack@google.com *
10212954Sgabeblack@google.com * If any processes became runnable during the delta notification phase, the
10313063Sgabeblack@google.com * readyEvent will have been scheduled and will be waiting and ready to run
10413063Sgabeblack@google.com * again, effectively starting the next delta cycle.
10512954Sgabeblack@google.com *
10612954Sgabeblack@google.com * TIMED NOTIFICATION PHASE
10712954Sgabeblack@google.com *
10812954Sgabeblack@google.com * If no processes became runnable, the event queue will continue to process
10913063Sgabeblack@google.com * events until it comes across an event which represents all the timed
11013063Sgabeblack@google.com * notifications which are supposed to happen at a particular time. The object
11113063Sgabeblack@google.com * which tracks them will execute all those notifications, and then destroy
11213063Sgabeblack@google.com * itself. If the readyEvent is now ready to run, the next delta cycle will
11313063Sgabeblack@google.com * start.
11412961Sgabeblack@google.com *
11512961Sgabeblack@google.com * PAUSE/STOP
11612961Sgabeblack@google.com *
11712961Sgabeblack@google.com * To inject a pause from sc_pause which should happen after the current delta
11812961Sgabeblack@google.com * cycle's delta notification phase, an event is scheduled with a lower than
11912961Sgabeblack@google.com * normal priority, but higher than the readyEvent. That ensures that any
12012961Sgabeblack@google.com * delta notifications which are scheduled with normal priority will happen
12112961Sgabeblack@google.com * first, since those are part of the current delta cycle. Then the pause
12212961Sgabeblack@google.com * event will happen before the next readyEvent which would start the next
12312961Sgabeblack@google.com * delta cycle. All of these events are scheduled for the current time, and so
12412961Sgabeblack@google.com * would happen before any timed notifications went off.
12512961Sgabeblack@google.com *
12612961Sgabeblack@google.com * To inject a stop from sc_stop, the delta cycles should stop before even the
12712961Sgabeblack@google.com * delta notifications have happened, but after the evaluate and update phases.
12812961Sgabeblack@google.com * For that, a stop event with slightly higher than normal priority will be
12912961Sgabeblack@google.com * scheduled so that it happens before any of the delta notification events
13012961Sgabeblack@google.com * which are at normal priority.
13112961Sgabeblack@google.com *
13212961Sgabeblack@google.com * MAX RUN TIME
13312961Sgabeblack@google.com *
13412961Sgabeblack@google.com * When sc_start is called, it's possible to pass in a maximum time the
13513058Sgabeblack@google.com * simulation should run to, at which point sc_pause is implicitly called. The
13613058Sgabeblack@google.com * simulation is supposed to run up to the latest timed notification phase
13713058Sgabeblack@google.com * which is less than or equal to the maximum time. In other words it should
13813058Sgabeblack@google.com * run timed notifications at the maximum time, but not the subsequent evaluate
13913058Sgabeblack@google.com * phase. That's implemented by scheduling an event at the max time with a
14013058Sgabeblack@google.com * priority which is lower than all the others except the ready event. Timed
14113058Sgabeblack@google.com * notifications will happen before it fires, but it will override any ready
14213058Sgabeblack@google.com * event and prevent the evaluate phase from starting.
14312954Sgabeblack@google.com */
14412953Sgabeblack@google.com
14512953Sgabeblack@google.comclass Scheduler
14612953Sgabeblack@google.com{
14712953Sgabeblack@google.com  public:
14813144Sgabeblack@google.com    typedef std::list<ScEvent *> ScEvents;
14913063Sgabeblack@google.com
15013063Sgabeblack@google.com    class TimeSlot : public ::Event
15113063Sgabeblack@google.com    {
15213063Sgabeblack@google.com      public:
15313063Sgabeblack@google.com        TimeSlot() : ::Event(Default_Pri, AutoDelete) {}
15413063Sgabeblack@google.com
15513063Sgabeblack@google.com        ScEvents events;
15613063Sgabeblack@google.com        void process();
15713063Sgabeblack@google.com    };
15813063Sgabeblack@google.com
15913063Sgabeblack@google.com    typedef std::map<Tick, TimeSlot *> TimeSlots;
16013063Sgabeblack@google.com
16112953Sgabeblack@google.com    Scheduler();
16213072Sgabeblack@google.com    ~Scheduler();
16312953Sgabeblack@google.com
16413076Sgabeblack@google.com    void clear();
16513076Sgabeblack@google.com
16612954Sgabeblack@google.com    const std::string name() const { return "systemc_scheduler"; }
16712954Sgabeblack@google.com
16812953Sgabeblack@google.com    uint64_t numCycles() { return _numCycles; }
16912953Sgabeblack@google.com    Process *current() { return _current; }
17012953Sgabeblack@google.com
17113067Sgabeblack@google.com    void initPhase();
17212953Sgabeblack@google.com
17312957Sgabeblack@google.com    // Register a process with the scheduler.
17412957Sgabeblack@google.com    void reg(Process *p);
17512957Sgabeblack@google.com
17612957Sgabeblack@google.com    // Tell the scheduler not to initialize a process.
17712957Sgabeblack@google.com    void dontInitialize(Process *p);
17812953Sgabeblack@google.com
17912953Sgabeblack@google.com    // Run the next process, if there is one.
18012953Sgabeblack@google.com    void yield();
18112953Sgabeblack@google.com
18212953Sgabeblack@google.com    // Put a process on the ready list.
18312954Sgabeblack@google.com    void ready(Process *p);
18412954Sgabeblack@google.com
18513133Sgabeblack@google.com    // Mark a process as ready if init is finished, or put it on the list of
18613133Sgabeblack@google.com    // processes to be initialized.
18713133Sgabeblack@google.com    void resume(Process *p);
18813133Sgabeblack@google.com
18913133Sgabeblack@google.com    // Remove a process from the ready/init list if it was on one of them, and
19013133Sgabeblack@google.com    // return if it was.
19113133Sgabeblack@google.com    bool suspend(Process *p);
19213133Sgabeblack@google.com
19312954Sgabeblack@google.com    // Schedule an update for a given channel.
19412954Sgabeblack@google.com    void requestUpdate(Channel *c);
19512953Sgabeblack@google.com
19612953Sgabeblack@google.com    // Run the given process immediately, preempting whatever may be running.
19712953Sgabeblack@google.com    void
19812953Sgabeblack@google.com    runNow(Process *p)
19912953Sgabeblack@google.com    {
20013176Sgabeblack@google.com        // This function may put a process on the wrong list, ie a method on
20113176Sgabeblack@google.com        // the process list or vice versa. That's fine since that's just a
20213176Sgabeblack@google.com        // performance optimization, and the important thing here is how the
20313176Sgabeblack@google.com        // processes are ordered.
20413176Sgabeblack@google.com
20512953Sgabeblack@google.com        // If a process is running, schedule it/us to run again.
20612953Sgabeblack@google.com        if (_current)
20713176Sgabeblack@google.com            readyList->pushFirst(_current);
20812953Sgabeblack@google.com        // Schedule p to run first.
20913176Sgabeblack@google.com        readyList->pushFirst(p);
21012953Sgabeblack@google.com        yield();
21112953Sgabeblack@google.com    }
21212953Sgabeblack@google.com
21312954Sgabeblack@google.com    // Set an event queue for scheduling events.
21412954Sgabeblack@google.com    void setEventQueue(EventQueue *_eq) { eq = _eq; }
21512954Sgabeblack@google.com
21612962Sgabeblack@google.com    // Get the current time according to gem5.
21712962Sgabeblack@google.com    Tick getCurTick() { return eq ? eq->getCurTick() : 0; }
21812962Sgabeblack@google.com
21913063Sgabeblack@google.com    Tick
22013063Sgabeblack@google.com    delayed(const ::sc_core::sc_time &delay)
22113063Sgabeblack@google.com    {
22213063Sgabeblack@google.com        //XXX We're assuming the systemc time resolution is in ps.
22313063Sgabeblack@google.com        return getCurTick() + delay.value() * SimClock::Int::ps;
22413063Sgabeblack@google.com    }
22513063Sgabeblack@google.com
22612962Sgabeblack@google.com    // For scheduling delayed/timed notifications/timeouts.
22712962Sgabeblack@google.com    void
22813063Sgabeblack@google.com    schedule(ScEvent *event, const ::sc_core::sc_time &delay)
22912962Sgabeblack@google.com    {
23013063Sgabeblack@google.com        Tick tick = delayed(delay);
23113125Sgabeblack@google.com        if (tick < getCurTick())
23213125Sgabeblack@google.com            tick = getCurTick();
23313125Sgabeblack@google.com
23413063Sgabeblack@google.com        // Delta notification/timeout.
23513063Sgabeblack@google.com        if (delay.value() == 0) {
23613144Sgabeblack@google.com            event->schedule(deltas, tick);
23713063Sgabeblack@google.com            scheduleReadyEvent();
23813063Sgabeblack@google.com            return;
23913063Sgabeblack@google.com        }
24013063Sgabeblack@google.com
24113063Sgabeblack@google.com        // Timed notification/timeout.
24213063Sgabeblack@google.com        TimeSlot *&ts = timeSlots[tick];
24313063Sgabeblack@google.com        if (!ts) {
24413063Sgabeblack@google.com            ts = new TimeSlot;
24513069Sgabeblack@google.com            schedule(ts, tick);
24613063Sgabeblack@google.com        }
24713144Sgabeblack@google.com        event->schedule(ts->events, tick);
24812962Sgabeblack@google.com    }
24912962Sgabeblack@google.com
25012962Sgabeblack@google.com    // For descheduling delayed/timed notifications/timeouts.
25112962Sgabeblack@google.com    void
25213063Sgabeblack@google.com    deschedule(ScEvent *event)
25312962Sgabeblack@google.com    {
25413144Sgabeblack@google.com        ScEvents *on = event->scheduledOn();
25513144Sgabeblack@google.com
25613144Sgabeblack@google.com        if (on == &deltas) {
25713144Sgabeblack@google.com            event->deschedule();
25813144Sgabeblack@google.com            return;
25913063Sgabeblack@google.com        }
26012985Sgabeblack@google.com
26113063Sgabeblack@google.com        // Timed notification/timeout.
26213063Sgabeblack@google.com        auto tsit = timeSlots.find(event->when());
26313063Sgabeblack@google.com        panic_if(tsit == timeSlots.end(),
26413063Sgabeblack@google.com                "Descheduling event at time with no events.");
26513063Sgabeblack@google.com        TimeSlot *ts = tsit->second;
26613063Sgabeblack@google.com        ScEvents &events = ts->events;
26713144Sgabeblack@google.com        assert(on == &events);
26813063Sgabeblack@google.com        event->deschedule();
26913063Sgabeblack@google.com
27013063Sgabeblack@google.com        // If no more events are happening at this time slot, get rid of it.
27113063Sgabeblack@google.com        if (events.empty()) {
27213069Sgabeblack@google.com            deschedule(ts);
27313063Sgabeblack@google.com            timeSlots.erase(tsit);
27413063Sgabeblack@google.com        }
27512962Sgabeblack@google.com    }
27612962Sgabeblack@google.com
27712962Sgabeblack@google.com    void
27813063Sgabeblack@google.com    completeTimeSlot(TimeSlot *ts)
27912962Sgabeblack@google.com    {
28013140Sgabeblack@google.com        _changeStamp++;
28113063Sgabeblack@google.com        assert(ts == timeSlots.begin()->second);
28213063Sgabeblack@google.com        timeSlots.erase(timeSlots.begin());
28313096Sgabeblack@google.com        if (!runToTime && starved())
28413096Sgabeblack@google.com            scheduleStarvationEvent();
28512962Sgabeblack@google.com    }
28612962Sgabeblack@google.com
28712962Sgabeblack@google.com    // Pending activity ignores gem5 activity, much like how a systemc
28812962Sgabeblack@google.com    // simulation wouldn't know about asynchronous external events (socket IO
28912962Sgabeblack@google.com    // for instance) that might happen before time advances in a pure
29012962Sgabeblack@google.com    // systemc simulation. Also the spec lists what specific types of pending
29112962Sgabeblack@google.com    // activity needs to be counted, which obviously doesn't include gem5
29212962Sgabeblack@google.com    // events.
29312962Sgabeblack@google.com
29412962Sgabeblack@google.com    // Return whether there's pending systemc activity at this time.
29512962Sgabeblack@google.com    bool
29612962Sgabeblack@google.com    pendingCurr()
29712962Sgabeblack@google.com    {
29813176Sgabeblack@google.com        return !readyListMethods.empty() || !readyListThreads.empty() ||
29913176Sgabeblack@google.com            !updateList.empty() || !deltas.empty();
30012962Sgabeblack@google.com    }
30112962Sgabeblack@google.com
30212962Sgabeblack@google.com    // Return whether there are pending timed notifications or timeouts.
30312962Sgabeblack@google.com    bool
30412962Sgabeblack@google.com    pendingFuture()
30512962Sgabeblack@google.com    {
30613063Sgabeblack@google.com        return !timeSlots.empty();
30712962Sgabeblack@google.com    }
30812962Sgabeblack@google.com
30912962Sgabeblack@google.com    // Return how many ticks there are until the first pending event, if any.
31012962Sgabeblack@google.com    Tick
31112962Sgabeblack@google.com    timeToPending()
31212962Sgabeblack@google.com    {
31313063Sgabeblack@google.com        if (pendingCurr())
31412962Sgabeblack@google.com            return 0;
31513063Sgabeblack@google.com        if (pendingFuture())
31613063Sgabeblack@google.com            return timeSlots.begin()->first - getCurTick();
31713063Sgabeblack@google.com        return MaxTick - getCurTick();
31812962Sgabeblack@google.com    }
31912954Sgabeblack@google.com
32012954Sgabeblack@google.com    // Run scheduled channel updates.
32112954Sgabeblack@google.com    void update();
32212954Sgabeblack@google.com
32312961Sgabeblack@google.com    void setScMainFiber(Fiber *sc_main) { scMain = sc_main; }
32412961Sgabeblack@google.com
32512961Sgabeblack@google.com    void start(Tick max_tick, bool run_to_time);
32613061Sgabeblack@google.com    void oneCycle();
32712961Sgabeblack@google.com
32812961Sgabeblack@google.com    void schedulePause();
32912961Sgabeblack@google.com    void scheduleStop(bool finish_delta);
33012961Sgabeblack@google.com
33112961Sgabeblack@google.com    bool paused() { return _paused; }
33212961Sgabeblack@google.com    bool stopped() { return _stopped; }
33312961Sgabeblack@google.com
33413140Sgabeblack@google.com    uint64_t changeStamp() { return _changeStamp; }
33513140Sgabeblack@google.com
33612953Sgabeblack@google.com  private:
33712961Sgabeblack@google.com    typedef const EventBase::Priority Priority;
33812961Sgabeblack@google.com    static Priority DefaultPriority = EventBase::Default_Pri;
33912961Sgabeblack@google.com
34012961Sgabeblack@google.com    static Priority StopPriority = DefaultPriority - 1;
34112961Sgabeblack@google.com    static Priority PausePriority = DefaultPriority + 1;
34213058Sgabeblack@google.com    static Priority MaxTickPriority = DefaultPriority + 2;
34313058Sgabeblack@google.com    static Priority ReadyPriority = DefaultPriority + 3;
34412987Sgabeblack@google.com    static Priority StarvationPriority = ReadyPriority;
34512961Sgabeblack@google.com
34612954Sgabeblack@google.com    EventQueue *eq;
34713063Sgabeblack@google.com
34813069Sgabeblack@google.com    // For gem5 style events.
34913069Sgabeblack@google.com    void
35013069Sgabeblack@google.com    schedule(::Event *event, Tick tick)
35113069Sgabeblack@google.com    {
35213069Sgabeblack@google.com        if (initDone)
35313069Sgabeblack@google.com            eq->schedule(event, tick);
35413069Sgabeblack@google.com        else
35513069Sgabeblack@google.com            eventsToSchedule[event] = tick;
35613069Sgabeblack@google.com    }
35713069Sgabeblack@google.com
35813069Sgabeblack@google.com    void schedule(::Event *event) { schedule(event, getCurTick()); }
35913069Sgabeblack@google.com
36013069Sgabeblack@google.com    void
36113069Sgabeblack@google.com    deschedule(::Event *event)
36213069Sgabeblack@google.com    {
36313069Sgabeblack@google.com        if (initDone)
36413069Sgabeblack@google.com            eq->deschedule(event);
36513069Sgabeblack@google.com        else
36613069Sgabeblack@google.com            eventsToSchedule.erase(event);
36713069Sgabeblack@google.com    }
36813069Sgabeblack@google.com
36913063Sgabeblack@google.com    ScEvents deltas;
37013063Sgabeblack@google.com    TimeSlots timeSlots;
37112954Sgabeblack@google.com
37212954Sgabeblack@google.com    void runReady();
37312954Sgabeblack@google.com    EventWrapper<Scheduler, &Scheduler::runReady> readyEvent;
37412954Sgabeblack@google.com    void scheduleReadyEvent();
37512954Sgabeblack@google.com
37612961Sgabeblack@google.com    void pause();
37712961Sgabeblack@google.com    void stop();
37812961Sgabeblack@google.com    EventWrapper<Scheduler, &Scheduler::pause> pauseEvent;
37912961Sgabeblack@google.com    EventWrapper<Scheduler, &Scheduler::stop> stopEvent;
38012961Sgabeblack@google.com    Fiber *scMain;
38112961Sgabeblack@google.com
38212987Sgabeblack@google.com    bool
38312987Sgabeblack@google.com    starved()
38412987Sgabeblack@google.com    {
38513176Sgabeblack@google.com        return (readyListMethods.empty() && readyListThreads.empty() &&
38613176Sgabeblack@google.com                updateList.empty() && deltas.empty() &&
38713063Sgabeblack@google.com                (timeSlots.empty() || timeSlots.begin()->first > maxTick) &&
38812987Sgabeblack@google.com                initList.empty());
38912987Sgabeblack@google.com    }
39012987Sgabeblack@google.com    EventWrapper<Scheduler, &Scheduler::pause> starvationEvent;
39112987Sgabeblack@google.com    void scheduleStarvationEvent();
39212987Sgabeblack@google.com
39312961Sgabeblack@google.com    bool _started;
39412961Sgabeblack@google.com    bool _paused;
39512961Sgabeblack@google.com    bool _stopped;
39613154Sgabeblack@google.com    bool _stopNow;
39712961Sgabeblack@google.com
39812961Sgabeblack@google.com    Tick maxTick;
39913140Sgabeblack@google.com    Tick lastReadyTick;
40013140Sgabeblack@google.com    void
40113140Sgabeblack@google.com    maxTickFunc()
40213140Sgabeblack@google.com    {
40313140Sgabeblack@google.com        if (lastReadyTick != getCurTick())
40413140Sgabeblack@google.com            _changeStamp++;
40513140Sgabeblack@google.com        pause();
40613140Sgabeblack@google.com    }
40713140Sgabeblack@google.com    EventWrapper<Scheduler, &Scheduler::maxTickFunc> maxTickEvent;
40812961Sgabeblack@google.com
40912953Sgabeblack@google.com    uint64_t _numCycles;
41013140Sgabeblack@google.com    uint64_t _changeStamp;
41112953Sgabeblack@google.com
41212953Sgabeblack@google.com    Process *_current;
41312953Sgabeblack@google.com
41413067Sgabeblack@google.com    bool initDone;
41512987Sgabeblack@google.com    bool runToTime;
41613061Sgabeblack@google.com    bool runOnce;
41712957Sgabeblack@google.com
41812953Sgabeblack@google.com    ProcessList initList;
41912957Sgabeblack@google.com    ProcessList toFinalize;
42013176Sgabeblack@google.com
42113176Sgabeblack@google.com    ProcessList *readyList;
42213176Sgabeblack@google.com    ProcessList readyListMethods;
42313176Sgabeblack@google.com    ProcessList readyListThreads;
42412953Sgabeblack@google.com
42512954Sgabeblack@google.com    ChannelList updateList;
42612985Sgabeblack@google.com
42712985Sgabeblack@google.com    std::map<::Event *, Tick> eventsToSchedule;
42812953Sgabeblack@google.com};
42912953Sgabeblack@google.com
43012953Sgabeblack@google.comextern Scheduler scheduler;
43112953Sgabeblack@google.com
43213063Sgabeblack@google.cominline void
43313063Sgabeblack@google.comScheduler::TimeSlot::process()
43413063Sgabeblack@google.com{
43513144Sgabeblack@google.com    while (!events.empty())
43613144Sgabeblack@google.com        events.front()->run();
43713063Sgabeblack@google.com    scheduler.completeTimeSlot(this);
43813063Sgabeblack@google.com}
43913063Sgabeblack@google.com
44012953Sgabeblack@google.com} // namespace sc_gem5
44112953Sgabeblack@google.com
44212953Sgabeblack@google.com#endif // __SYSTEMC_CORE_SCHEDULER_H__
443