OperatingSystemProject/CPU.cpp at master · risatoy/OperatingSystemProject · GitHub

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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
//
//  CPU.cpp
//

#include <iostream>
#include <string>
#include <sstream>
#include <stddef.h>
#include <list>
#include <vector>
#include <algorithm>
#include <fstream>
#include <math.h>

#include "CPU.h"

using namespace std;

//add process to ready queue
void CPU::addProcessToReadyQueue(int priority, int gpid){
    //check if the new process is higher than the process running in CPU
    if(priority > current_process_in_CPU_priority){
        if(current_process_in_CPU_priority == -1){  //when CPU is empty
            current_process_in_CPU_priority = priority;
            current_process_in_CPU_pid = gpid;
        }
        else{  //when CPU has process and and need to push back the old one
            if(current_process_in_CPU_priority == 3)
                readyQueuePrior3.push_back(current_process_in_CPU_pid);
            else if(current_process_in_CPU_priority == 2)
                readyQueuePrior2.push_back(current_process_in_CPU_pid);
            else if(current_process_in_CPU_priority == 1)
                readyQueuePrior1.push_back(current_process_in_CPU_pid);
            else if(current_process_in_CPU_priority == 0)
                readyQueuePrior0.push_back(current_process_in_CPU_pid);
            else
                cout << "*Error; Cannot push back the process that was running in CPU!" << endl;

            current_process_in_CPU_priority = priority;
            current_process_in_CPU_pid = gpid;
        }
    }
    else{
        if(priority == 4)
            readyQueuePrior4.push_back(gpid);
        else if(priority == 3)
            readyQueuePrior3.push_back(gpid);
        else if(priority == 2)
            readyQueuePrior2.push_back(gpid);
        else if(priority == 1)
            readyQueuePrior1.push_back(gpid);
        else if(priority == 0)
            readyQueuePrior0.push_back(gpid);
        else{
            cout << "*Error; Cannot add process to Ready Queue." << endl;
            return;
        }
    }

}

//remove process from CPU when terminate
void CPU::removeProcessfromCPU(){
    current_process_in_CPU_priority = -1;
    current_process_in_CPU_pid = -1;

    //push the highest priority process in CPU
    if(!readyQueuePrior4.empty()){
        current_process_in_CPU_priority = 4;
        current_process_in_CPU_pid = readyQueuePrior4.front();
        readyQueuePrior4.pop_front();
    }
    else if(!readyQueuePrior3.empty()){
        current_process_in_CPU_priority = 3;
        current_process_in_CPU_pid = readyQueuePrior3.front();
        readyQueuePrior3.pop_front();
    }
    else if(!readyQueuePrior2.empty()){
        current_process_in_CPU_priority = 2;
        current_process_in_CPU_pid = readyQueuePrior2.front();
        readyQueuePrior2.pop_front();
    }
    else if(!readyQueuePrior1.empty()){
        current_process_in_CPU_priority = 1;
        current_process_in_CPU_pid = readyQueuePrior1.front();
        readyQueuePrior1.pop_front();
    }
    else if(!readyQueuePrior0.empty()){
        current_process_in_CPU_priority = 0;
        current_process_in_CPU_pid = readyQueuePrior0.front();
        readyQueuePrior0.pop_front();
    }

}

//command - S r
void CPU::commandShowReadyQueueAndCPU(){
    if(current_process_in_CPU_pid == -1)
        cout << "No process in CPU" << endl;
    else
        cout << "In CPU: P" << current_process_in_CPU_pid<< endl;

    if(!readyQueuePrior4.empty()){
        cout << "Ready Queue Priority 4: ";
        for (list<int>::iterator it = readyQueuePrior4.begin(); it !=readyQueuePrior4.end(); ++it)
            cout << "P" << *it << " ";
        cout << endl;
    }
    if(!readyQueuePrior3.empty()){
        cout << "Ready Queue Priority 3: ";
        for (list<int>::iterator it = readyQueuePrior3.begin(); it !=readyQueuePrior3.end(); ++it)
            cout << "P" << *it << " ";
        cout << endl;
    }
    if(!readyQueuePrior2.empty()){
        cout << "Ready Queue Priority 2: ";
        for (list<int>::iterator it = readyQueuePrior2.begin(); it !=readyQueuePrior2.end(); ++it)
            cout << "P" << *it << " ";
        cout << endl;
    }
    if(!readyQueuePrior1.empty()){
        cout << "Ready Queue Priority 1: ";
        for (list<int>::iterator it = readyQueuePrior1.begin(); it !=readyQueuePrior1.end(); ++it)
            cout << "P" << *it << " ";
        cout << endl;
    }
    if(!readyQueuePrior0.empty()){
        cout << "Ready Queue Priority 0: ";
        for (list<int>::iterator it = readyQueuePrior0.begin(); it !=readyQueuePrior0.end(); ++it)
            cout << "P" << *it << " ";
        cout << endl;
    }

}