projects
/
gem5.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
inorder: squash on memory stall
[gem5.git]
/
src
/
dev
/
io_device.cc
diff --git
a/src/dev/io_device.cc
b/src/dev/io_device.cc
index 657739e2ca196c07081f31617896fc53a2ed8b09..cdba171a6017d21b9f9a255e9f511f4a65c47c1d 100644
(file)
--- a/
src/dev/io_device.cc
+++ b/
src/dev/io_device.cc
@@
-108,9
+108,7
@@
DmaPort::DmaPort(DmaDevice *dev, System *s)
bool
DmaPort::recvTiming(PacketPtr pkt)
{
bool
DmaPort::recvTiming(PacketPtr pkt)
{
-
-
- if (pkt->result == Packet::Nacked) {
+ if (pkt->wasNacked()) {
DPRINTF(DMA, "Received nacked %s addr %#x\n",
pkt->cmdString(), pkt->getAddr());
DPRINTF(DMA, "Received nacked %s addr %#x\n",
pkt->cmdString(), pkt->getAddr());
@@
-119,7
+117,7
@@
DmaPort::recvTiming(PacketPtr pkt)
else if (backoffTime < device->maxBackoffDelay)
backoffTime <<= 1;
else if (backoffTime < device->maxBackoffDelay)
backoffTime <<= 1;
-
backoffEvent.reschedule(
curTick + backoffTime, true);
+
reschedule(backoffEvent,
curTick + backoffTime, true);
DPRINTF(DMA, "Backoff time set to %d ticks\n", backoffTime);
DPRINTF(DMA, "Backoff time set to %d ticks\n", backoffTime);
@@
-140,7
+138,10
@@
DmaPort::recvTiming(PacketPtr pkt)
state->numBytes += pkt->req->getSize();
assert(state->totBytes >= state->numBytes);
if (state->totBytes == state->numBytes) {
state->numBytes += pkt->req->getSize();
assert(state->totBytes >= state->numBytes);
if (state->totBytes == state->numBytes) {
- state->completionEvent->process();
+ if (state->delay)
+ schedule(state->completionEvent, curTick + state->delay);
+ else
+ state->completionEvent->process();
delete state;
}
delete pkt->req;
delete state;
}
delete pkt->req;
@@
-189,9
+190,9
@@
void
DmaPort::recvRetry()
{
assert(transmitList.size());
DmaPort::recvRetry()
{
assert(transmitList.size());
- PacketPtr pkt = transmitList.front();
bool result = true;
do {
bool result = true;
do {
+ PacketPtr pkt = transmitList.front();
DPRINTF(DMA, "Retry on %s addr %#x\n",
pkt->cmdString(), pkt->getAddr());
result = sendTiming(pkt);
DPRINTF(DMA, "Retry on %s addr %#x\n",
pkt->cmdString(), pkt->getAddr());
result = sendTiming(pkt);
@@
-208,7
+209,7
@@
DmaPort::recvRetry()
if (transmitList.size() && backoffTime && !inRetry) {
DPRINTF(DMA, "Scheduling backoff for %d\n", curTick+backoffTime);
if (!backoffEvent.scheduled())
if (transmitList.size() && backoffTime && !inRetry) {
DPRINTF(DMA, "Scheduling backoff for %d\n", curTick+backoffTime);
if (!backoffEvent.scheduled())
-
backoffEvent.schedule(backoffTime+
curTick);
+
schedule(backoffEvent, backoffTime +
curTick);
}
DPRINTF(DMA, "TransmitList: %d, backoffTime: %d inRetry: %d es: %d\n",
transmitList.size(), backoffTime, inRetry,
}
DPRINTF(DMA, "TransmitList: %d, backoffTime: %d inRetry: %d es: %d\n",
transmitList.size(), backoffTime, inRetry,
@@
-218,13
+219,13
@@
DmaPort::recvRetry()
void
DmaPort::dmaAction(Packet::Command cmd, Addr addr, int size, Event *event,
void
DmaPort::dmaAction(Packet::Command cmd, Addr addr, int size, Event *event,
- uint8_t *data)
+ uint8_t *data
, Tick delay
)
{
assert(event);
assert(device->getState() == SimObject::Running);
{
assert(event);
assert(device->getState() == SimObject::Running);
- DmaReqState *reqState = new DmaReqState(event, this, size);
+ DmaReqState *reqState = new DmaReqState(event, this, size
, delay
);
DPRINTF(DMA, "Starting DMA for addr: %#x size: %d sched: %d\n", addr, size,
DPRINTF(DMA, "Starting DMA for addr: %#x size: %d sched: %d\n", addr, size,
@@
-296,7
+297,7
@@
DmaPort::sendDma()
!backoffEvent.scheduled()) {
DPRINTF(DMA, "-- Scheduling backoff timer for %d\n",
backoffTime+curTick);
!backoffEvent.scheduled()) {
DPRINTF(DMA, "-- Scheduling backoff timer for %d\n",
backoffTime+curTick);
-
backoffEvent.schedule(backoffTime+
curTick);
+
schedule(backoffEvent, backoffTime +
curTick);
}
} else if (state == Enums::atomic) {
transmitList.pop_front();
}
} else if (state == Enums::atomic) {
transmitList.pop_front();
@@
-316,7
+317,7
@@
DmaPort::sendDma()
if (state->totBytes == state->numBytes) {
assert(!state->completionEvent->scheduled());
if (state->totBytes == state->numBytes) {
assert(!state->completionEvent->scheduled());
- s
tate->completionEvent->schedule(curTick + lat
);
+ s
chedule(state->completionEvent, curTick + lat + state->delay
);
delete state;
delete pkt->req;
}
delete state;
delete pkt->req;
}