derek/DRAMSys
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Finish multiple ready batch formation

Browse Source
This commit is contained in:
Thanh C. Tran
2017-05-16 02:03:10 +02:00
parent dab2237572
commit 6d739c64f1
2 changed files with 28 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
DRAMSys/simulator/src/controller/scheduler/SMS.cpp
View File

@@ -54,19 +54,36 @@ void SMS::batchScheduler()
while (true)
{
// updateMPKCs(memClk);
// if (isRequestBuffersEmpty() && !existReadyBatches()) {
// wait(newRequest);
// } else {
// batchFormation(memClk);
// if (existReadyBatches()) {
// if (!isSystemLightlyLoaded() && (existLowIntensityThread() || distribution(generator))) {
// selectSJF(memClk);
// } else {
// selectRR(memClk);
// }
// } else {
// wait(memClk);
// }
// }
updateMPKCs(memClk);
if (isRequestBuffersEmpty() && !existReadyBatches()) {
wait(newRequest);
if (isRequestBuffersEmpty()) {
wait(newRequest);
} else {
batchFormation(memClk);
if (existReadyBatches()) {
if (!isSystemLightlyLoaded() && (existLowIntensityThread() || distribution(generator))) {
selectSJF(memClk);
} else {
selectRR(memClk);
multiBatchFormation(memClk);
if (!isSystemLightlyLoaded() && (existLowIntensityThread() || distribution(generator))) {
if (pickSJF()) {
drain(memClk, readyBatchesIter[(*lastSelectedThread).first].front());
readyBatchesIter[(*lastSelectedThread).first].pop_front();
}
} else {
wait(memClk);
if (pickRR()) {
drain(memClk, readyBatchesIter[(*lastSelectedThread).first].front());
readyBatchesIter[(*lastSelectedThread).first].pop_front();
}
}
}
}

4
DRAMSys/simulator/src/controller/scheduler/SMS.h
View File

@@ -27,8 +27,8 @@ public:
SMS(sc_module_name /*_name*/, ControllerCore &controllerCore, unsigned int SJFprobability) : IScheduler(controllerCore), SJFprobability(SJFprobability), debugManager(DebugManager::getInstance())
{
// initialize selected thread iterator
lastSelectedThread = readybatches.end();
// lastSelectedThread = requestBuffers.end();
// lastSelectedThread = readybatches.end();
lastSelectedThread = requestBuffers.end();
SC_THREAD(batchScheduler);
}
SC_HAS_PROCESS(SMS);