This is an automated email from the ASF dual-hosted git repository.

jvanderzee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/trafficserver.git


The following commit(s) were added to refs/heads/master by this push:
     new dd8fe7d778 Fix incorrect metric for agg_copy bytes written (#11508)
dd8fe7d778 is described below

commit dd8fe7d7780575e42310e97f28a87b04523e45e0
Author: JosiahWI <[email protected]>
AuthorDate: Wed Jul 3 11:44:21 2024 -0500

    Fix incorrect metric for agg_copy bytes written (#11508)
    
    We introduced an issue in f23826d where we count backlog failures when
    copying bytes to the aggregation buffer. The original, intended behavior,
    was to count the number of bytes copied. This restores the original 
behavior.
    
    Fixes #11457.
---
 src/iocore/cache/CacheWrite.cc             |  5 ++---
 src/iocore/cache/unit_tests/test_Stripe.cc | 10 +++++-----
 2 files changed, 7 insertions(+), 8 deletions(-)

diff --git a/src/iocore/cache/CacheWrite.cc b/src/iocore/cache/CacheWrite.cc
index dec0da4687..651029f7a6 100644
--- a/src/iocore/cache/CacheWrite.cc
+++ b/src/iocore/cache/CacheWrite.cc
@@ -734,10 +734,9 @@ Stripe::_agg_copy(CacheVC *vc)
         ProxyMutex *mutex ATS_UNUSED = this->mutex.get();
         ink_assert(mutex->thread_holding == this_ethread());
 
-// ToDo: Why are these for debug only ?
 #ifdef DEBUG
-        Metrics::Counter::increment(cache_rsb.write_backlog_failure);
-        
Metrics::Counter::increment(this->cache_vol->vol_rsb.write_backlog_failure);
+        Metrics::Counter::increment(cache_rsb.write_bytes, vc->write_len);
+        Metrics::Counter::increment(this->cache_vol->vol_rsb.write_bytes, 
vc->write_len);
 #endif
       }
       if (vc->f.rewrite_resident_alt) {
diff --git a/src/iocore/cache/unit_tests/test_Stripe.cc 
b/src/iocore/cache/unit_tests/test_Stripe.cc
index ae2043a055..fb07824d36 100644
--- a/src/iocore/cache/unit_tests/test_Stripe.cc
+++ b/src/iocore/cache/unit_tests/test_Stripe.cc
@@ -107,11 +107,11 @@ attach_tmpfile_to_stripe(Stripe &stripe)
 static std::FILE *
 init_stripe_for_writing(Stripe &stripe, StripteHeaderFooter &header, CacheVol 
&cache_vol)
 {
-  stripe.cache_vol                                = &cache_vol;
-  cache_rsb.write_backlog_failure                 = 
Metrics::Counter::createPtr("unit_test.write.backlog.failure");
-  stripe.cache_vol->vol_rsb.write_backlog_failure = 
Metrics::Counter::createPtr("unit_test.write.backlog.failure");
-  cache_rsb.gc_frags_evacuated                    = 
Metrics::Counter::createPtr("unit_test.gc.frags.evacuated");
-  stripe.cache_vol->vol_rsb.gc_frags_evacuated    = 
Metrics::Counter::createPtr("unit_test.gc.frags.evacuated");
+  stripe.cache_vol                             = &cache_vol;
+  cache_rsb.write_bytes                        = 
Metrics::Counter::createPtr("unit_test.write.bytes");
+  stripe.cache_vol->vol_rsb.write_bytes        = 
Metrics::Counter::createPtr("unit_test.write.bytes");
+  cache_rsb.gc_frags_evacuated                 = 
Metrics::Counter::createPtr("unit_test.gc.frags.evacuated");
+  stripe.cache_vol->vol_rsb.gc_frags_evacuated = 
Metrics::Counter::createPtr("unit_test.gc.frags.evacuated");
 
   // A number of things must be initialized in a certain way for Stripe
   // not to segfault, hit an assertion, or exhibit zero-division.

Reply via email to