Add: experimental st40p api flag for queue stats

Add experimental st40p api flag for our
framebuffer queue statistics. This will allow
user to see clearly how many frames are in
which queue state.

Example output:
TX_st40p(0,st40sink), stat free: 15
TX_st40p(0,st40sink), stat in_user: 0
TX_st40p(0,st40sink), stat ready: 12
TX_st40p(0,st40sink), stat in_transmitting: 1

We are assuming this may be inaccurate as no
locking is done on the queue, but it is
useful for debugging purposes.

We could possibly replace the current stats for
consumer / producer.

For now we are keeping it as an optional
feature.

Author: DawidWesierski4

include/experimental/st40_pipeline_api.h

@@ -88,6 +88,10 @@ enum st40p_tx_flag {
   /** Enable the st40p_tx_get_frame block behavior to wait until a frame becomes
    available or timeout(default: 1s, use st40p_tx_set_block_timeout to customize)*/
   ST40P_TX_FLAG_BLOCK_GET = (MTL_BIT32(15)),
+  /**
+   * Enable accurate statistics to be shown in the stat dump for the frmaebuffers
+   */
+  ST40P_TX_FLAG_ACCURATE_FRAMEBUFF_STATISTICS = (MTL_BIT32(25)),
 };
 
 /**

lib/src/st2110/experimental/st40_pipeline_tx.c

@@ -92,6 +92,10 @@ static int tx_st40p_next_frame(void* priv, uint16_t* next_frame_idx,
     meta->timestamp = framebuff->frame_info.timestamp;
   }
 
+  if (ctx->ops.flags & (ST40P_TX_FLAG_ACCURATE_FRAMEBUFF_STATISTICS)) {
+    ctx->stat_enable_detailed_framebuffer_status = true;
+  }
+
   /* point to next */
   ctx->framebuff_consumer_idx = tx_st40p_next_idx(ctx, framebuff->idx);
   mt_pthread_mutex_unlock(&ctx->lock);
@@ -283,17 +287,36 @@ static int tx_st40p_stat(void* priv) {
   struct st40p_tx_frame* framebuff = ctx->framebuffs;
   uint16_t producer_idx;
   uint16_t consumer_idx;
+  uint16_t status_counts[ST40P_TX_FRAME_STATUS_MAX] = {0};
+  enum st40p_tx_frame_status stat;
 
   if (!ctx->ready) return -EBUSY; /* not ready */
 
   producer_idx = ctx->framebuff_producer_idx;
   consumer_idx = ctx->framebuff_consumer_idx;
-  notice("TX_st40p(%d,%s), p(%d:%s) c(%d:%s)\n", ctx->idx, ctx->ops_name, producer_idx,
-         tx_st40p_stat_name(framebuff[producer_idx].stat), consumer_idx,
-         tx_st40p_stat_name(framebuff[consumer_idx].stat));
+
+  if (ctx->stat_enable_detailed_framebuffer_status) {
+    for (uint16_t j = 0; j < ctx->framebuff_cnt; j++) {
+      stat = framebuff[j].stat;
+
+      if (stat < ST40P_TX_FRAME_STATUS_MAX) {
+        status_counts[stat]++;
+      }
+    }
+
+    for (uint16_t i = 0; i < ST40P_TX_FRAME_STATUS_MAX; i++) {
+      notice("TX_st40p(%d,%s), framebuffer queue %s: %u\n", ctx->idx, ctx->ops_name,
+             tx_st40p_stat_name(i), status_counts[i]);
+    }
+  } else {
+    notice("TX_st40p(%d,%s), p(%d:%s) c(%d:%s)\n", ctx->idx, ctx->ops_name, producer_idx,
+           tx_st40p_stat_name(framebuff[producer_idx].stat), consumer_idx,
+           tx_st40p_stat_name(framebuff[consumer_idx].stat));
+  }
 
   notice("TX_st40p(%d), frame get try %d succ %d, put %d\n", ctx->idx,
          ctx->stat_get_frame_try, ctx->stat_get_frame_succ, ctx->stat_put_frame);
+
   ctx->stat_get_frame_try = 0;
   ctx->stat_get_frame_succ = 0;
   ctx->stat_put_frame = 0;

lib/src/st2110/experimental/st40_pipeline_tx.h

@@ -47,6 +47,7 @@ struct st40p_tx_ctx {
   uint64_t block_timeout_ns;
 
   /* get frame stat */
+  bool stat_enable_detailed_framebuffer_status;
   int stat_get_frame_try;
   int stat_get_frame_succ;
   int stat_put_frame;