if (tid >= 0) {
DPRINTF(InOrderStage, "Processing [tid:%i]\n",tid);
processThread(status_change, tid);
+ DPRINTF(InOrderStage, "Done Processing [tid:%i]\n",tid);
} else {
DPRINTF(InOrderStage, "No more threads to fetch from.\n");
+ break;
}
}
{
bool all_reqs_completed = true;
- for (int insts_fetched = 0;
+ for (int insts_fetched = instsProcessed;
insts_fetched < stageWidth && canSendInstToStage(1);
insts_fetched++) {
"list.\n", tid, inst->seqNum);
insts[tid].push(inst);
}
+ block(tid);
break;
} else if (!insts[tid].empty()){
+ DPRINTF(InOrderStage, "[tid:%u]: [sn:%u] Finished all "
+ "requests for this stage.\n", tid, inst->seqNum);
insts[tid].pop();
}
// Record that stage has written to the time buffer for activity
// tracking.
- if (toNextStageIndex) {
+ if (instsProcessed) {
wroteToTimeBuffer = true;
}
}
// signalled fetch to unblock. In that case, there is no need to tell
// fetch to block.
if (stageStatus[tid] != Blocked) {
- // Set the status to Blocked.
- stageStatus[tid] = Blocked;
-
if (stageStatus[tid] != Unblocking) {
- if (prevStageValid)
- toPrevStages->stageBlock[stageNum][tid] = true;
wroteToTimeBuffer = true;
}
+ stageStatus[tid] = Blocked;
+
+ if (prevStageValid)
+ toPrevStages->stageBlock[stageNum][tid] = true;
+
return true;
}
"next stage.\n", tid);
if (stageStatus[tid] != Blocked) {
- // Set the status to Blocked.
- stageStatus[tid] = Blocked;
-
if (stageStatus[tid] != Unblocking) {
wroteToTimeBuffer = true;
}
+
+ // Set the status to Blocked.
+ stageStatus[tid] = Blocked;
}
}
{
if (prevStageValid) {
int insts_from_prev_stage = prevStage->size;
+ int insts_from_cur_stage = skidSize();
+ DPRINTF(InOrderStage, "%i insts available from stage buffer %i. Stage "
+ "currently has %i insts from last cycle.\n",
+ insts_from_prev_stage, prevStageQueue->id(),
+ insts_from_cur_stage);
- DPRINTF(InOrderStage, "%i insts available from stage buffer %i.\n",
- insts_from_prev_stage, prevStageQueue->id());
-
+ int inserted_insts = 0;
for (int i = 0; i < insts_from_prev_stage; ++i) {
+ if (inserted_insts + insts_from_cur_stage == stageWidth) {
+ DPRINTF(InOrderStage, "Stage %i has accepted all insts "
+ "possible for this tick.\n");
+ break;
+ }
if (prevStage->insts[i]->isSquashed()) {
DPRINTF(InOrderStage, "[tid:%i]: Ignoring squashed [sn:%i], "
"not inserting into stage buffer.\n",
prevStage->insts[i]->readTid(),
prevStage->insts[i]->seqNum);
-
+ prevStage->size--;
continue;
}
prevStage->insts[i] = cpu->dummyBufferInst;
+ prevStage->size--;
+
+ inserted_insts++;
}
+ assert(prevStage->size == 0);
}
}
// Record that stage has written to the time buffer for activity
// tracking.
- if (toNextStageIndex) {
+ if (instsProcessed) {
wroteToTimeBuffer = true;
}
}