fix ip header checksum wrong after modify DSCP value for a packet

fix table_info.json shaping profile table valid column
add some debug info

3 files changed, 25 insertions, 16 deletions

diff --git a/shaping/include/shaper_aqm.h b/shaping/include/shaper_aqm.h
index 2955c3a..8575076 100644
--- a/shaping/include/shaper_aqm.h
+++ b/shaping/include/shaper_aqm.h
@@ -35,5 +35,5 @@ struct shaper_aqm_codel_para {
 };
 
 int shaper_aqm_need_drop(struct shaping_profile_info *profile, struct shaping_packet_wrapper *pkt_wrapper, struct timespec *curr_time, unsigned long long latency_us);
-int shaper_aqm_blue_need_drop(struct shaper_aqm_blue_para *para, int curr_queue_len);
-int shaper_aqm_codel_need_drop(struct shaper_aqm_codel_para *para, unsigned long long curr_time_ms, unsigned long long latency_ms);
\ No newline at end of file
+int shaper_aqm_blue_need_drop(int profile_id, struct shaper_aqm_blue_para *para, int curr_queue_len);
+int shaper_aqm_codel_need_drop(int profile_id, struct shaper_aqm_codel_para *para, unsigned long long curr_time_ms, unsigned long long latency_ms);
\ No newline at end of file
diff --git a/shaping/src/shaper_aqm.cpp b/shaping/src/shaper_aqm.cpp
index e06bf7e..96d3e8b 100644
--- a/shaping/src/shaper_aqm.cpp
+++ b/shaping/src/shaper_aqm.cpp
@@ -1,10 +1,11 @@
 #include <math.h>
 #include <time.h>
+#include "log.h"
 #include "shaper.h"
 #include "shaper_aqm.h"
 
 thread_local unsigned int seed = 0;
-int shaper_aqm_blue_need_drop(struct shaper_aqm_blue_para *para, int curr_queue_len)
+int shaper_aqm_blue_need_drop(int profile_id, struct shaper_aqm_blue_para *para, int curr_queue_len)
 {
     time_t curr_time;
 
@@ -15,6 +16,8 @@ int shaper_aqm_blue_need_drop(struct shaper_aqm_blue_para *para, int curr_queue_
         } else if (curr_queue_len == 0) {
             para->probability = (para->probability - BLUE_DECREMENT) >= 0 ? (para->probability - BLUE_DECREMENT) : 0;
         }
+
+        LOG_INFO("%s: profile id: %d blue probability update to %d", LOG_TAG_SHAPING, profile_id, para->probability);
     }
 
     if (rand_r(&seed) % BLUE_PROBABILITY_MAX < para->probability) {
@@ -24,10 +27,14 @@ int shaper_aqm_blue_need_drop(struct shaper_aqm_blue_para *para, int curr_queue_
     return 0;
 }
 
-int shaper_aqm_codel_need_drop(struct shaper_aqm_codel_para *para, unsigned long long curr_time_ms, unsigned long long latency_ms)
+int shaper_aqm_codel_need_drop(int profile_id, struct shaper_aqm_codel_para *para, unsigned long long curr_time_ms, unsigned long long latency_ms)
 {
     if (latency_ms < CODEL_MAX_LATENCY) {
-        para->state = CODEL_STATE_NORMAL;
+        if (para->state != CODEL_STATE_NORMAL) {
+            para->state = CODEL_STATE_NORMAL;
+            LOG_INFO("%s: profile id: %d codel enter state CODEL_STATE_NORMAL", LOG_TAG_SHAPING, profile_id);
+        }
+        
         return 0;
     } 
 
@@ -36,6 +43,7 @@ int shaper_aqm_codel_need_drop(struct shaper_aqm_codel_para *para, unsigned long
         case CODEL_STATE_NORMAL:
             para->start_drop_time_ms = curr_time_ms + CODEL_DROP_INTERVAL;
             para->state = CODEL_STATE_DROPPING_TIMER;
+            LOG_INFO("%s: profile id: %d codel enter state CODEL_STATE_DROPPING_TIMER", LOG_TAG_SHAPING, profile_id);
             break;
         case CODEL_STATE_DROPPING_TIMER:
             if (curr_time_ms >= para->start_drop_time_ms) {
@@ -43,6 +51,7 @@ int shaper_aqm_codel_need_drop(struct shaper_aqm_codel_para *para, unsigned long
                 para->drop_count = 1;
                 para->next_drop_time_ms = curr_time_ms + CODEL_DROP_INTERVAL / sqrt(para->drop_count);
                 ret = 1;
+                LOG_INFO("%s: profile id: %d codel enter state CODEL_STATE_DROPPING_PHASE", LOG_TAG_SHAPING, profile_id);
             }
             break;
         case CODEL_STATE_DROPPING_PHASE:
@@ -102,11 +111,11 @@ int shaper_aqm_need_drop(struct shaping_profile_info *profile, struct shaping_pa
     
     switch (profile->hash_node->aqm_type) {
         case AQM_TYPE_BLUE:
-            ret = shaper_aqm_blue_need_drop(&profile->hash_node->aqm_blue_para, profile->hash_node->queue_len[profile->priority]);
+            ret = shaper_aqm_blue_need_drop(profile->id, &profile->hash_node->aqm_blue_para, profile->hash_node->queue_len[profile->priority]);
             break;
         case AQM_TYPE_CODEL:
             curr_time_ms = curr_time->tv_sec * MILLI_SECONDS_PER_SEC + curr_time->tv_nsec / NANO_SECONDS_PER_MILLI_SEC;
-            ret = shaper_aqm_codel_need_drop(&profile->hash_node->aqm_codel_para, curr_time_ms, latency_us / 1000);
+            ret = shaper_aqm_codel_need_drop(profile->id, &profile->hash_node->aqm_codel_para, curr_time_ms, latency_us / 1000);
             break;
         default:
             break;
diff --git a/shaping/test/gtest_shaper_aqm.cpp b/shaping/test/gtest_shaper_aqm.cpp
index 92bab10..6acb1f3 100644
--- a/shaping/test/gtest_shaper_aqm.cpp
+++ b/shaping/test/gtest_shaper_aqm.cpp
@@ -13,7 +13,7 @@ TEST(aqm_bule, need_drop)
     para.probability = 0;
 
     for (int i = 0; i < 10000; i++) {
-        if (shaper_aqm_blue_need_drop(&para, BLUE_QUEUE_LEN_MAX + 1)) {
+        if (shaper_aqm_blue_need_drop(0, &para, BLUE_QUEUE_LEN_MAX + 1)) {
             drop_cnt++;
         }
     }
@@ -24,7 +24,7 @@ TEST(aqm_bule, need_drop)
     EXPECT_LT(drop_cnt, 1100);
 
     sleep(3);
-    shaper_aqm_blue_need_drop(&para, 0);
+    shaper_aqm_blue_need_drop(0, &para, 0);
     EXPECT_EQ(para.probability, BLUE_INCREMENT - BLUE_DECREMENT);
 }
 
@@ -37,7 +37,7 @@ TEST(aqm_blue, no_drop)
     para.probability = 0;
 
     for (int i = 0; i < 10000; i++) {
-        if (shaper_aqm_blue_need_drop(&para, BLUE_QUEUE_LEN_MAX - 1)) {
+        if (shaper_aqm_blue_need_drop(0, &para, BLUE_QUEUE_LEN_MAX - 1)) {
             drop_cnt++;
         }
     }
@@ -46,7 +46,7 @@ TEST(aqm_blue, no_drop)
     EXPECT_EQ(drop_cnt, 0);
 
     sleep(3);
-    shaper_aqm_blue_need_drop(&para, BLUE_QUEUE_LEN_MAX - 1);
+    shaper_aqm_blue_need_drop(0, &para, BLUE_QUEUE_LEN_MAX - 1);
     EXPECT_EQ(para.probability, 0);
 }
 
@@ -57,23 +57,23 @@ TEST(aqm_codel, need_drop)
 
     memset(&para, 0, sizeof(para));
 
-    shaper_aqm_codel_need_drop(&para, curr_time_ms, CODEL_MAX_LATENCY + 1);
+    shaper_aqm_codel_need_drop(0, &para, curr_time_ms, CODEL_MAX_LATENCY + 1);
     EXPECT_EQ(para.state, CODEL_STATE_DROPPING_TIMER);
     EXPECT_EQ(para.start_drop_time_ms, curr_time_ms + CODEL_DROP_INTERVAL);
 
     curr_time_ms = para.start_drop_time_ms + 1;
-    shaper_aqm_codel_need_drop(&para, curr_time_ms, CODEL_MAX_LATENCY + 1);
+    shaper_aqm_codel_need_drop(0, &para, curr_time_ms, CODEL_MAX_LATENCY + 1);
     EXPECT_EQ(para.state, CODEL_STATE_DROPPING_PHASE);
     EXPECT_EQ(para.drop_count, 1);
     EXPECT_EQ(para.next_drop_time_ms, int(curr_time_ms + CODEL_DROP_INTERVAL / sqrt(para.drop_count)));
 
     curr_time_ms = para.next_drop_time_ms + 1;
-    shaper_aqm_codel_need_drop(&para, curr_time_ms, CODEL_MAX_LATENCY + 1);
+    shaper_aqm_codel_need_drop(0, &para, curr_time_ms, CODEL_MAX_LATENCY + 1);
     EXPECT_EQ(para.state, CODEL_STATE_DROPPING_PHASE);
     EXPECT_EQ(para.drop_count, 2);
     EXPECT_EQ(para.next_drop_time_ms, int(curr_time_ms + CODEL_DROP_INTERVAL / sqrt(para.drop_count)));
 
-    shaper_aqm_codel_need_drop(&para, curr_time_ms, CODEL_MAX_LATENCY - 1);
+    shaper_aqm_codel_need_drop(0, &para, curr_time_ms, CODEL_MAX_LATENCY - 1);
     EXPECT_EQ(para.state, CODEL_STATE_NORMAL);
 }
 
@@ -84,7 +84,7 @@ TEST(aqm_codel, no_drop)
 
     memset(&para, 0, sizeof(para));
 
-    shaper_aqm_codel_need_drop(&para, curr_time_ms, CODEL_MAX_LATENCY - 1);
+    shaper_aqm_codel_need_drop(0, &para, curr_time_ms, CODEL_MAX_LATENCY - 1);
     EXPECT_EQ(para.state, CODEL_STATE_NORMAL);
     EXPECT_EQ(para.drop_count, 0);
 }