-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathsrt_scheduler.cpp
69 lines (55 loc) · 1.62 KB
/
srt_scheduler.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
#include "Headers/scheduler.h"
class SRTScheduler : public Scheduler
{
MegaNode *current = NULL;
Proc Dispatch(std::vector<MegaNode *> newcomers, int time)
{
for (int i = 0; i < newcomers.size(); ++i)
{
mega_list.InsertSorted(newcomers[i]);
}
if (current == NULL)
{
if (mega_list.Size() == 0)
{
return IDLE_PROC;
}
else
{
current = mega_list.GetCurrent();
procs[current->origin_index].start_time = time;
fragments.push_back(current->proc.proc_name);
}
}
if (current != mega_list.GetCurrent())
{
current = mega_list.GetCurrent();
if (procs[current->origin_index].start_time == -1)
{
procs[current->origin_index].start_time = time;
}
fragments.push_back(current->proc.proc_name);
}
if (current->remaining > 0)
{
--(current->remaining);
return current->proc;
}
procs[current->origin_index].finish_time = time;
mega_list.Remove(false);
delete current;
if (mega_list.Size() == 0)
{
current = NULL;
return IDLE_PROC;
}
current = mega_list.GetCurrent();
if (procs[current->origin_index].start_time == -1)
{
procs[current->origin_index].start_time = time;
}
fragments.push_back(current->proc.proc_name);
--(current->remaining);
return current->proc;
}
};