cache-coherence-simulator/bus_impl.hpp at master · adamozh/cache-coherence-simulator · 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
#pragma once

#include "bus.hpp"
#include "processor.hpp"
#include "request.hpp"
#include <memory>
#include <queue>
#include <unordered_map>

using namespace std;

class BusImpl : public Bus {
  protected:
    virtual void processBusRd(shared_ptr<Request> request);
    virtual void processBusRdX(shared_ptr<Request> request);

  public:
    int wordsPerBlock;
    vector<shared_ptr<Processor>> processors;
    vector<shared_ptr<Request>> currentRequests;
    shared_ptr<Request> currReq = nullptr;
    vector<shared_ptr<Request>> memRequests;
    queue<shared_ptr<Request>> busQueue;
    void processRequest(shared_ptr<Request> request);

    unsigned int trafficInBytes = 0;
    unsigned int numInvalidationsOrUpdates = 0;
    unsigned int numShared = 0;
    unsigned int numPrivate = 0;

  public:
    BusImpl(int wordsPerBlock) : wordsPerBlock(wordsPerBlock){};
    void attachProcessor(shared_ptr<Processor> proc) override;
    void issueInvalidation(unsigned int pid, unsigned int address) override;
    void pushRequestToBus(shared_ptr<Request> request) override;
    bool isCurrentRequestDone(int pid) override;
    void executeCycle() override;
    virtual shared_ptr<Processor> getProcessor(int pid);
    bool checkCacheBlocked(unsigned int indexWithTag, int pid) override { return true; };
    void addCacheBlocked(unsigned int indexWithTag, int pid) override{};
    void removeCacheBlocked(unsigned int indexWithTag, int pid) override{};
    void updateOtherCachesToSc(unsigned int indexWithTag, int pid) override{};

    void printProgress() override;
    void printStatistics() override;
    unsigned int getNumShared() override;
    unsigned int getNumPrivate() override;
};