Daniel Carvalho has uploaded this change for review. ( https://gem5-review.googlesource.com/c/public/gem5/+/17995

Change subject: mem-cache: Use SatCounter for prefetchers
......................................................................

mem-cache: Use SatCounter for prefetchers

Many prefetchers re-implement saturating counters with ints. Make
them use SatCounters instead.

Added missing operators and constructors to SatCounter for that to
be possible and their respective tests.

Change-Id: I36f10c89c27c9b3d1bf461e9ea546920f6ebb888
Signed-off-by: Daniel <[email protected]>
---
M src/base/sat_counter.hh
M src/base/sat_counter.test.cc
M src/mem/cache/prefetch/Prefetcher.py
M src/mem/cache/prefetch/indirect_memory.cc
M src/mem/cache/prefetch/indirect_memory.hh
M src/mem/cache/prefetch/irregular_stream_buffer.cc
M src/mem/cache/prefetch/irregular_stream_buffer.hh
M src/mem/cache/prefetch/signature_path.cc
M src/mem/cache/prefetch/signature_path.hh
M src/mem/cache/prefetch/signature_path_v2.cc
M src/mem/cache/prefetch/spatio_temporal_memory_streaming.cc
M src/mem/cache/prefetch/spatio_temporal_memory_streaming.hh
12 files changed, 231 insertions(+), 75 deletions(-)



diff --git a/src/base/sat_counter.hh b/src/base/sat_counter.hh
index 342a338..c20e3f4 100644
--- a/src/base/sat_counter.hh
+++ b/src/base/sat_counter.hh
@@ -75,6 +75,58 @@
                  "Saturating counter's Initial value exceeds max value.");
     }

+    /** Copy constructor. */
+    SatCounter(const SatCounter& other)
+        : initialVal(other.initialVal), maxVal(other.maxVal),
+          counter(other.counter)
+    {
+    }
+
+    /** Copy assignment. */
+    SatCounter& operator=(const SatCounter& other) {
+        if (this != &other) {
+            SatCounter temp(other);
+            this->swap(temp);
+        }
+        return *this;
+    }
+
+    /** Move constructor. */
+    SatCounter(SatCounter&& other)
+    {
+        initialVal = other.initialVal;
+        maxVal = other.maxVal;
+        counter = other.counter;
+        SatCounter temp(0);
+        other.swap(temp);
+    }
+
+    /** Move assignment. */
+    SatCounter& operator=(SatCounter&& other) {
+        if (this != &other) {
+            initialVal = other.initialVal;
+            maxVal = other.maxVal;
+            counter = other.counter;
+            SatCounter temp(0);
+            other.swap(temp);
+        }
+        return *this;
+    }
+
+    /**
+     * Swap the contents of every member of the class. Used for the default
+     * copy-assignment created by the compiler.
+     *
+     * @param other The other object to swap contents with.
+     */
+    void
+    swap(SatCounter& other)
+    {
+        std::swap(initialVal, other.initialVal);
+        std::swap(maxVal, other.maxVal);
+        std::swap(counter, other.counter);
+    }
+
     /** Pre-increment operator. */
     SatCounter&
     operator++()
@@ -113,6 +165,25 @@
         return old_counter;
     }

+    /** Shift-right-assignment. */
+    SatCounter&
+    operator>>=(const int& shift)
+    {
+        this->counter >>= shift;
+        return *this;
+    }
+
+    /** Shift-left-assignment. */
+    SatCounter&
+    operator<<=(const int& shift)
+    {
+        this->counter <<= shift;
+        if (this->counter > maxVal) {
+            this->counter = maxVal;
+        }
+        return *this;
+    }
+
     /**
      * Read the counter's value.
      */
@@ -125,6 +196,12 @@
     uint8_t initialVal;
     uint8_t maxVal;
     uint8_t counter;
+
+    /** The default constructor should not be used. */
+    SatCounter()
+        : SatCounter(0)
+    {
+    }
 };

 #endif // __BASE_SAT_COUNTER_HH__
diff --git a/src/base/sat_counter.test.cc b/src/base/sat_counter.test.cc
index d2ff68c..b32572c 100644
--- a/src/base/sat_counter.test.cc
+++ b/src/base/sat_counter.test.cc
@@ -30,6 +30,8 @@

 #include <gtest/gtest.h>

+#include <utility>
+
 #include "base/sat_counter.hh"

 /**
@@ -102,6 +104,34 @@
 }

 /**
+ * Test shift operators.
+ */
+TEST(SatCounterTest, Shift)
+{
+    const unsigned bits = 3;
+    const unsigned max_value = (1 << bits) - 1;
+    const unsigned initial_value = 1;
+    SatCounter counter(bits, initial_value);
+    int value = initial_value;
+
+    // Test random shifts
+    counter <<= 2;
+    value <<= 2;
+    ASSERT_EQ(counter, value);
+    counter >>= 1;
+    value >>= 1;
+    ASSERT_EQ(counter, value);
+
+    // Test saturation
+    counter <<= bits;
+    ASSERT_EQ(counter, max_value);
+
+    // Test zeroing
+    counter >>= bits;
+    ASSERT_EQ(counter, 0);
+}
+
+/**
  * Test both pre and post operators.
  */
 TEST(SatCounterTest, PrePostOperators)
@@ -129,3 +159,58 @@
     ASSERT_EQ(counter_pre, 0);
     ASSERT_EQ(counter_post, 0);
 }
+
+/**
+ * Test copy and move for both constructor and assignment.
+ */
+TEST(SatCounterTest, CopyMove)
+{
+    const unsigned bits = 3;
+    const unsigned max_value = (1 << bits) - 1;
+    const unsigned initial_value = 1;
+    SatCounter counter(bits, initial_value);
+    SatCounter deep_copy(1);
+    SatCounter counter_copy(2);
+
+    // Increase counter value so that we can check if the inner counter is
+    // being copied
+    counter++;
+
+    // Copy counter using both the copy constructor and the copy assignment
+    SatCounter counter_copy_constructor(counter);
+    deep_copy = counter_copy = counter;
+    ASSERT_EQ(counter_copy_constructor, initial_value + 1);
+    ASSERT_EQ(counter_copy, initial_value + 1);
+    ASSERT_EQ(deep_copy, initial_value + 1);
+
+    // Make sure max value is the same for all of them, and that modifying
+    // the copies does not modify the original
+    for (int i = 0; i < 2*max_value; i++) {
+        counter_copy_constructor++;
+        counter_copy++;
+        deep_copy++;
+    }
+    ASSERT_EQ(counter, initial_value + 1);
+    ASSERT_EQ(counter_copy_constructor, max_value);
+    ASSERT_EQ(counter_copy, max_value);
+    ASSERT_EQ(deep_copy, max_value);
+
+    // Make sure initial value is the same for all of them
+    counter_copy_constructor.reset();
+    counter_copy.reset();
+    deep_copy.reset();
+    ASSERT_EQ(counter_copy_constructor, initial_value);
+    ASSERT_EQ(counter_copy, initial_value);
+    ASSERT_EQ(deep_copy, initial_value);
+
+    // Now check move
+    SatCounter counter_move_constructor(std::move(counter));
+    ASSERT_EQ(counter, 0);
+    ASSERT_EQ(counter_move_constructor, initial_value + 1);
+
+    SatCounter counter_move(bits);
+    counter_move = std::move(counter_move_constructor);
+    ASSERT_EQ(counter_move_constructor, 0);
+    ASSERT_EQ(counter_move, initial_value + 1);
+}
+
diff --git a/src/mem/cache/prefetch/Prefetcher.py b/src/mem/cache/prefetch/Prefetcher.py
index aaa1408..b933b49 100644
--- a/src/mem/cache/prefetch/Prefetcher.py
+++ b/src/mem/cache/prefetch/Prefetcher.py
@@ -156,8 +156,8 @@
     pt_table_replacement_policy = Param.BaseReplacementPolicy(LRURP(),
         "Replacement policy of the pattern table")
     max_prefetch_distance = Param.Unsigned(16, "Maximum prefetch distance")
-    max_indirect_counter_value = Param.Unsigned(8,
-        "Maximum value of the indirect counter")
+    num_indirect_counter_bits = Param.Unsigned(3,
+        "Number of bits of the indirect counter")
     ipd_table_entries = Param.MemorySize("4",
         "Number of entries of the Indirect Pattern Detector")
     ipd_table_assoc = Param.Unsigned(4,
@@ -197,7 +197,8 @@
signature_table_replacement_policy = Param.BaseReplacementPolicy(LRURP(),
         "Replacement policy of the signature table")

-    max_counter_value = Param.UInt8(7, "Maximum pattern counter value")
+    num_counter_bits = Param.UInt8(3,
+        "Number of bits of the saturating counters")
     pattern_table_entries = Param.MemorySize("4096",
         "Number of entries of the pattern table")
     pattern_table_assoc = Param.Unsigned(1,
@@ -225,7 +226,7 @@
     signature_table_assoc = 1
     pattern_table_entries = "512"
     pattern_table_assoc = 1
-    max_counter_value = 15
+    num_counter_bits = 4
     prefetch_confidence_threshold = 0.25
     lookahead_confidence_threshold = 0.25

@@ -318,8 +319,8 @@
     cxx_class = "IrregularStreamBufferPrefetcher"
     cxx_header = "mem/cache/prefetch/irregular_stream_buffer.hh"

-    max_counter_value = Param.Unsigned(3,
-        "Maximum value of the confidence counter")
+    num_counter_bits = Param.Unsigned(2,
+        "Number of bits of the confidence counter")
     chunk_size = Param.Unsigned(256,
         "Maximum number of addresses in a temporal stream")
     degree = Param.Unsigned(4, "Number of prefetches to generate")
diff --git a/src/mem/cache/prefetch/indirect_memory.cc b/src/mem/cache/prefetch/indirect_memory.cc
index d49652f..bf90ce9 100644
--- a/src/mem/cache/prefetch/indirect_memory.cc
+++ b/src/mem/cache/prefetch/indirect_memory.cc
@@ -38,11 +38,12 @@
     const IndirectMemoryPrefetcherParams *p) : QueuedPrefetcher(p),
     maxPrefetchDistance(p->max_prefetch_distance),
     shiftValues(p->shift_values), prefetchThreshold(p->prefetch_threshold),
-    maxIndirectCounterValue(p->max_indirect_counter_value),
+    maxIndirectCounterValue((1 << p->num_indirect_counter_bits) - 1),
     streamCounterThreshold(p->stream_counter_threshold),
     streamingDistance(p->streaming_distance),
     prefetchTable(p->pt_table_assoc, p->pt_table_entries,
- p->pt_table_indexing_policy, p->pt_table_replacement_policy), + p->pt_table_indexing_policy, p->pt_table_replacement_policy,
+                  PrefetchTableEntry(p->num_indirect_counter_bits)),
ipd(p->ipd_table_assoc, p->ipd_table_entries, p->ipd_table_indexing_policy,
         p->ipd_table_replacement_policy,
IndirectPatternDetectorEntry(p->addr_array_len, shiftValues.size())),
@@ -135,9 +136,7 @@
                         // Enabled entry, update the index
                         pt_entry->index = index;
                         if (!pt_entry->increasedIndirectCounter) {
-                            if (pt_entry->indirectCounter > 0) {
-                                pt_entry->indirectCounter -= 1;
-                            }
+                            pt_entry->indirectCounter--;
                         } else {
                             // Set this to false, to see if the new index
                             // has any match
@@ -147,7 +146,8 @@
                         // If the counter is high enough, start prefetching
if (pt_entry->indirectCounter > prefetchThreshold) {
                             unsigned distance = pt_entry->indirectCounter *
- maxPrefetchDistance / maxIndirectCounterValue;
+                                maxPrefetchDistance /
+                                (maxIndirectCounterValue + 1);
for (int delta = 1; delta < distance; delta += 1) {
                                 Addr pf_addr = pt_entry->baseAddr +
                                     (pt_entry->index << pt_entry->shift);
@@ -237,7 +237,7 @@
                 pt_entry->baseAddr = ba_array[idx];
                 pt_entry->shift = shift;
                 pt_entry->enabled = true;
-                pt_entry->indirectCounter = 0;
+                pt_entry->indirectCounter.reset();
                 // Release the current IPD Entry
                 entry->reset();
                 // Do not track more misses
@@ -256,10 +256,8 @@
         if (pt_entry.enabled) {
             if (addr == pt_entry.baseAddr +
                        (pt_entry.index << pt_entry.shift)) {
-                if (pt_entry.indirectCounter < maxIndirectCounterValue) {
-                    pt_entry.indirectCounter += 1;
-                    pt_entry.increasedIndirectCounter = true;
-                }
+                pt_entry.indirectCounter++;
+                pt_entry.increasedIndirectCounter = true;
             }
         }
     }
diff --git a/src/mem/cache/prefetch/indirect_memory.hh b/src/mem/cache/prefetch/indirect_memory.hh
index b67cdfb..d878437 100644
--- a/src/mem/cache/prefetch/indirect_memory.hh
+++ b/src/mem/cache/prefetch/indirect_memory.hh
@@ -43,6 +43,7 @@

 #include <vector>

+#include "base/sat_counter.hh"
 #include "mem/cache/prefetch/associative_set.hh"
 #include "mem/cache/prefetch/queued.hh"

@@ -86,7 +87,7 @@
         /** Shift detected */
         int shift;
         /** Confidence counter of the indirect fields */
-        int indirectCounter;
+        SatCounter indirectCounter;
         /**
* This variable is set to indicate that there has been at least one * match with the current index value. This information is later used
@@ -95,9 +96,11 @@
          */
         bool increasedIndirectCounter;

-        PrefetchTableEntry() : TaggedEntry(), address(0), secure(false),
- streamCounter(0), enabled(false), index(0), baseAddr(0), shift(0),
-            indirectCounter(0), increasedIndirectCounter(false)
+        PrefetchTableEntry(unsigned indirect_counter_bits)
+            : TaggedEntry(), address(0), secure(false), streamCounter(0),
+              enabled(false), index(0), baseAddr(0), shift(0),
+              indirectCounter(indirect_counter_bits),
+              increasedIndirectCounter(false)
         {}

         void reset() override {
@@ -108,7 +111,7 @@
             index = 0;
             baseAddr = 0;
             shift = 0;
-            indirectCounter = 0;
+            indirectCounter.reset();
             increasedIndirectCounter = false;
         }
     };
diff --git a/src/mem/cache/prefetch/irregular_stream_buffer.cc b/src/mem/cache/prefetch/irregular_stream_buffer.cc
index 345fe70..73fa9eb 100644
--- a/src/mem/cache/prefetch/irregular_stream_buffer.cc
+++ b/src/mem/cache/prefetch/irregular_stream_buffer.cc
@@ -36,7 +36,7 @@

 IrregularStreamBufferPrefetcher::IrregularStreamBufferPrefetcher(
     const IrregularStreamBufferPrefetcherParams *p)
-    : QueuedPrefetcher(p), maxCounterValue(p->max_counter_value),
+    : QueuedPrefetcher(p),
         chunkSize(p->chunk_size),
         prefetchCandidatesPerEntry(p->prefetch_candidates_per_entry),
         degree(p->degree),
@@ -47,12 +47,14 @@
                               p->address_map_cache_entries,
                               p->ps_address_map_cache_indexing_policy,
                               p->ps_address_map_cache_replacement_policy,
- AddressMappingEntry(prefetchCandidatesPerEntry)), + AddressMappingEntry(prefetchCandidatesPerEntry,
+                                                  p->num_counter_bits)),
         spAddressMappingCache(p->address_map_cache_assoc,
                               p->address_map_cache_entries,
                               p->sp_address_map_cache_indexing_policy,
                               p->sp_address_map_cache_replacement_policy,
- AddressMappingEntry(prefetchCandidatesPerEntry)), + AddressMappingEntry(prefetchCandidatesPerEntry,
+                                                  p->num_counter_bits)),
         structuralAddressCounter(0)
 {
     assert(isPowerOf2(prefetchCandidatesPerEntry));
@@ -100,30 +102,29 @@
         if (mapping_A.counter > 0 && mapping_B.counter > 0) {
             // Entry for A and B
             if (mapping_B.address == (mapping_A.address + 1)) {
-                if (mapping_B.counter < maxCounterValue) {
-                    mapping_B.counter += 1;
-                }
+                mapping_B.counter++;
             } else {
                 if (mapping_B.counter == 1) {
-                    // counter would hit 0, reassign address
-                    mapping_B.counter = 1;
+                    // Counter would hit 0, reassign address while keeping
+                    // counter at 1
                     mapping_B.address = mapping_A.address + 1;
addStructuralToPhysicalEntry(mapping_B.address, is_secure,
                             correlated_addr_B);
                 } else {
-                    mapping_B.counter -= 1;
+                    mapping_B.counter--;
                 }
             }
         } else {
             if (mapping_A.counter == 0) {
                 // if A is not valid, generate a new structural address
-                mapping_A.counter = 1;
+                mapping_A.counter++;
                 mapping_A.address = structuralAddressCounter;
                 structuralAddressCounter += chunkSize;
                 addStructuralToPhysicalEntry(mapping_A.address,
                         is_secure, correlated_addr_A);
             }
-            mapping_B.counter = 1;
+            mapping_B.counter.reset();
+            mapping_B.counter++;
             mapping_B.address = mapping_A.address + 1;
             // update SP-AMC
             addStructuralToPhysicalEntry(mapping_B.address, is_secure,
@@ -203,7 +204,8 @@
     }
     AddressMapping &mapping = sp_entry->mappings[map_index];
     mapping.address = physical_address;
-    mapping.counter = 1;
+    mapping.counter.reset();
+    mapping.counter++;
 }

 IrregularStreamBufferPrefetcher*
diff --git a/src/mem/cache/prefetch/irregular_stream_buffer.hh b/src/mem/cache/prefetch/irregular_stream_buffer.hh
index 47038cb..c97fde8 100644
--- a/src/mem/cache/prefetch/irregular_stream_buffer.hh
+++ b/src/mem/cache/prefetch/irregular_stream_buffer.hh
@@ -41,6 +41,7 @@
 #define __MEM_CACHE_PREFETCH_IRREGULAR_STREAM_BUFFER_HH__

 #include "base/callback.hh"
+#include "base/sat_counter.hh"
 #include "mem/cache/prefetch/associative_set.hh"
 #include "mem/cache/prefetch/queued.hh"

@@ -48,8 +49,6 @@

 class IrregularStreamBufferPrefetcher : public QueuedPrefetcher
 {
-    /** Maximum value of the confidence counters */
-    const unsigned maxCounterValue;
     /** Size in bytes of a temporal stream */
     const size_t chunkSize;
     /** Number of prefetch candidates per Physical-to-Structural entry */
@@ -71,8 +70,8 @@
     /** Address Mapping entry, holds an address and a confidence counter */
     struct AddressMapping {
         Addr address;
-        unsigned counter;
-        AddressMapping() : address(0), counter(0)
+        SatCounter counter;
+        AddressMapping(unsigned bits) : address(0), counter(bits)
         {}
     };

@@ -82,13 +81,14 @@
      */
     struct AddressMappingEntry : public TaggedEntry {
         std::vector<AddressMapping> mappings;
-        AddressMappingEntry(size_t num_mappings) : mappings(num_mappings)
+        AddressMappingEntry(size_t num_mappings, unsigned counter_bits)
+            : mappings(num_mappings, counter_bits)
         {}
         void reset() override
         {
             for (auto &entry : mappings) {
                 entry.address = 0;
-                entry.counter = 0;
+                entry.counter.reset();
             }
         }
     };
diff --git a/src/mem/cache/prefetch/signature_path.cc b/src/mem/cache/prefetch/signature_path.cc
index 857354e..07494fa 100644
--- a/src/mem/cache/prefetch/signature_path.cc
+++ b/src/mem/cache/prefetch/signature_path.cc
@@ -31,6 +31,7 @@
 #include "mem/cache/prefetch/signature_path.hh"

 #include <cassert>
+#include <climits>

 #include "debug/HWPrefetch.hh"
 #include "mem/cache/prefetch/associative_set_impl.hh"
@@ -42,7 +43,7 @@
       stridesPerPatternEntry(p->strides_per_pattern_entry),
       signatureShift(p->signature_shift),
       signatureBits(p->signature_bits),
-      maxCounterValue(p->max_counter_value),
+      maxCounterValue((1 << p->num_counter_bits) - 1),
       prefetchConfidenceThreshold(p->prefetch_confidence_threshold),
       lookaheadConfidenceThreshold(p->lookahead_confidence_threshold),
       signatureTable(p->signature_table_assoc, p->signature_table_entries,
@@ -51,7 +52,7 @@
       patternTable(p->pattern_table_assoc, p->pattern_table_entries,
                    p->pattern_table_indexing_policy,
                    p->pattern_table_replacement_policy,
-                   PatternEntry(stridesPerPatternEntry))
+ PatternEntry(stridesPerPatternEntry, p->num_counter_bits))
 {
     fatal_if(prefetchConfidenceThreshold < 0,
         "The prefetch confidence threshold must be greater than 0\n");
@@ -64,8 +65,7 @@
 }

 SignaturePathPrefetcher::PatternStrideEntry &
-SignaturePathPrefetcher::PatternEntry::getStrideEntry(stride_t stride,
- uint8_t max_counter_value)
+SignaturePathPrefetcher::PatternEntry::getStrideEntry(stride_t stride)
 {
     PatternStrideEntry *pstride_entry = findStride(stride);
     if (pstride_entry == nullptr) {
@@ -76,18 +76,16 @@
         // If all counters have the max value, this will be the pick
         PatternStrideEntry *victim_pstride_entry = &(strideEntries[0]);

-        uint8_t current_counter = max_counter_value;
+        uint8_t current_counter = UCHAR_MAX;
         for (auto &entry : strideEntries) {
             if (entry.counter < current_counter) {
                 victim_pstride_entry = &entry;
                 current_counter = entry.counter;
             }
-            if (entry.counter > 0) {
-                entry.counter -= 1;
-            }
+            entry.counter--;
         }
         pstride_entry = victim_pstride_entry;
-        pstride_entry->counter = 0;
+        pstride_entry->counter.reset();
         pstride_entry->stride = stride;
     }
     return *pstride_entry;
@@ -147,9 +145,7 @@
 SignaturePathPrefetcher::increasePatternEntryCounter(
         PatternEntry &pattern_entry, PatternStrideEntry &pstride_entry)
 {
-    if (pstride_entry.counter < maxCounterValue) {
-        pstride_entry.counter += 1;
-    }
+    pstride_entry.counter++;
 }

 void
@@ -158,8 +154,7 @@
     assert(stride != 0);
     // The pattern table is indexed by signatures
     PatternEntry &p_entry = getPatternEntry(signature);
-    PatternStrideEntry &ps_entry = p_entry.getStrideEntry(stride,
-                                                          maxCounterValue);
+    PatternStrideEntry &ps_entry = p_entry.getStrideEntry(stride);
     increasePatternEntryCounter(p_entry, ps_entry);
 }

diff --git a/src/mem/cache/prefetch/signature_path.hh b/src/mem/cache/prefetch/signature_path.hh
index 974c027..e135043 100644
--- a/src/mem/cache/prefetch/signature_path.hh
+++ b/src/mem/cache/prefetch/signature_path.hh
@@ -42,6 +42,7 @@
 #ifndef __MEM_CACHE_PREFETCH_SIGNATURE_PATH_HH__
 #define __MEM_CACHE_PREFETCH_SIGNATURE_PATH_HH__

+#include "base/sat_counter.hh"
 #include "mem/cache/prefetch/associative_set.hh"
 #include "mem/cache/prefetch/queued.hh"
 #include "mem/packet.hh"
@@ -88,8 +89,8 @@
         /** stride in a page in blkSize increments */
         stride_t stride;
         /** counter value (max value defined by maxCounterValue) */
-        uint8_t counter;
-        PatternStrideEntry() : stride(0), counter(0)
+        SatCounter counter;
+        PatternStrideEntry(unsigned bits) : stride(0), counter(bits)
         {}
     };
     /** Pattern entry data type, a set of stride and counter entries */
@@ -99,15 +100,15 @@
         std::vector<PatternStrideEntry> strideEntries;
         /** use counter, used by SPPv2 */
         uint8_t counter;
-        PatternEntry(size_t num_strides) : strideEntries(num_strides),
-                                           counter(0)
+        PatternEntry(size_t num_strides, unsigned ps_counter_bits)
+            : strideEntries(num_strides, ps_counter_bits), counter(0)
         {}

         /** Reset the entries to their initial values */
         void reset() override
         {
             for (auto &entry : strideEntries) {
-                entry.counter = 0;
+                entry.counter.reset();
                 entry.stride = 0;
             }
             counter = 0;
@@ -135,13 +136,9 @@
* Gets the entry with the provided stride, if there is no entry with
          * the associated stride, it replaces one of them.
          * @param stride the stride to find
- * @param max_counter_value maximum value of the confidence counters, - * it is used when no strides are found and an entry needs to be
-         *        replaced
          * @result reference to the selected entry
          */
-        PatternStrideEntry &getStrideEntry(stride_t stride,
-                                           uint8_t max_counter_value);
+        PatternStrideEntry &getStrideEntry(stride_t stride);
     };
     /** Pattern table */
     AssociativeSet<PatternEntry> patternTable;
diff --git a/src/mem/cache/prefetch/signature_path_v2.cc b/src/mem/cache/prefetch/signature_path_v2.cc
index 571c3d1..04a8cdb 100644
--- a/src/mem/cache/prefetch/signature_path_v2.cc
+++ b/src/mem/cache/prefetch/signature_path_v2.cc
@@ -108,8 +108,8 @@
             entry.counter >>= 1;
         }
     }
-    pattern_entry.counter += 1;
-    pstride_entry.counter += 1;
+    pattern_entry.counter++;
+    pstride_entry.counter++;
 }

 void
diff --git a/src/mem/cache/prefetch/spatio_temporal_memory_streaming.cc b/src/mem/cache/prefetch/spatio_temporal_memory_streaming.cc
index df5190a..cf6144a 100644
--- a/src/mem/cache/prefetch/spatio_temporal_memory_streaming.cc
+++ b/src/mem/cache/prefetch/spatio_temporal_memory_streaming.cc
@@ -212,7 +212,7 @@
             patternSequenceTable.accessEntry(pst_entry);
             for (auto &seq_entry : pst_entry->sequence) {
                 if (seq_entry.counter > 1) {
-                    // 3-bit counter: high enough confidence with a
+                    // 2-bit counter: high enough confidence with a
                     // value greater than 1
                     Addr rec_addr = rmob[i].srAddress * spatialRegionSize +
                         seq_entry.offset;
diff --git a/src/mem/cache/prefetch/spatio_temporal_memory_streaming.hh b/src/mem/cache/prefetch/spatio_temporal_memory_streaming.hh
index a7e25fe..34cf5d1 100644
--- a/src/mem/cache/prefetch/spatio_temporal_memory_streaming.hh
+++ b/src/mem/cache/prefetch/spatio_temporal_memory_streaming.hh
@@ -45,6 +45,7 @@

 #include <vector>

+#include "base/sat_counter.hh"
 #include "mem/cache/prefetch/associative_set.hh"
 #include "mem/cache/prefetch/queued.hh"

@@ -74,12 +75,12 @@
         /** Sequence entry data type */
         struct SequenceEntry {
             /** 2-bit confidence counter */
-            unsigned int counter;
+            SatCounter counter;
             /** Offset, in cache lines, within the spatial region */
             unsigned int offset;
             /** Intearleaving position on the global access sequence */
             unsigned int delta;
-            SequenceEntry() : counter(0), offset(0), delta(0)
+            SequenceEntry() : counter(2), offset(0), delta(0)
             {}
         };
         /** Sequence of accesses */
@@ -95,7 +96,7 @@
             pc = 0;
             seqCounter = 0;
             for (auto &seq_entry : sequence) {
-                seq_entry.counter = 0;
+                seq_entry.counter.reset();
                 seq_entry.offset = 0;
                 seq_entry.delta = 0;
             }
@@ -125,15 +126,12 @@
             for (auto &seq_entry : sequence) {
                 if (seq_entry.counter > 0) {
                     if (seq_entry.offset == offset) {
-                        //2 bit counter, saturates at 3
-                        if (seq_entry.counter < 3) {
-                            seq_entry.counter += 1;
-                        }
+                        seq_entry.counter++;
                     }
                 } else {
// If the counter is 0 it means that this position is not
                     // being used, and we can allocate the new offset here
-                    seq_entry.counter = 1;
+                    seq_entry.counter++;
                     seq_entry.offset = offset;
                     seq_entry.delta = seqCounter;
                     break;

--
To view, visit https://gem5-review.googlesource.com/c/public/gem5/+/17995
To unsubscribe, or for help writing mail filters, visit https://gem5-review.googlesource.com/settings

Gerrit-Project: public/gem5
Gerrit-Branch: master
Gerrit-Change-Id: I36f10c89c27c9b3d1bf461e9ea546920f6ebb888
Gerrit-Change-Number: 17995
Gerrit-PatchSet: 1
Gerrit-Owner: Daniel Carvalho <[email protected]>
Gerrit-MessageType: newchange
_______________________________________________
gem5-dev mailing list
[email protected]
http://m5sim.org/mailman/listinfo/gem5-dev

Reply via email to