comm_monitor.cc revision 10994
18981Sandreas.hansson@arm.com/* 210744SGeoffrey.Blake@arm.com * Copyright (c) 2012-2013, 2015 ARM Limited 38981Sandreas.hansson@arm.com * All rights reserved 48981Sandreas.hansson@arm.com * 58981Sandreas.hansson@arm.com * The license below extends only to copyright in the software and shall 68981Sandreas.hansson@arm.com * not be construed as granting a license to any other intellectual 78981Sandreas.hansson@arm.com * property including but not limited to intellectual property relating 88981Sandreas.hansson@arm.com * to a hardware implementation of the functionality of the software 98981Sandreas.hansson@arm.com * licensed hereunder. You may use the software subject to the license 108981Sandreas.hansson@arm.com * terms below provided that you ensure that this notice is replicated 118981Sandreas.hansson@arm.com * unmodified and in its entirety in all distributions of the software, 128981Sandreas.hansson@arm.com * modified or unmodified, in source code or in binary form. 138981Sandreas.hansson@arm.com * 148981Sandreas.hansson@arm.com * Redistribution and use in source and binary forms, with or without 158981Sandreas.hansson@arm.com * modification, are permitted provided that the following conditions are 168981Sandreas.hansson@arm.com * met: redistributions of source code must retain the above copyright 178981Sandreas.hansson@arm.com * notice, this list of conditions and the following disclaimer; 188981Sandreas.hansson@arm.com * redistributions in binary form must reproduce the above copyright 198981Sandreas.hansson@arm.com * notice, this list of conditions and the following disclaimer in the 208981Sandreas.hansson@arm.com * documentation and/or other materials provided with the distribution; 218981Sandreas.hansson@arm.com * neither the name of the copyright holders nor the names of its 228981Sandreas.hansson@arm.com * contributors may be used to endorse or promote products derived from 238981Sandreas.hansson@arm.com * this software without specific prior written permission. 248981Sandreas.hansson@arm.com * 258981Sandreas.hansson@arm.com * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 268981Sandreas.hansson@arm.com * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 278981Sandreas.hansson@arm.com * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR 288981Sandreas.hansson@arm.com * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT 298981Sandreas.hansson@arm.com * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 308981Sandreas.hansson@arm.com * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT 318981Sandreas.hansson@arm.com * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, 328981Sandreas.hansson@arm.com * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY 338981Sandreas.hansson@arm.com * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 348981Sandreas.hansson@arm.com * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 358981Sandreas.hansson@arm.com * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 368981Sandreas.hansson@arm.com * 378981Sandreas.hansson@arm.com * Authors: Thomas Grass 388981Sandreas.hansson@arm.com * Andreas Hansson 398981Sandreas.hansson@arm.com */ 408981Sandreas.hansson@arm.com 419398Sandreas.hansson@arm.com#include "base/callback.hh" 429398Sandreas.hansson@arm.com#include "base/output.hh" 439356Snilay@cs.wisc.edu#include "base/trace.hh" 448981Sandreas.hansson@arm.com#include "debug/CommMonitor.hh" 458981Sandreas.hansson@arm.com#include "mem/comm_monitor.hh" 469398Sandreas.hansson@arm.com#include "proto/packet.pb.h" 478981Sandreas.hansson@arm.com#include "sim/stats.hh" 488981Sandreas.hansson@arm.com 498981Sandreas.hansson@arm.comCommMonitor::CommMonitor(Params* params) 508981Sandreas.hansson@arm.com : MemObject(params), 518981Sandreas.hansson@arm.com masterPort(name() + "-master", *this), 528981Sandreas.hansson@arm.com slavePort(name() + "-slave", *this), 538981Sandreas.hansson@arm.com samplePeriodicEvent(this), 548981Sandreas.hansson@arm.com samplePeriodTicks(params->sample_period), 5510902Sandreas.sandberg@arm.com samplePeriod(params->sample_period / SimClock::Float::s), 568981Sandreas.hansson@arm.com readAddrMask(params->read_addr_mask), 578981Sandreas.hansson@arm.com writeAddrMask(params->write_addr_mask), 5810615Skanishk.sugand@arm.com stackDistCalc(params->stack_dist_calc), 5910902Sandreas.sandberg@arm.com system(params->system), 6010902Sandreas.sandberg@arm.com traceStream(nullptr), 6110902Sandreas.sandberg@arm.com stats(params) 628981Sandreas.hansson@arm.com{ 6310189Ssascha.bischoff@ARM.com // If we are using a trace file, then open the file 6410189Ssascha.bischoff@ARM.com if (params->trace_enable) { 6510189Ssascha.bischoff@ARM.com std::string filename; 6610189Ssascha.bischoff@ARM.com if (params->trace_file != "") { 6710189Ssascha.bischoff@ARM.com // If the trace file is not specified as an absolute path, 6810189Ssascha.bischoff@ARM.com // append the current simulation output directory 6910189Ssascha.bischoff@ARM.com filename = simout.resolve(params->trace_file); 7010189Ssascha.bischoff@ARM.com 7110189Ssascha.bischoff@ARM.com std::string suffix = ".gz"; 7210189Ssascha.bischoff@ARM.com // If trace_compress has been set, check the suffix. Append 7310189Ssascha.bischoff@ARM.com // accordingly. 7410189Ssascha.bischoff@ARM.com if (params->trace_compress && 7510189Ssascha.bischoff@ARM.com filename.compare(filename.size() - suffix.size(), suffix.size(), 7610189Ssascha.bischoff@ARM.com suffix) != 0) 7710189Ssascha.bischoff@ARM.com filename = filename + suffix; 7810189Ssascha.bischoff@ARM.com } else { 7910189Ssascha.bischoff@ARM.com // Generate a filename from the name of the SimObject. Append .trc 8010189Ssascha.bischoff@ARM.com // and .gz if we want compression enabled. 8110189Ssascha.bischoff@ARM.com filename = simout.resolve(name() + ".trc" + 8210189Ssascha.bischoff@ARM.com (params->trace_compress ? ".gz" : "")); 8310189Ssascha.bischoff@ARM.com } 8410189Ssascha.bischoff@ARM.com 859398Sandreas.hansson@arm.com traceStream = new ProtoOutputStream(filename); 869398Sandreas.hansson@arm.com 879398Sandreas.hansson@arm.com // Create a protobuf message for the header and write it to 889398Sandreas.hansson@arm.com // the stream 8910309Snilay@cs.wisc.edu ProtoMessage::PacketHeader header_msg; 909398Sandreas.hansson@arm.com header_msg.set_obj_id(name()); 919398Sandreas.hansson@arm.com header_msg.set_tick_freq(SimClock::Frequency); 929398Sandreas.hansson@arm.com traceStream->write(header_msg); 939398Sandreas.hansson@arm.com 949398Sandreas.hansson@arm.com // Register a callback to compensate for the destructor not 959398Sandreas.hansson@arm.com // being called. The callback forces the stream to flush and 969398Sandreas.hansson@arm.com // closes the output file. 979398Sandreas.hansson@arm.com Callback* cb = new MakeCallback<CommMonitor, 989398Sandreas.hansson@arm.com &CommMonitor::closeStreams>(this); 999398Sandreas.hansson@arm.com registerExitCallback(cb); 1009398Sandreas.hansson@arm.com } 1019398Sandreas.hansson@arm.com 1028981Sandreas.hansson@arm.com DPRINTF(CommMonitor, 10310064Sandreas.hansson@arm.com "Created monitor %s with sample period %d ticks (%f ms)\n", 10410902Sandreas.sandberg@arm.com name(), samplePeriodTicks, samplePeriod * 1E3); 1058981Sandreas.hansson@arm.com} 1068981Sandreas.hansson@arm.com 10710412Sandreas.hansson@arm.comCommMonitor::~CommMonitor() 10810412Sandreas.hansson@arm.com{ 10910412Sandreas.hansson@arm.com // if not already done, close the stream 11010412Sandreas.hansson@arm.com closeStreams(); 11110412Sandreas.hansson@arm.com} 11210412Sandreas.hansson@arm.com 1139398Sandreas.hansson@arm.comvoid 1149398Sandreas.hansson@arm.comCommMonitor::closeStreams() 1159398Sandreas.hansson@arm.com{ 1169398Sandreas.hansson@arm.com if (traceStream != NULL) 1179398Sandreas.hansson@arm.com delete traceStream; 1189398Sandreas.hansson@arm.com} 1199398Sandreas.hansson@arm.com 1208981Sandreas.hansson@arm.comCommMonitor* 1218981Sandreas.hansson@arm.comCommMonitorParams::create() 1228981Sandreas.hansson@arm.com{ 1238981Sandreas.hansson@arm.com return new CommMonitor(this); 1248981Sandreas.hansson@arm.com} 1258981Sandreas.hansson@arm.com 1268981Sandreas.hansson@arm.comvoid 1278981Sandreas.hansson@arm.comCommMonitor::init() 1288981Sandreas.hansson@arm.com{ 1298981Sandreas.hansson@arm.com // make sure both sides of the monitor are connected 1308981Sandreas.hansson@arm.com if (!slavePort.isConnected() || !masterPort.isConnected()) 1318981Sandreas.hansson@arm.com fatal("Communication monitor is not connected on both sides.\n"); 13210129SSascha.Bischoff@ARM.com 13310129SSascha.Bischoff@ARM.com if (traceStream != NULL) { 13410129SSascha.Bischoff@ARM.com // Check the memory mode. We only record something when in 13510129SSascha.Bischoff@ARM.com // timing mode. Warn accordingly. 13610129SSascha.Bischoff@ARM.com if (!system->isTimingMode()) 13710129SSascha.Bischoff@ARM.com warn("%s: Not in timing mode. No trace will be recorded.", name()); 13810129SSascha.Bischoff@ARM.com } 13910615Skanishk.sugand@arm.com 1408981Sandreas.hansson@arm.com} 1418981Sandreas.hansson@arm.com 14210994Sandreas.sandberg@arm.comvoid 14310994Sandreas.sandberg@arm.comCommMonitor::regProbePoints() 14410994Sandreas.sandberg@arm.com{ 14510994Sandreas.sandberg@arm.com ppPktReq.reset(new ProbePoints::Packet(getProbeManager(), "PktRequest")); 14610994Sandreas.sandberg@arm.com ppPktResp.reset(new ProbePoints::Packet(getProbeManager(), "PktResponse")); 14710994Sandreas.sandberg@arm.com} 14810994Sandreas.sandberg@arm.com 1499294Sandreas.hansson@arm.comBaseMasterPort& 1509294Sandreas.hansson@arm.comCommMonitor::getMasterPort(const std::string& if_name, PortID idx) 1518981Sandreas.hansson@arm.com{ 1528981Sandreas.hansson@arm.com if (if_name == "master") { 1538981Sandreas.hansson@arm.com return masterPort; 1548981Sandreas.hansson@arm.com } else { 1558981Sandreas.hansson@arm.com return MemObject::getMasterPort(if_name, idx); 1568981Sandreas.hansson@arm.com } 1578981Sandreas.hansson@arm.com} 1588981Sandreas.hansson@arm.com 1599294Sandreas.hansson@arm.comBaseSlavePort& 1609294Sandreas.hansson@arm.comCommMonitor::getSlavePort(const std::string& if_name, PortID idx) 1618981Sandreas.hansson@arm.com{ 1628981Sandreas.hansson@arm.com if (if_name == "slave") { 1638981Sandreas.hansson@arm.com return slavePort; 1648981Sandreas.hansson@arm.com } else { 1658981Sandreas.hansson@arm.com return MemObject::getSlavePort(if_name, idx); 1668981Sandreas.hansson@arm.com } 1678981Sandreas.hansson@arm.com} 1688981Sandreas.hansson@arm.com 1698981Sandreas.hansson@arm.comvoid 1708981Sandreas.hansson@arm.comCommMonitor::recvFunctional(PacketPtr pkt) 1718981Sandreas.hansson@arm.com{ 1728981Sandreas.hansson@arm.com masterPort.sendFunctional(pkt); 1738981Sandreas.hansson@arm.com} 1748981Sandreas.hansson@arm.com 1758981Sandreas.hansson@arm.comvoid 1768981Sandreas.hansson@arm.comCommMonitor::recvFunctionalSnoop(PacketPtr pkt) 1778981Sandreas.hansson@arm.com{ 1788981Sandreas.hansson@arm.com slavePort.sendFunctionalSnoop(pkt); 1798981Sandreas.hansson@arm.com} 1808981Sandreas.hansson@arm.com 1818981Sandreas.hansson@arm.comTick 1828981Sandreas.hansson@arm.comCommMonitor::recvAtomic(PacketPtr pkt) 1838981Sandreas.hansson@arm.com{ 18410994Sandreas.sandberg@arm.com ppPktReq->notify(pkt); 18510994Sandreas.sandberg@arm.com 18610744SGeoffrey.Blake@arm.com // do stack distance calculations if enabled 18710615Skanishk.sugand@arm.com if (stackDistCalc) 18810615Skanishk.sugand@arm.com stackDistCalc->update(pkt->cmd, pkt->getAddr()); 18910615Skanishk.sugand@arm.com 19010902Sandreas.sandberg@arm.com // if tracing enabled, store the packet information 19110902Sandreas.sandberg@arm.com // to the trace stream 19210902Sandreas.sandberg@arm.com if (traceStream != NULL) { 19310744SGeoffrey.Blake@arm.com ProtoMessage::Packet pkt_msg; 19410744SGeoffrey.Blake@arm.com pkt_msg.set_tick(curTick()); 19510744SGeoffrey.Blake@arm.com pkt_msg.set_cmd(pkt->cmdToIndex()); 19610744SGeoffrey.Blake@arm.com pkt_msg.set_flags(pkt->req->getFlags()); 19710744SGeoffrey.Blake@arm.com pkt_msg.set_addr(pkt->getAddr()); 19810744SGeoffrey.Blake@arm.com pkt_msg.set_size(pkt->getSize()); 19910744SGeoffrey.Blake@arm.com 20010744SGeoffrey.Blake@arm.com traceStream->write(pkt_msg); 20110744SGeoffrey.Blake@arm.com } 20210744SGeoffrey.Blake@arm.com 20310994Sandreas.sandberg@arm.com const Tick delay(masterPort.sendAtomic(pkt)); 20410994Sandreas.sandberg@arm.com assert(pkt->isResponse()); 20510994Sandreas.sandberg@arm.com ppPktResp->notify(pkt); 20610994Sandreas.sandberg@arm.com return delay; 2078981Sandreas.hansson@arm.com} 2088981Sandreas.hansson@arm.com 2098981Sandreas.hansson@arm.comTick 2108981Sandreas.hansson@arm.comCommMonitor::recvAtomicSnoop(PacketPtr pkt) 2118981Sandreas.hansson@arm.com{ 2128981Sandreas.hansson@arm.com return slavePort.sendAtomicSnoop(pkt); 2138981Sandreas.hansson@arm.com} 2148981Sandreas.hansson@arm.com 2158981Sandreas.hansson@arm.combool 2168981Sandreas.hansson@arm.comCommMonitor::recvTimingReq(PacketPtr pkt) 2178981Sandreas.hansson@arm.com{ 2188981Sandreas.hansson@arm.com // should always see a request 2198981Sandreas.hansson@arm.com assert(pkt->isRequest()); 2208981Sandreas.hansson@arm.com 2218981Sandreas.hansson@arm.com // Store relevant fields of packet, because packet may be modified 2228981Sandreas.hansson@arm.com // or even deleted when sendTiming() is called. 22310994Sandreas.sandberg@arm.com const bool is_read = pkt->isRead(); 22410994Sandreas.sandberg@arm.com const bool is_write = pkt->isWrite(); 22510994Sandreas.sandberg@arm.com const MemCmd cmd = pkt->cmd; 22610994Sandreas.sandberg@arm.com const int cmd_idx = pkt->cmdToIndex(); 22710994Sandreas.sandberg@arm.com const Request::FlagsType req_flags = pkt->req->getFlags(); 22810994Sandreas.sandberg@arm.com const unsigned size = pkt->getSize(); 22910994Sandreas.sandberg@arm.com const Addr addr = pkt->getAddr(); 23010994Sandreas.sandberg@arm.com const bool expects_response( 23110994Sandreas.sandberg@arm.com pkt->needsResponse() && !pkt->memInhibitAsserted()); 2328981Sandreas.hansson@arm.com 2338981Sandreas.hansson@arm.com // If a cache miss is served by a cache, a monitor near the memory 2348981Sandreas.hansson@arm.com // would see a request which needs a response, but this response 2358981Sandreas.hansson@arm.com // would be inhibited and not come back from the memory. Therefore 2368981Sandreas.hansson@arm.com // we additionally have to check the inhibit flag. 2379785Sandreas.hansson@arm.com if (expects_response && !stats.disableLatencyHists) { 2389542Sandreas.hansson@arm.com pkt->pushSenderState(new CommMonitorSenderState(curTick())); 2398981Sandreas.hansson@arm.com } 2408981Sandreas.hansson@arm.com 2418981Sandreas.hansson@arm.com // Attempt to send the packet (always succeeds for inhibited 2428981Sandreas.hansson@arm.com // packets) 2438981Sandreas.hansson@arm.com bool successful = masterPort.sendTimingReq(pkt); 2448981Sandreas.hansson@arm.com 2458981Sandreas.hansson@arm.com // If not successful, restore the sender state 2469785Sandreas.hansson@arm.com if (!successful && expects_response && !stats.disableLatencyHists) { 2479542Sandreas.hansson@arm.com delete pkt->popSenderState(); 2488981Sandreas.hansson@arm.com } 2498981Sandreas.hansson@arm.com 25010994Sandreas.sandberg@arm.com if (successful) { 25110994Sandreas.sandberg@arm.com // The receiver might already have modified the packet. We 25210994Sandreas.sandberg@arm.com // want to give the probe access to the original packet, which 25310994Sandreas.sandberg@arm.com // means we need to fake the original packet by temporarily 25410994Sandreas.sandberg@arm.com // restoring the command. 25510994Sandreas.sandberg@arm.com const MemCmd response_cmd(pkt->cmd); 25610994Sandreas.sandberg@arm.com pkt->cmd = cmd; 25710994Sandreas.sandberg@arm.com ppPktReq->notify(pkt); 25810994Sandreas.sandberg@arm.com pkt->cmd = response_cmd; 25910994Sandreas.sandberg@arm.com } 26010994Sandreas.sandberg@arm.com 26110615Skanishk.sugand@arm.com // If successful and we are calculating stack distances, update 26210615Skanishk.sugand@arm.com // the calculator 26310615Skanishk.sugand@arm.com if (successful && stackDistCalc) 26410615Skanishk.sugand@arm.com stackDistCalc->update(cmd, addr); 26510615Skanishk.sugand@arm.com 2669398Sandreas.hansson@arm.com if (successful && traceStream != NULL) { 2679398Sandreas.hansson@arm.com // Create a protobuf message representing the 2689398Sandreas.hansson@arm.com // packet. Currently we do not preserve the flags in the 2699398Sandreas.hansson@arm.com // trace. 27010309Snilay@cs.wisc.edu ProtoMessage::Packet pkt_msg; 2719398Sandreas.hansson@arm.com pkt_msg.set_tick(curTick()); 27210615Skanishk.sugand@arm.com pkt_msg.set_cmd(cmd_idx); 2739609Sandreas.hansson@arm.com pkt_msg.set_flags(req_flags); 2749540Sandreas.hansson@armm.com pkt_msg.set_addr(addr); 2759540Sandreas.hansson@armm.com pkt_msg.set_size(size); 2769398Sandreas.hansson@arm.com 2779398Sandreas.hansson@arm.com traceStream->write(pkt_msg); 2789398Sandreas.hansson@arm.com } 2799398Sandreas.hansson@arm.com 2809785Sandreas.hansson@arm.com if (successful && is_read) { 2818981Sandreas.hansson@arm.com DPRINTF(CommMonitor, "Forwarded read request\n"); 2828981Sandreas.hansson@arm.com 2838981Sandreas.hansson@arm.com // Increment number of observed read transactions 2848981Sandreas.hansson@arm.com if (!stats.disableTransactionHists) { 2858981Sandreas.hansson@arm.com ++stats.readTrans; 2868981Sandreas.hansson@arm.com } 2878981Sandreas.hansson@arm.com 2888981Sandreas.hansson@arm.com // Get sample of burst length 2898981Sandreas.hansson@arm.com if (!stats.disableBurstLengthHists) { 2908981Sandreas.hansson@arm.com stats.readBurstLengthHist.sample(size); 2918981Sandreas.hansson@arm.com } 2928981Sandreas.hansson@arm.com 2938981Sandreas.hansson@arm.com // Sample the masked address 2948981Sandreas.hansson@arm.com if (!stats.disableAddrDists) { 2958981Sandreas.hansson@arm.com stats.readAddrDist.sample(addr & readAddrMask); 2968981Sandreas.hansson@arm.com } 2978981Sandreas.hansson@arm.com 2988981Sandreas.hansson@arm.com // If it needs a response increment number of outstanding read 2998981Sandreas.hansson@arm.com // requests 3009785Sandreas.hansson@arm.com if (!stats.disableOutstandingHists && expects_response) { 3018981Sandreas.hansson@arm.com ++stats.outstandingReadReqs; 3028981Sandreas.hansson@arm.com } 3038981Sandreas.hansson@arm.com 3048981Sandreas.hansson@arm.com if (!stats.disableITTDists) { 3058981Sandreas.hansson@arm.com // Sample value of read-read inter transaction time 3068981Sandreas.hansson@arm.com if (stats.timeOfLastRead != 0) { 3078981Sandreas.hansson@arm.com stats.ittReadRead.sample(curTick() - stats.timeOfLastRead); 3088981Sandreas.hansson@arm.com } 3098981Sandreas.hansson@arm.com stats.timeOfLastRead = curTick(); 3108981Sandreas.hansson@arm.com 3118981Sandreas.hansson@arm.com // Sample value of req-req inter transaction time 3128981Sandreas.hansson@arm.com if (stats.timeOfLastReq != 0) { 3138981Sandreas.hansson@arm.com stats.ittReqReq.sample(curTick() - stats.timeOfLastReq); 3148981Sandreas.hansson@arm.com } 3158981Sandreas.hansson@arm.com stats.timeOfLastReq = curTick(); 3168981Sandreas.hansson@arm.com } 3179785Sandreas.hansson@arm.com } else if (successful && is_write) { 3188981Sandreas.hansson@arm.com DPRINTF(CommMonitor, "Forwarded write request\n"); 3198981Sandreas.hansson@arm.com 3208981Sandreas.hansson@arm.com // Same as for reads 3218981Sandreas.hansson@arm.com if (!stats.disableTransactionHists) { 3228981Sandreas.hansson@arm.com ++stats.writeTrans; 3238981Sandreas.hansson@arm.com } 3248981Sandreas.hansson@arm.com 3258981Sandreas.hansson@arm.com if (!stats.disableBurstLengthHists) { 3268981Sandreas.hansson@arm.com stats.writeBurstLengthHist.sample(size); 3278981Sandreas.hansson@arm.com } 3288981Sandreas.hansson@arm.com 3298981Sandreas.hansson@arm.com // Update the bandwidth stats on the request 3308981Sandreas.hansson@arm.com if (!stats.disableBandwidthHists) { 3318981Sandreas.hansson@arm.com stats.writtenBytes += size; 3328981Sandreas.hansson@arm.com stats.totalWrittenBytes += size; 3338981Sandreas.hansson@arm.com } 3348981Sandreas.hansson@arm.com 3358981Sandreas.hansson@arm.com // Sample the masked write address 3368981Sandreas.hansson@arm.com if (!stats.disableAddrDists) { 3378981Sandreas.hansson@arm.com stats.writeAddrDist.sample(addr & writeAddrMask); 3388981Sandreas.hansson@arm.com } 3398981Sandreas.hansson@arm.com 3409785Sandreas.hansson@arm.com if (!stats.disableOutstandingHists && expects_response) { 3418981Sandreas.hansson@arm.com ++stats.outstandingWriteReqs; 3428981Sandreas.hansson@arm.com } 3438981Sandreas.hansson@arm.com 3448981Sandreas.hansson@arm.com if (!stats.disableITTDists) { 3458981Sandreas.hansson@arm.com // Sample value of write-to-write inter transaction time 3468981Sandreas.hansson@arm.com if (stats.timeOfLastWrite != 0) { 3478981Sandreas.hansson@arm.com stats.ittWriteWrite.sample(curTick() - stats.timeOfLastWrite); 3488981Sandreas.hansson@arm.com } 3498981Sandreas.hansson@arm.com stats.timeOfLastWrite = curTick(); 3508981Sandreas.hansson@arm.com 3518981Sandreas.hansson@arm.com // Sample value of req-to-req inter transaction time 3528981Sandreas.hansson@arm.com if (stats.timeOfLastReq != 0) { 3538981Sandreas.hansson@arm.com stats.ittReqReq.sample(curTick() - stats.timeOfLastReq); 3548981Sandreas.hansson@arm.com } 3558981Sandreas.hansson@arm.com stats.timeOfLastReq = curTick(); 3568981Sandreas.hansson@arm.com } 3578981Sandreas.hansson@arm.com } else if (successful) { 3588981Sandreas.hansson@arm.com DPRINTF(CommMonitor, "Forwarded non read/write request\n"); 3598981Sandreas.hansson@arm.com } 3608981Sandreas.hansson@arm.com 3618981Sandreas.hansson@arm.com return successful; 3628981Sandreas.hansson@arm.com} 3638981Sandreas.hansson@arm.com 3648981Sandreas.hansson@arm.combool 3658981Sandreas.hansson@arm.comCommMonitor::recvTimingResp(PacketPtr pkt) 3668981Sandreas.hansson@arm.com{ 3678981Sandreas.hansson@arm.com // should always see responses 3688981Sandreas.hansson@arm.com assert(pkt->isResponse()); 3698981Sandreas.hansson@arm.com 3708981Sandreas.hansson@arm.com // Store relevant fields of packet, because packet may be modified 3718981Sandreas.hansson@arm.com // or even deleted when sendTiming() is called. 3729785Sandreas.hansson@arm.com bool is_read = pkt->isRead(); 3739785Sandreas.hansson@arm.com bool is_write = pkt->isWrite(); 3748981Sandreas.hansson@arm.com unsigned size = pkt->getSize(); 3758981Sandreas.hansson@arm.com Tick latency = 0; 3769785Sandreas.hansson@arm.com CommMonitorSenderState* received_state = 3778981Sandreas.hansson@arm.com dynamic_cast<CommMonitorSenderState*>(pkt->senderState); 3788981Sandreas.hansson@arm.com 3798981Sandreas.hansson@arm.com if (!stats.disableLatencyHists) { 3808981Sandreas.hansson@arm.com // Restore initial sender state 3819785Sandreas.hansson@arm.com if (received_state == NULL) 3828981Sandreas.hansson@arm.com panic("Monitor got a response without monitor sender state\n"); 3838981Sandreas.hansson@arm.com 3848981Sandreas.hansson@arm.com // Restore the sate 3859785Sandreas.hansson@arm.com pkt->senderState = received_state->predecessor; 3868981Sandreas.hansson@arm.com } 3878981Sandreas.hansson@arm.com 3888981Sandreas.hansson@arm.com // Attempt to send the packet 3898981Sandreas.hansson@arm.com bool successful = slavePort.sendTimingResp(pkt); 3908981Sandreas.hansson@arm.com 3918981Sandreas.hansson@arm.com if (!stats.disableLatencyHists) { 3928981Sandreas.hansson@arm.com // If packet successfully send, sample value of latency, 3938981Sandreas.hansson@arm.com // afterwards delete sender state, otherwise restore state 3948981Sandreas.hansson@arm.com if (successful) { 3959785Sandreas.hansson@arm.com latency = curTick() - received_state->transmitTime; 3968981Sandreas.hansson@arm.com DPRINTF(CommMonitor, "Latency: %d\n", latency); 3979785Sandreas.hansson@arm.com delete received_state; 3988981Sandreas.hansson@arm.com } else { 3998981Sandreas.hansson@arm.com // Don't delete anything and let the packet look like we 4008981Sandreas.hansson@arm.com // did not touch it 4019785Sandreas.hansson@arm.com pkt->senderState = received_state; 4028981Sandreas.hansson@arm.com } 4038981Sandreas.hansson@arm.com } 4048981Sandreas.hansson@arm.com 40510994Sandreas.sandberg@arm.com if (successful) { 40610994Sandreas.sandberg@arm.com assert(pkt->isResponse()); 40710994Sandreas.sandberg@arm.com ppPktResp->notify(pkt); 40810994Sandreas.sandberg@arm.com } 40910994Sandreas.sandberg@arm.com 4109785Sandreas.hansson@arm.com if (successful && is_read) { 4118981Sandreas.hansson@arm.com // Decrement number of outstanding read requests 4128981Sandreas.hansson@arm.com DPRINTF(CommMonitor, "Received read response\n"); 4138981Sandreas.hansson@arm.com if (!stats.disableOutstandingHists) { 4148981Sandreas.hansson@arm.com assert(stats.outstandingReadReqs != 0); 4158981Sandreas.hansson@arm.com --stats.outstandingReadReqs; 4168981Sandreas.hansson@arm.com } 4178981Sandreas.hansson@arm.com 4188981Sandreas.hansson@arm.com if (!stats.disableLatencyHists) { 4198981Sandreas.hansson@arm.com stats.readLatencyHist.sample(latency); 4208981Sandreas.hansson@arm.com } 4218981Sandreas.hansson@arm.com 4228981Sandreas.hansson@arm.com // Update the bandwidth stats based on responses for reads 4238981Sandreas.hansson@arm.com if (!stats.disableBandwidthHists) { 4248981Sandreas.hansson@arm.com stats.readBytes += size; 4258981Sandreas.hansson@arm.com stats.totalReadBytes += size; 4268981Sandreas.hansson@arm.com } 4278981Sandreas.hansson@arm.com 4289785Sandreas.hansson@arm.com } else if (successful && is_write) { 4298981Sandreas.hansson@arm.com // Decrement number of outstanding write requests 4308981Sandreas.hansson@arm.com DPRINTF(CommMonitor, "Received write response\n"); 4318981Sandreas.hansson@arm.com if (!stats.disableOutstandingHists) { 4328981Sandreas.hansson@arm.com assert(stats.outstandingWriteReqs != 0); 4338981Sandreas.hansson@arm.com --stats.outstandingWriteReqs; 4348981Sandreas.hansson@arm.com } 4358981Sandreas.hansson@arm.com 4368981Sandreas.hansson@arm.com if (!stats.disableLatencyHists) { 4378981Sandreas.hansson@arm.com stats.writeLatencyHist.sample(latency); 4388981Sandreas.hansson@arm.com } 4398981Sandreas.hansson@arm.com } else if (successful) { 4408981Sandreas.hansson@arm.com DPRINTF(CommMonitor, "Received non read/write response\n"); 4418981Sandreas.hansson@arm.com } 4428981Sandreas.hansson@arm.com return successful; 4438981Sandreas.hansson@arm.com} 4448981Sandreas.hansson@arm.com 4458981Sandreas.hansson@arm.comvoid 4468981Sandreas.hansson@arm.comCommMonitor::recvTimingSnoopReq(PacketPtr pkt) 4478981Sandreas.hansson@arm.com{ 4488981Sandreas.hansson@arm.com slavePort.sendTimingSnoopReq(pkt); 4498981Sandreas.hansson@arm.com} 4508981Sandreas.hansson@arm.com 4518981Sandreas.hansson@arm.combool 4528981Sandreas.hansson@arm.comCommMonitor::recvTimingSnoopResp(PacketPtr pkt) 4538981Sandreas.hansson@arm.com{ 4548981Sandreas.hansson@arm.com return masterPort.sendTimingSnoopResp(pkt); 4558981Sandreas.hansson@arm.com} 4568981Sandreas.hansson@arm.com 4578981Sandreas.hansson@arm.combool 4588981Sandreas.hansson@arm.comCommMonitor::isSnooping() const 4598981Sandreas.hansson@arm.com{ 4609088Sandreas.hansson@arm.com // check if the connected master port is snooping 4619088Sandreas.hansson@arm.com return slavePort.isSnooping(); 4628981Sandreas.hansson@arm.com} 4638981Sandreas.hansson@arm.com 4648981Sandreas.hansson@arm.comAddrRangeList 4659090Sandreas.hansson@arm.comCommMonitor::getAddrRanges() const 4668981Sandreas.hansson@arm.com{ 4679089Sandreas.hansson@arm.com // get the address ranges of the connected slave port 4689089Sandreas.hansson@arm.com return masterPort.getAddrRanges(); 4698981Sandreas.hansson@arm.com} 4708981Sandreas.hansson@arm.com 4718981Sandreas.hansson@arm.comvoid 47210713Sandreas.hansson@arm.comCommMonitor::recvReqRetry() 4738981Sandreas.hansson@arm.com{ 47410713Sandreas.hansson@arm.com slavePort.sendRetryReq(); 4758981Sandreas.hansson@arm.com} 4768981Sandreas.hansson@arm.com 4778981Sandreas.hansson@arm.comvoid 47810713Sandreas.hansson@arm.comCommMonitor::recvRespRetry() 4798981Sandreas.hansson@arm.com{ 48010713Sandreas.hansson@arm.com masterPort.sendRetryResp(); 4818981Sandreas.hansson@arm.com} 4828981Sandreas.hansson@arm.com 4838981Sandreas.hansson@arm.comvoid 4848981Sandreas.hansson@arm.comCommMonitor::recvRangeChange() 4858981Sandreas.hansson@arm.com{ 4868981Sandreas.hansson@arm.com slavePort.sendRangeChange(); 4878981Sandreas.hansson@arm.com} 4888981Sandreas.hansson@arm.com 4898981Sandreas.hansson@arm.comvoid 4908981Sandreas.hansson@arm.comCommMonitor::regStats() 4918981Sandreas.hansson@arm.com{ 4928981Sandreas.hansson@arm.com // Initialise all the monitor stats 4938981Sandreas.hansson@arm.com using namespace Stats; 4948981Sandreas.hansson@arm.com 4958981Sandreas.hansson@arm.com stats.readBurstLengthHist 4968981Sandreas.hansson@arm.com .init(params()->burst_length_bins) 4978981Sandreas.hansson@arm.com .name(name() + ".readBurstLengthHist") 4988981Sandreas.hansson@arm.com .desc("Histogram of burst lengths of transmitted packets") 4998981Sandreas.hansson@arm.com .flags(stats.disableBurstLengthHists ? nozero : pdf); 5008981Sandreas.hansson@arm.com 5018981Sandreas.hansson@arm.com stats.writeBurstLengthHist 5028981Sandreas.hansson@arm.com .init(params()->burst_length_bins) 5038981Sandreas.hansson@arm.com .name(name() + ".writeBurstLengthHist") 5048981Sandreas.hansson@arm.com .desc("Histogram of burst lengths of transmitted packets") 5058981Sandreas.hansson@arm.com .flags(stats.disableBurstLengthHists ? nozero : pdf); 5068981Sandreas.hansson@arm.com 5078981Sandreas.hansson@arm.com // Stats based on received responses 5088981Sandreas.hansson@arm.com stats.readBandwidthHist 5098981Sandreas.hansson@arm.com .init(params()->bandwidth_bins) 5108981Sandreas.hansson@arm.com .name(name() + ".readBandwidthHist") 5118981Sandreas.hansson@arm.com .desc("Histogram of read bandwidth per sample period (bytes/s)") 5128981Sandreas.hansson@arm.com .flags(stats.disableBandwidthHists ? nozero : pdf); 5138981Sandreas.hansson@arm.com 5148981Sandreas.hansson@arm.com stats.averageReadBW 5158981Sandreas.hansson@arm.com .name(name() + ".averageReadBandwidth") 5168981Sandreas.hansson@arm.com .desc("Average read bandwidth (bytes/s)") 5178981Sandreas.hansson@arm.com .flags(stats.disableBandwidthHists ? nozero : pdf); 5188981Sandreas.hansson@arm.com 5198981Sandreas.hansson@arm.com stats.totalReadBytes 5208981Sandreas.hansson@arm.com .name(name() + ".totalReadBytes") 5218981Sandreas.hansson@arm.com .desc("Number of bytes read") 5228981Sandreas.hansson@arm.com .flags(stats.disableBandwidthHists ? nozero : pdf); 5238981Sandreas.hansson@arm.com 5248981Sandreas.hansson@arm.com stats.averageReadBW = stats.totalReadBytes / simSeconds; 5258981Sandreas.hansson@arm.com 5268981Sandreas.hansson@arm.com // Stats based on successfully sent requests 5278981Sandreas.hansson@arm.com stats.writeBandwidthHist 5288981Sandreas.hansson@arm.com .init(params()->bandwidth_bins) 5298981Sandreas.hansson@arm.com .name(name() + ".writeBandwidthHist") 5308981Sandreas.hansson@arm.com .desc("Histogram of write bandwidth (bytes/s)") 5318981Sandreas.hansson@arm.com .flags(stats.disableBandwidthHists ? (pdf | nozero) : pdf); 5328981Sandreas.hansson@arm.com 5338981Sandreas.hansson@arm.com stats.averageWriteBW 5348981Sandreas.hansson@arm.com .name(name() + ".averageWriteBandwidth") 5358981Sandreas.hansson@arm.com .desc("Average write bandwidth (bytes/s)") 5368981Sandreas.hansson@arm.com .flags(stats.disableBandwidthHists ? nozero : pdf); 5378981Sandreas.hansson@arm.com 5388981Sandreas.hansson@arm.com stats.totalWrittenBytes 5398981Sandreas.hansson@arm.com .name(name() + ".totalWrittenBytes") 5408981Sandreas.hansson@arm.com .desc("Number of bytes written") 5418981Sandreas.hansson@arm.com .flags(stats.disableBandwidthHists ? nozero : pdf); 5428981Sandreas.hansson@arm.com 5438981Sandreas.hansson@arm.com stats.averageWriteBW = stats.totalWrittenBytes / simSeconds; 5448981Sandreas.hansson@arm.com 5458981Sandreas.hansson@arm.com stats.readLatencyHist 5468981Sandreas.hansson@arm.com .init(params()->latency_bins) 5478981Sandreas.hansson@arm.com .name(name() + ".readLatencyHist") 5488981Sandreas.hansson@arm.com .desc("Read request-response latency") 5498981Sandreas.hansson@arm.com .flags(stats.disableLatencyHists ? nozero : pdf); 5508981Sandreas.hansson@arm.com 5518981Sandreas.hansson@arm.com stats.writeLatencyHist 5528981Sandreas.hansson@arm.com .init(params()->latency_bins) 5538981Sandreas.hansson@arm.com .name(name() + ".writeLatencyHist") 5548981Sandreas.hansson@arm.com .desc("Write request-response latency") 5558981Sandreas.hansson@arm.com .flags(stats.disableLatencyHists ? nozero : pdf); 5568981Sandreas.hansson@arm.com 5578981Sandreas.hansson@arm.com stats.ittReadRead 5588981Sandreas.hansson@arm.com .init(1, params()->itt_max_bin, params()->itt_max_bin / 5598981Sandreas.hansson@arm.com params()->itt_bins) 5608981Sandreas.hansson@arm.com .name(name() + ".ittReadRead") 5618981Sandreas.hansson@arm.com .desc("Read-to-read inter transaction time") 5628981Sandreas.hansson@arm.com .flags(stats.disableITTDists ? nozero : pdf); 5638981Sandreas.hansson@arm.com 5648981Sandreas.hansson@arm.com stats.ittWriteWrite 5658981Sandreas.hansson@arm.com .init(1, params()->itt_max_bin, params()->itt_max_bin / 5668981Sandreas.hansson@arm.com params()->itt_bins) 5678981Sandreas.hansson@arm.com .name(name() + ".ittWriteWrite") 5688981Sandreas.hansson@arm.com .desc("Write-to-write inter transaction time") 5698981Sandreas.hansson@arm.com .flags(stats.disableITTDists ? nozero : pdf); 5708981Sandreas.hansson@arm.com 5718981Sandreas.hansson@arm.com stats.ittReqReq 5728981Sandreas.hansson@arm.com .init(1, params()->itt_max_bin, params()->itt_max_bin / 5738981Sandreas.hansson@arm.com params()->itt_bins) 5748981Sandreas.hansson@arm.com .name(name() + ".ittReqReq") 5758981Sandreas.hansson@arm.com .desc("Request-to-request inter transaction time") 5768981Sandreas.hansson@arm.com .flags(stats.disableITTDists ? nozero : pdf); 5778981Sandreas.hansson@arm.com 5788981Sandreas.hansson@arm.com stats.outstandingReadsHist 5798981Sandreas.hansson@arm.com .init(params()->outstanding_bins) 5808981Sandreas.hansson@arm.com .name(name() + ".outstandingReadsHist") 5818981Sandreas.hansson@arm.com .desc("Outstanding read transactions") 5828981Sandreas.hansson@arm.com .flags(stats.disableOutstandingHists ? nozero : pdf); 5838981Sandreas.hansson@arm.com 5848981Sandreas.hansson@arm.com stats.outstandingWritesHist 5858981Sandreas.hansson@arm.com .init(params()->outstanding_bins) 5868981Sandreas.hansson@arm.com .name(name() + ".outstandingWritesHist") 5878981Sandreas.hansson@arm.com .desc("Outstanding write transactions") 5888981Sandreas.hansson@arm.com .flags(stats.disableOutstandingHists ? nozero : pdf); 5898981Sandreas.hansson@arm.com 5908981Sandreas.hansson@arm.com stats.readTransHist 5918981Sandreas.hansson@arm.com .init(params()->transaction_bins) 5928981Sandreas.hansson@arm.com .name(name() + ".readTransHist") 5938981Sandreas.hansson@arm.com .desc("Histogram of read transactions per sample period") 5948981Sandreas.hansson@arm.com .flags(stats.disableTransactionHists ? nozero : pdf); 5958981Sandreas.hansson@arm.com 5968981Sandreas.hansson@arm.com stats.writeTransHist 5978981Sandreas.hansson@arm.com .init(params()->transaction_bins) 5988981Sandreas.hansson@arm.com .name(name() + ".writeTransHist") 5998981Sandreas.hansson@arm.com .desc("Histogram of read transactions per sample period") 6008981Sandreas.hansson@arm.com .flags(stats.disableTransactionHists ? nozero : pdf); 6018981Sandreas.hansson@arm.com 6028981Sandreas.hansson@arm.com stats.readAddrDist 6038981Sandreas.hansson@arm.com .init(0) 6048981Sandreas.hansson@arm.com .name(name() + ".readAddrDist") 6058981Sandreas.hansson@arm.com .desc("Read address distribution") 6068981Sandreas.hansson@arm.com .flags(stats.disableAddrDists ? nozero : pdf); 6078981Sandreas.hansson@arm.com 6088981Sandreas.hansson@arm.com stats.writeAddrDist 6098981Sandreas.hansson@arm.com .init(0) 6108981Sandreas.hansson@arm.com .name(name() + ".writeAddrDist") 6118981Sandreas.hansson@arm.com .desc("Write address distribution") 6128981Sandreas.hansson@arm.com .flags(stats.disableAddrDists ? nozero : pdf); 6138981Sandreas.hansson@arm.com} 6148981Sandreas.hansson@arm.com 6158981Sandreas.hansson@arm.comvoid 6168981Sandreas.hansson@arm.comCommMonitor::samplePeriodic() 6178981Sandreas.hansson@arm.com{ 6188981Sandreas.hansson@arm.com // the periodic stats update runs on the granularity of sample 6198981Sandreas.hansson@arm.com // periods, but in combination with this there may also be a 6208981Sandreas.hansson@arm.com // external resets and dumps of the stats (through schedStatEvent) 6218981Sandreas.hansson@arm.com // causing the stats themselves to capture less than a sample 6228981Sandreas.hansson@arm.com // period 6238981Sandreas.hansson@arm.com 6248981Sandreas.hansson@arm.com // only capture if we have not reset the stats during the last 6258981Sandreas.hansson@arm.com // sample period 6268981Sandreas.hansson@arm.com if (simTicks.value() >= samplePeriodTicks) { 6278981Sandreas.hansson@arm.com if (!stats.disableTransactionHists) { 6288981Sandreas.hansson@arm.com stats.readTransHist.sample(stats.readTrans); 6298981Sandreas.hansson@arm.com stats.writeTransHist.sample(stats.writeTrans); 6308981Sandreas.hansson@arm.com } 6318981Sandreas.hansson@arm.com 6328981Sandreas.hansson@arm.com if (!stats.disableBandwidthHists) { 6338981Sandreas.hansson@arm.com stats.readBandwidthHist.sample(stats.readBytes / samplePeriod); 6348981Sandreas.hansson@arm.com stats.writeBandwidthHist.sample(stats.writtenBytes / samplePeriod); 6358981Sandreas.hansson@arm.com } 6368981Sandreas.hansson@arm.com 6378981Sandreas.hansson@arm.com if (!stats.disableOutstandingHists) { 6388981Sandreas.hansson@arm.com stats.outstandingReadsHist.sample(stats.outstandingReadReqs); 6398981Sandreas.hansson@arm.com stats.outstandingWritesHist.sample(stats.outstandingWriteReqs); 6408981Sandreas.hansson@arm.com } 6418981Sandreas.hansson@arm.com } 6428981Sandreas.hansson@arm.com 6438981Sandreas.hansson@arm.com // reset the sampled values 6448981Sandreas.hansson@arm.com stats.readTrans = 0; 6458981Sandreas.hansson@arm.com stats.writeTrans = 0; 6468981Sandreas.hansson@arm.com 6478981Sandreas.hansson@arm.com stats.readBytes = 0; 6488981Sandreas.hansson@arm.com stats.writtenBytes = 0; 6498981Sandreas.hansson@arm.com 6508981Sandreas.hansson@arm.com schedule(samplePeriodicEvent, curTick() + samplePeriodTicks); 6518981Sandreas.hansson@arm.com} 6528981Sandreas.hansson@arm.com 6538981Sandreas.hansson@arm.comvoid 6548981Sandreas.hansson@arm.comCommMonitor::startup() 6558981Sandreas.hansson@arm.com{ 6568981Sandreas.hansson@arm.com schedule(samplePeriodicEvent, curTick() + samplePeriodTicks); 6578981Sandreas.hansson@arm.com} 658