Add: RxTxApp unify support for drop frame for pipeline jsons

add unified drop-frame parsing in RxTxApp, allow users to test drop
frame functionality.

Author: DawidWesierski4

lib/src/st2110/pipeline/st30_pipeline_tx.c

@@ -91,7 +91,7 @@ static bool tx_st30p_if_frame_late(struct st30p_tx_ctx* ctx,
 
   uint64_t frame_tai = frame->timestamp;
   uint64_t cur_tai = mt_get_ptp_time(ctx->impl, MTL_PORT_P);
-  uint64_t frame_period_ns = NS_PER_S / ctx->frames_per_sec;
+  uint64_t frame_period_ns = (uint64_t)NS_PER_S / ctx->frames_per_sec;
 
   if (cur_tai < frame_tai + frame_period_ns)
     return false; /* within acceptable TX window */
@@ -139,6 +139,8 @@ static int tx_st30p_next_frame(void* priv, uint16_t* next_frame_idx,
 
   if (!ctx->ready) return -EBUSY; /* not ready */
 
+  uint32_t drops_before = ctx->stat_drop_frame;
+
   mt_pthread_mutex_lock(&ctx->lock);
   do {
     framebuff = tx_st30p_newest_available(ctx, ST30P_TX_FRAME_READY);
@@ -148,6 +150,10 @@ static int tx_st30p_next_frame(void* priv, uint16_t* next_frame_idx,
   /* not any ready frame */
   if (!framebuff) {
     mt_pthread_mutex_unlock(&ctx->lock);
+    /* Notify the app once after the entire drop batch so it can provide
+     * fresh frames.  Doing this here (instead of per-drop) avoids the
+     * drop→refill→drop feedback loop with high-rate audio streams. */
+    if (ctx->stat_drop_frame > drops_before) tx_st30p_notify_frame_available(ctx);
     return -EBUSY;
   }
 

tests/tools/RxTxApp/src/parse_json.c

@@ -1049,6 +1049,8 @@ static int st_json_parse_st30p(int idx, json_object* st30p_obj,
 
   st30p->user_pacing =
       json_object_get_boolean(st_json_object_object_get(st30p_obj, "user_pacing"));
+  st30p->drop_when_late =
+      json_object_get_boolean(st_json_object_object_get(st30p_obj, "drop_when_late"));
   return ST_JSON_SUCCESS;
 }
 
@@ -1118,6 +1120,8 @@ static int st_json_parse_tx_st40p(int idx, json_object* st40p_obj,
       json_object_get_boolean(st_json_object_object_get(st40p_obj, "user_timestamp"));
   st40p->enable_rtcp =
       json_object_get_boolean(st_json_object_object_get(st40p_obj, "enable_rtcp"));
+  st40p->drop_when_late =
+      json_object_get_boolean(st_json_object_object_get(st40p_obj, "drop_when_late"));
 
   return ST_JSON_SUCCESS;
 }

tests/tools/RxTxApp/src/parse_json.h

@@ -244,6 +244,7 @@ typedef struct st_json_st30p_session {
   st_json_audio_info_t info;
   bool enable_rtcp;
   bool user_pacing;
+  bool drop_when_late;
 } st_json_st30p_session_t;
 
 typedef struct st_json_ancillary_session {
@@ -300,6 +301,7 @@ typedef struct st_json_st40p_session {
   bool exact_user_pacing;
   bool user_timestamp;
   bool enable_rtcp;
+  bool drop_when_late;
 } st_json_st40p_session_t;
 
 typedef struct st_json_context {

tests/tools/RxTxApp/src/tx_st30p_app.c

@@ -231,6 +231,7 @@ static int app_tx_st30p_init(struct st_app_context* ctx, st_json_st30p_session_t
     s->frame_num = 0;
     s->local_tai_base_time = 0;
   }
+  if (st30p && st30p->drop_when_late) ops.flags |= ST30P_TX_FLAG_DROP_WHEN_LATE;
 
   ops.flags |= ST30P_TX_FLAG_BLOCK_GET;
   s->num_port = ops.port.num_port;

tests/tools/RxTxApp/src/tx_st40p_app.c

@@ -282,6 +282,7 @@ static int app_tx_st40p_init(struct st_app_context* ctx, st_json_st40p_session_t
   if ((st40p && st40p->exact_user_pacing) || ctx->tx_exact_user_pacing)
     ops.flags |= ST40P_TX_FLAG_EXACT_USER_PACING;
   if (st40p && st40p->enable_rtcp) ops.flags |= ST40P_TX_FLAG_ENABLE_RTCP;
+  if (st40p && st40p->drop_when_late) ops.flags |= ST40P_TX_FLAG_DROP_WHEN_LATE;
   if (ctx->tx_anc_dedicate_queue) ops.flags |= ST40P_TX_FLAG_DEDICATE_QUEUE;
 
   handle = st40p_tx_create(ctx->st, &ops);