Delete files script/ with huggingface_hub

script/batch_extract_smpl_cs.sh

@@ -1,72 +0,0 @@
-conda activate uni3c
-#!/usr/bin/env bash
-set -euo pipefail
-IFS=$'\n\t'
-
-# ========= 路径配置 =========
-SRC_DIR="/mnt/data_nas/guanfb/Pose/tiktok/rgb"  # 待处理视频目录
-GVHMR_DIR="../Uni3C/third_party/GVHMR_realisdance"
-BATCH_OUT_BASE="../Uni3C/outputs/batch"  # 每个视频的输出根
-FINAL_DIR="../SMPL_result"               # 汇总目录
-# PYTHON_BIN="/home/pai/envs/uni3c/bin/python"  # 或写绝对路径：/home/pai/envs/uni3c/bin/python
-
-mkdir -p "$BATCH_OUT_BASE" "$FINAL_DIR"
-
-# ========= 自检 =========
-if [[ ! -f "$GVHMR_DIR/extract_pose.py" ]]; then
-  echo "❌ 找不到 $GVHMR_DIR/extract_pose.py（请检查 Uni3C 路径）"
-  exit 2
-fi
-echo "▶ 批处理来源目录: $SRC_DIR"
-echo "▶ GVHMR_realisdance: $GVHMR_DIR"
-echo "▶ 中间输出根    : $BATCH_OUT_BASE"
-echo "▶ 最终结果目录  : $FINAL_DIR"
-echo
-
-SUCCESS=0
-FAIL=0
-
-# 用 NUL 分隔读取（find -print0 | sort -z），避免空格/换行/特殊字符问题
-while IFS= read -r -d '' V; do
-  BASENAME="${V##*/}"                # foo.mp4
-  STEM="${BASENAME%.*}"              # foo
-  OUT_ROOT="$BATCH_OUT_BASE/$STEM"
-
-  echo "==============================="
-  echo "▶ 处理视频: $BASENAME"
-  echo "   输出根  : $OUT_ROOT"
-  echo "==============================="
-
-  # 1) 在 GVHMR 目录执行（保持相对路径与资源一致）
-  pushd "$GVHMR_DIR" >/dev/null
-  if python extract_pose.py \
-      --video "$V" \
-      --output_root "$OUT_ROOT"; then
-    popd >/dev/null
-  else
-    popd >/dev/null
-    echo "❌ 提取失败：$BASENAME"
-    FAIL=$((FAIL + 1))
-    echo
-    continue
-  fi
-
-  # 2) 找到并复制 cs_map.mp4 -> 最终目录，命名为 原名_smpl.mp4
-  CS_MP4="$(find "$OUT_ROOT" -type f -name 'cs_map.mp4' -print -quit 2>/dev/null || true)"
-  if [[ -n "${CS_MP4:-}" && -f "$CS_MP4" ]]; then
-    TARGET="$FINAL_DIR/${STEM}_smpl.mp4"
-    cp -f "$CS_MP4" "$TARGET"
-    echo "✅ 提取成功：$TARGET"
-    SUCCESS=$((SUCCESS + 1))
-  else
-    echo "❌ 未找到 cs_map.mp4（视频：$BASENAME）。请检查 $OUT_ROOT"
-    FAIL=$((FAIL + 1))
-  fi
-
-  echo
-done < <(find "$SRC_DIR" -maxdepth 1 -type f -iname '*.mp4' -print0 | sort -z)
-
-echo "==============================="
-echo "🎯 完成：成功 $SUCCESS 个，失败 $FAIL 个"
-echo "📂 汇总目录：$FINAL_DIR"
-echo "==============================="

script/hamer_batch.sh

@@ -1,305 +0,0 @@
-#!/usr/bin/env bash
-conda activate hamer
-set -euo pipefail
-IFS=$'\n\t'
-
-########################################
-# 通用：日志 & 目录校验
-########################################
-log() { echo "[$(date +'%F %T')] $*"; }
-die() { echo "[$(date +'%F %T')] ❌ $*" >&2; exit 1; }
-
-# dir 存在且可写（会自动 mkdir -p）
-ensure_dir_writable() {
-  local d="$1"
-  mkdir -p "$d" || die "创建目录失败：$d"
-  if ! test -w "$d"; then
-    die "目录不可写：$d（可能是只读挂载或权限不足）"
-  fi
-  local tf="$d/.write_test_$$"
-  if ! ( : > "$tf" ) 2>/dev/null; then
-    die "无法在 $d 写入文件（磁盘满 / quota / 权限？）"
-  fi
-  rm -f "$tf" || true
-}
-
-########################################
-# 路径基准：以脚本所在目录为根处理相对路径
-########################################
-SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
-
-########################################
-# 先确保依赖
-########################################
-command -v ffmpeg  >/dev/null 2>&1 || die "未找到 ffmpeg，请先安装：sudo apt-get install -y ffmpeg 或 conda install -c conda-forge ffmpeg"
-command -v ffprobe >/dev/null 2>&1 || die "未找到 ffprobe，请先安装：sudo apt-get install -y ffmpeg 或 conda install -c conda-forge ffmpeg"
-
-########################################
-# 配置
-########################################
-# 1) HaMeR 仓库与缓存
-export HAMER_DIR="${SCRIPT_DIR}/../hamer"
-ensure_dir_writable "$HAMER_DIR/_DATA/cache"
-export FVCORE_CACHE="$HAMER_DIR/_DATA/cache"
-export IOPATH_CACHE_DIR="$HAMER_DIR/_DATA/cache"
-
-# 2) 输入/输出根目录
-SRC_DIR="/mnt/data_nas/guanfb/Pose/tiktok/rgb"
-OUT_IMG_ROOT="${SCRIPT_DIR}/../hamer_img"
-OUT_RES_ROOT="${SCRIPT_DIR}/../hamer_result"
-
-ensure_dir_writable "$OUT_IMG_ROOT"
-ensure_dir_writable "$OUT_RES_ROOT"
-
-########################################
-# 3) 环境（离屏渲染）—— 检测/安装 EGL，不行就回退 OSMesa
-########################################
-unset DISPLAY
-export LD_PRELOAD=${LD_PRELOAD:-/usr/lib/x86_64-linux-gnu/libstdc++.so.6}
-
-_have_cmd() { command -v "$1" >/dev/null 2>&1; }
-_have_sudo() { _have_cmd sudo && sudo -n true 2>/dev/null; }
-_has_libegl() { ldconfig -p 2>/dev/null | grep -qi 'libEGL\.so'; }
-_apt_ensure() {
-  local pkgs=("$@")
-  _have_cmd apt-get || return 1
-  _have_sudo || return 2
-  sudo apt-get update -y
-  sudo apt-get install -y "${pkgs[@]}"
-}
-
-choose_gl_backend() {
-  if _has_libegl; then
-    echo "egl"; return 0
-  fi
-  if _apt_ensure libegl1 libglvnd0 libgles2 libopengl0 libgl1-mesa-glx libgl1 libglx-mesa0 2>/dev/null; then
-    hash -r || true
-    _have_cmd ldconfig && { _have_sudo && sudo ldconfig || ldconfig || true; }
-    _has_libegl && { echo "egl"; return 0; }
-  fi
-  if _apt_ensure libosmesa6 libosmesa6-dev mesa-utils libglu1-mesa 2>/dev/null; then
-    echo "osmesa"; return 0
-  fi
-  echo "osmesa"
-}
-
-GL_BACKEND="$(choose_gl_backend)"
-if [[ "$GL_BACKEND" == "egl" ]]; then
-  export PYOPENGL_PLATFORM=egl
-  log "[GL] 使用 EGL 后端（PYOPENGL_PLATFORM=egl）"
-else
-  export PYOPENGL_PLATFORM=osmesa
-  export LIBGL_ALWAYS_SOFTWARE=1
-  export MESA_GL_VERSION_OVERRIDE=3.3
-  export MESA_GLSL_VERSION_OVERRIDE=330
-  log "[GL] 未检测/安装到 EGL，回退到 OSMesa（PYOPENGL_PLATFORM=osmesa）"
-fi
-
-# 4) HaMeR demo 运行参数
-BATCH_SIZE=48
-SIDE_VIEW=1
-FULL_FRAME=0   # ⚠️ 为提高手部像素密度，这里改为 0；如需全画幅可改回 1
-SAVE_MESH=1
-
-########################################
-# 单视频处理
-########################################
-process_one() {
-  local vid="$1"
-  local base="$(basename "$vid")"
-  local stem="${base%.*}"
-  log "开始处理：$base"
-
-  local ROOT="$OUT_IMG_ROOT/$stem"
-  local FRAMES="$ROOT/frames"
-  local HAMER_OUT="$ROOT/hamer_vis"
-  local FILLED="$ROOT/hamer_vis_all_filled"
-  local ALIGNED_COLOR="$ROOT/hamer_vis_color_aligned"
-  local OUT_MP4="$OUT_RES_ROOT/hamer_color_aligned_${stem}.mp4"
-
-  ensure_dir_writable "$ROOT"
-  ensure_dir_writable "$FRAMES"
-  ensure_dir_writable "$HAMER_OUT"
-  ensure_dir_writable "$FILLED"
-  ensure_dir_writable "$ALIGNED_COLOR"
-  ensure_dir_writable "$OUT_RES_ROOT"
-
-  pushd "$ROOT" >/dev/null
-  trap 'popd >/dev/null || true' RETURN
-
-  # 1) 抽帧 —— 无损 PNG
-  local FPS_RAW
-  FPS_RAW=$(ffprobe -v error -select_streams v:0 -show_entries stream=r_frame_rate \
-            -of default=nokey=1:noprint_wrappers=1 "$vid")
-  ffmpeg -y -i "$vid" -vsync 0 "$FRAMES/%06d.png"
-  local TOTAL
-  TOTAL=$(ls -1 "$FRAMES"/*.png | wc -l)
-  log "[$stem] 源帧数: $TOTAL  (FPS raw=$FPS_RAW)"
-
-  # 2) 跑 HaMeR
-  [[ -d "$HAMER_DIR" ]] || die "HaMeR 目录不存在：$HAMER_DIR"
-  pushd "$HAMER_DIR" >/dev/null
-  python demo.py \
-    --img_folder "$FRAMES" \
-    --out_folder "$HAMER_OUT" \
-    --batch_size "$BATCH_SIZE" \
-    $( ((SIDE_VIEW)) && echo --side_view ) \
-    $( ((SAVE_MESH)) && echo --save_mesh ) \
-    $( ((FULL_FRAME)) && echo --full_frame )
-  popd >/dev/null
-
-  # 3) 只用 *_all.{jpg|png} 并补齐缺帧（无则回退原始帧 PNG）
-  local EXT=""
-  if ls "$HAMER_OUT"/*_all.jpg 1>/dev/null 2>&1; then
-    EXT="jpg"
-  elif ls "$HAMER_OUT"/*_all.png 1>/dev/null 2>&1; then
-    EXT="png"
-  else
-    EXT=""
-  fi
-
-  python - "$FRAMES" "$HAMER_OUT" "$FILLED" "$EXT" <<'PY'
-import os, sys, glob, shutil
-FRAMES, HAMER_OUT, FILLED, EXT = sys.argv[1:]
-imgs = sorted(glob.glob(os.path.join(FRAMES, '*.png')))
-N = len(imgs)
-if not EXT:
-    EXT = 'png'
-os.makedirs(FILLED, exist_ok=True)
-for i in range(1, N+1):
-    stem = f"{i:06d}"
-    src_all = os.path.join(HAMER_OUT, f"{stem}_all.{EXT}")
-    dst_all = os.path.join(FILLED,   f"{stem}_all.{EXT}")
-    if os.path.exists(src_all):
-        shutil.copy2(src_all, dst_all)
-    else:
-        shutil.copy2(os.path.join(FRAMES, f"{stem}.png"), dst_all)
-print("[Info] 补齐到目录：", FILLED)
-PY
-
-  # 4) 黑底 + 彩色（像素对齐，不改位置/尺度）
-  if ls "$FILLED"/*_all.jpg 1>/dev/null 2>&1; then
-    EXT="jpg"
-  elif ls "$FILLED"/*_all.png 1>/dev/null 2>&1; then
-    EXT="png"
-  else
-    log "❌ $FILLED 里没有 *_all.{jpg,png}"; return 2
-  fi
-
-  python - "$FRAMES" "$FILLED" "$ALIGNED_COLOR" "$EXT" <<'PY'
-import os, sys, glob
-import numpy as np
-from PIL import Image, ImageFilter
-
-FRAMES, FILLED, OUT, EXT = sys.argv[1:]
-os.makedirs(OUT, exist_ok=True)
-
-frames = sorted(glob.glob(os.path.join(FRAMES, '*.png')))
-N = len(frames)
-THR = 16  # ↑ 略提阈值，掩模更贴边；可调 14~22
-
-def hsv_to_rgb_arr(h):
-    h6 = (h * 6.0).astype(np.float32)
-    i = np.floor(h6).astype(np.int32) % 6
-    f = h6 - np.floor(h6)
-    v = np.ones_like(h, dtype=np.float32)
-    s = np.ones_like(h, dtype=np.float32)
-    p = v*(1-s); q = v*(1-f*s); t = v*(1-(1-f)*s)
-
-    r = np.zeros_like(h, dtype=np.float32)
-    g = np.zeros_like(h, dtype=np.float32)
-    b = np.zeros_like(h, dtype=np.float32)
-
-    m0 = (i==0); r[m0]=v[m0]; g[m0]=t[m0]; b[m0]=p[m0]
-    m1 = (i==1); r[m1]=q[m1]; g[m1]=v[m1]; b[m1]=p[m1]
-    m2 = (i==2); r[m2]=p[m2]; g[m2]=v[m2]; b[m2]=t[m2]
-    m3 = (i==3); r[m3]=p[m3]; g[m3]=q[m3]; b[m3]=v[m3]
-    m4 = (i==4); r[m4]=t[m4]; g[m4]=p[m4]; b[m4]=v[m4]
-    m5 = (i==5); r[m5]=v[m5]; g[m5]=p[m5]; b[m5]=q[m5]
-    return np.stack([r,g,b], axis=2)
-
-for idx in range(1, N+1):
-    stem = f"{idx:06d}"
-    src_frame = os.path.join(FRAMES, f"{stem}.png")
-    src_all   = os.path.join(FILLED, f"{stem}_all.{EXT}")
-    dst_png   = os.path.join(OUT,    f"{stem}_all.png")
-
-    im0 = Image.open(src_frame).convert("RGB")
-    W, H = im0.size
-
-    if not os.path.exists(src_all):
-        Image.new("RGB", (W,H), (0,0,0)).save(dst_png)
-        continue
-
-    im = Image.open(src_all).convert("RGB")
-    if im.size != (W,H):
-        im = im.resize((W,H), Image.BILINEAR)
-
-    a = np.asarray(im , np.int16)
-    b = np.asarray(im0, np.int16)
-    diff = np.mean(np.abs(a - b), axis=2).astype(np.uint8)
-
-    # 掩模：差分二值化 + 轻微腐蚀（代替膨胀，细化边缘）
-    mask = (diff > THR).astype(np.uint8)*255
-    mask_img = Image.fromarray(mask).filter(ImageFilter.MinFilter(3))  # ← 原来是 MaxFilter(3)
-    mask_np  = np.asarray(mask_img, np.uint8)
-    if mask_np.max() == 0:
-        Image.new("RGB", (W,H), (0,0,0)).save(dst_png)
-        continue
-
-    # 纵向渐变（蓝→红）
-    ys = np.linspace(0, 1, H, dtype=np.float32)[:, None]
-    hs = np.repeat(ys, W, axis=1)
-    h  = 0.66 * (1.0 - hs)
-    color = hsv_to_rgb_arr(h)
-
-    # 明暗调制（用合成图亮度）
-    gray  = a.mean(axis=2).astype(np.float32) / 255.0
-    shade = 0.6 + 0.4 * gray
-    color = color * shade[..., None]
-
-    color_u8 = (np.clip(color, 0, 1) * 255).astype(np.uint8)
-    color_u8[mask_np==0] = 0
-
-    Image.fromarray(color_u8, mode="RGB").save(dst_png)
-
-print("[Info] 彩色黑底输出：", OUT)
-PY
-
-  # 5) 合成 mp4（保持原视频 FPS）
-  local FPS
-  FPS=$(python - <<PY
-fr="$FPS_RAW"
-try:
-    n,d = fr.split("/")
-    print(float(n)/float(d))
-except Exception:
-    print(30.0)
-PY
-)
-  ffmpeg -y -framerate "$FPS" \
-    -start_number 1 \
-    -i "$ALIGNED_COLOR/%06d_all.png" \
-    -c:v libx264 -pix_fmt yuv420p "$OUT_MP4"
-
-  log "完成：$OUT_MP4"
-}
-
-########################################
-# 扫描并处理所有 mp4（串行）
-########################################
-ensure_dir_writable "$OUT_IMG_ROOT"
-ensure_dir_writable "$OUT_RES_ROOT"
-
-log "扫描目录：$SRC_DIR"
-shopt -s nullglob
-mapfile -d '' VIDEOS < <(find "$SRC_DIR" -maxdepth 1 -type f -name '*.mp4' -print0)
-
-if (( ${#VIDEOS[@]} == 0 )); then
-  log "未发现 mp4 文件，退出。"
-  exit 0
-fi
-
-for v in "${VIDEOS[@]}"; do
-  process_one "$v"
-done

script/mgpu_mworker_extract_smpl_cs.sh

@@ -1,438 +0,0 @@
-#!/usr/bin/env bash
-set -euo pipefail
-IFS=$'\n\t'
-
-########################################
-# 环境与 Python 选择（静默、固定解释器）
-########################################
-unset BASH_ENV
-PYTHON_BIN=""
-
-if command -v conda >/dev/null 2>&1; then
-  if __conda_setup="$('conda' 'shell.bash' 'hook' 2>/dev/null)"; then
-    eval "$__conda_setup"
-    unset __conda_setup
-  else
-    for csh in "$HOME/miniconda3/etc/profile.d/conda.sh" \
-               "$HOME/anaconda3/etc/profile.d/conda.sh" \
-               "/opt/conda/etc/profile.d/conda.sh"; do
-      [[ -f "$csh" ]] && . "$csh" && break
-    done
-  fi
-  PYTHON_BIN="$(conda run -n hamer python -c 'import sys;print(sys.executable)' 2>/dev/null || true)"
-fi
-[[ -n "${PYTHON_BIN:-}" ]] || PYTHON_BIN="$(command -v python || command -v python3)"
-
-########################################
-# 日志 & 工具（与单线程版风格一致）
-########################################
-log(){ echo "[$(date +'%F %T')] $*"; }
-die(){ echo "[$(date +'%F %T')] ❌ $*" >&2; exit 1; }
-
-ensure_dir_writable() {
-  local d="$1"
-  mkdir -p "$d" || die "创建目录失败：$d"
-  if ! test -w "$d"; then die "目录不可写：$d（可能是只读挂载或权限不足）"; fi
-  local tf="$d/.write_test_$$"
-  : > "$tf" 2>/dev/null || die "无法在 $d 写入文件（磁盘满 / quota / 权限？）"
-  rm -f "$tf" || true
-}
-
-########################################
-# 路径基准 & 依赖
-########################################
-SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
-SCRIPT_PATH="$(readlink -f "${BASH_SOURCE[0]}")"
-
-command -v ffmpeg  >/dev/null 2>&1 || die "未找到 ffmpeg，请先安装：sudo apt-get install -y ffmpeg 或 conda install -c conda-forge ffmpeg"
-command -v ffprobe >/dev/null 2>&1 || die "未找到 ffprobe，请先安装：sudo apt-get install -y ffmpeg 或 conda install -c conda-forge ffmpeg"
-
-########################################
-# 配置（保持与单线程一致）
-########################################
-export HAMER_DIR="${SCRIPT_DIR}/../hamer"
-ensure_dir_writable "$HAMER_DIR/_DATA/cache"
-export FVCORE_CACHE="$HAMER_DIR/_DATA/cache"
-export IOPATH_CACHE_DIR="$HAMER_DIR/_DATA/cache"
-
-SRC_DIR="/mnt/data_nas/guanfb/Pose/tiktok/rgb"
-OUT_IMG_ROOT="${SCRIPT_DIR}/../hamer_img"
-OUT_RES_ROOT="${SCRIPT_DIR}/../hamer_result"
-LOG_DIR="${SCRIPT_DIR}/../hamer_log"
-
-ensure_dir_writable "$OUT_IMG_ROOT"
-ensure_dir_writable "$OUT_RES_ROOT"
-ensure_dir_writable "$LOG_DIR"
-
-########################################
-# 离屏渲染（与单线程一致）
-########################################
-unset DISPLAY
-export LD_PRELOAD=${LD_PRELOAD:-/usr/lib/x86_64-linux-gnu/libstdc++.so.6}
-
-_have_cmd() { command -v "$1" >/dev/null 2>&1; }
-_have_sudo() { _have_cmd sudo && sudo -n true 2>/dev/null; }
-_has_libegl() { ldconfig -p 2>/dev/null | grep -qi 'libEGL\.so'; }
-_apt_ensure() {
-  local pkgs=("$@")
-  _have_cmd apt-get || return 1
-  _have_sudo || return 2
-  sudo apt-get update -y
-  sudo apt-get install -y "${pkgs[@]}"
-}
-choose_gl_backend() {
-  if _has_libegl; then echo "egl"; return 0; fi
-  _apt_ensure libegl1 libglvnd0 libgles2 libopengl0 libgl1-mesa-glx libgl1 libglx-mesa0 2>/dev/null || true
-  if _has_libegl; then echo "egl"; return 0; fi
-  _apt_ensure libosmesa6 libosmesa6-dev mesa-utils libglu1-mesa 2>/dev/null || true
-  echo "osmesa"
-}
-GL_BACKEND="$(choose_gl_backend)"
-if [[ "$GL_BACKEND" == "egl" ]]; then
-  export PYOPENGL_PLATFORM=egl
-else
-  export PYOPENGL_PLATFORM=osmesa
-  export LIBGL_ALWAYS_SOFTWARE=1
-  export MESA_GL_VERSION_OVERRIDE=3.3
-  export MESA_GLSL_VERSION_OVERRIDE=330
-fi
-
-########################################
-# HaMeR 运行参数（与单线程一致）
-########################################
-BATCH_SIZE=48
-SIDE_VIEW=1
-FULL_FRAME=0   # 提高手部像素密度；需要全幅改为 1
-SAVE_MESH=1
-
-########################################
-# 并行与 GPU 调度（GPU 分配信息将写入每视频日志）
-########################################
-GPUS="${GPUS:-}"  # 形如 "0,1,2,3"；为空自动探测
-if [[ -z "$GPUS" ]] && command -v nvidia-smi >/dev/null 2>&1; then
-  NGPU="$(nvidia-smi --query-gpu=index --format=csv,noheader | wc -l | awk '{print $1}')"
-  (( NGPU > 0 )) && GPUS="$(seq -s, 0 $((NGPU-1)))" || true
-fi
-
-MAX_JOBS_PER_GPU="${MAX_JOBS_PER_GPU:-1}"
-SKIP_IF_DONE="${SKIP_IF_DONE:-1}"
-
-if [[ -n "$GPUS" ]]; then
-  _GPU_COUNT="$(awk -F, '{print NF}' <<<"$GPUS")"
-  DEFAULT_JOBS=$((_GPU_COUNT * MAX_JOBS_PER_GPU))
-  (( DEFAULT_JOBS > 0 )) || DEFAULT_JOBS=1
-else
-  DEFAULT_JOBS=4  # 无GPU时的CPU并发（若模型支持）
-fi
-JOBS="${JOBS:-$DEFAULT_JOBS}"
-
-GPU_LOCK_DIR="${SCRIPT_DIR}/.gpu_locks"
-ensure_dir_writable "$GPU_LOCK_DIR"
-
-init_gpu_tokens() {
-  rm -f "${GPU_LOCK_DIR}/gpu"*".lock" 2>/dev/null || true
-  if [[ -z "$GPUS" ]]; then
-    return 0
-  fi
-  IFS=',' read -r -a GPU_ARR <<<"$GPUS"
-  for gid in "${GPU_ARR[@]}"; do
-    for ((s=1; s<=MAX_JOBS_PER_GPU; s++)); do : > "${GPU_LOCK_DIR}/gpu${gid}.${s}.lock"; done
-  done
-}
-init_gpu_tokens
-
-# 子进程组统一清理（强力中止）
-declare -a CHILD_PGIDS=()
-ADD_PGID(){ CHILD_PGIDS+=("$1"); }
-run_pgroup(){
-  if command -v setsid >/dev/null 2>&1; then
-    setsid bash -c "$*" &
-    local pid=$!
-    ADD_PGID "$pid"
-    wait "$pid"; return $?
-  else
-    bash -c "$*"; return $?
-  fi
-}
-CLEANED=0
-cleanup_all(){
-  (( CLEANED )) && return 0
-  CLEANED=1
-  for pg in "${CHILD_PGIDS[@]:-}"; do [[ -n "$pg" ]] && kill -TERM -- "-${pg}" 2>/dev/null || true; done
-  sleep 0.5
-  for pg in "${CHILD_PGIDS[@]:-}"; do [[ -n "$pg" ]] && kill -KILL -- "-${pg}" 2>/dev/null || true; done
-}
-on_master_signal(){ cleanup_all; kill -TERM -- "-$$" 2>/dev/null || true; }
-on_worker_signal(){ cleanup_all; exit 130; }
-trap on_master_signal INT TERM
-
-# GPU token（分配/释放信息写入**每视频日志**）
-GPU_LOCK_FD=-1
-GPU_LOCK_FILE=""
-GPU_ID=""
-acquire_gpu(){
-  if [[ -z "$GPUS" ]]; then
-    unset CUDA_VISIBLE_DEVICES
-    GPU_ID="cpu"
-    # 分配信息会在每视频日志中打印（见 process_one 内部）
-    return 0
-  fi
-  IFS=',' read -r -a GPU_ARR <<<"$GPUS"
-  while true; do
-    for gid in "${GPU_ARR[@]}"; do
-      for ((s=1; s<=MAX_JOBS_PER_GPU; s++)); do
-        local f="${GPU_LOCK_DIR}/gpu${gid}.${s}.lock"
-        exec {fd}> "$f" || continue
-        if flock -n "$fd"; then
-          GPU_LOCK_FD="$fd"; GPU_LOCK_FILE="$f"; GPU_ID="$gid"
-          export CUDA_VISIBLE_DEVICES="$gid"
-          return 0
-        else
-          exec {fd}>&-
-        fi
-      done
-    done
-    sleep 0.2
-  done
-}
-release_gpu(){
-  if [[ "$GPU_ID" == "cpu" || -z "$GPUS" ]]; then return 0; fi
-  if [[ "$GPU_LOCK_FD" -ge 0 ]]; then
-    flock -u "$GPU_LOCK_FD" || true
-    eval "exec ${GPU_LOCK_FD}>&-" || true
-    GPU_LOCK_FD=-1; GPU_LOCK_FILE=""; GPU_ID=""
-  fi
-}
-
-########################################
-# —— 核心：单视频处理（日志写 hamer_log，内容与单线程一致 + GPU分配信息）——
-########################################
-process_one() {
-  trap on_worker_signal INT TERM
-
-  local vid="$1"
-  local base="$(basename "$vid")"
-  local stem="${base%.*}"
-
-  local ROOT="$OUT_IMG_ROOT/$stem"
-  local FRAMES="$ROOT/frames"
-  local HAMER_OUT="$ROOT/hamer_vis"
-  local FILLED="$ROOT/hamer_vis_all_filled"
-  local ALIGNED_COLOR="$ROOT/hamer_vis_color_aligned"
-  local OUT_MP4="$OUT_RES_ROOT/hamer_color_aligned_${stem}.mp4"
-  local LOGF="$LOG_DIR/${stem}.log"
-
-  # 跳过：已有最终结果且非空 —— 与单线程保持一致（跳过时不产生日志）
-  if (( SKIP_IF_DONE )) && [[ -s "$OUT_MP4" ]]; then
-    return 0
-  fi
-
-  # 从此处起，每视频日志
-  exec >>"$LOGF" 2>&1
-
-  log "开始处理：$base"
-
-  ensure_dir_writable "$ROOT"
-  ensure_dir_writable "$FRAMES"
-  ensure_dir_writable "$HAMER_OUT"
-  ensure_dir_writable "$FILLED"
-  ensure_dir_writable "$ALIGNED_COLOR"
-  ensure_dir_writable "$OUT_RES_ROOT"
-
-  pushd "$ROOT" >/dev/null
-  trap 'popd >/dev/null || true' RETURN
-
-  # 1) 抽帧 —— 无损 PNG
-  local FPS_RAW
-  FPS_RAW=$(ffprobe -v error -select_streams v:0 -show_entries stream=r_frame_rate \
-            -of default=nokey=1:noprint_wrappers=1 "$vid")
-  run_pgroup "ffmpeg -y -i \"$vid\" -vsync 0 \"$FRAMES/%06d.png\""
-
-  local TOTAL
-  TOTAL=$(ls -1 "$FRAMES"/*.png 2>/dev/null | wc -l)
-  log "[$stem] 源帧数: $TOTAL  (FPS raw=$FPS_RAW)"
-
-  # 2) HaMeR 推理（打印 GPU 分配/释放信息到**该视频日志**）
-  [[ -d "$HAMER_DIR" ]] || { die "HaMeR 目录不存在：$HAMER_DIR"; }
-  acquire_gpu
-  if [[ "$GPU_ID" == "cpu" ]]; then
-    log "[GPU] 分配：CPU（无可用 GPU）"
-  else
-    log "[GPU] 分配：GPU ${GPU_ID}（token=${GPU_LOCK_FILE})"
-  fi
-
-  pushd "$HAMER_DIR" >/dev/null
-  run_pgroup "\"$PYTHON_BIN\" demo.py \
-      --img_folder \"$FRAMES\" \
-      --out_folder \"$HAMER_OUT\" \
-      --batch_size \"$BATCH_SIZE\" \
-      $([[ $SIDE_VIEW -eq 1 ]]  && echo --side_view) \
-      $([[ $SAVE_MESH -eq 1 ]]  && echo --save_mesh) \
-      $([[ $FULL_FRAME -eq 1 ]] && echo --full_frame)"
-  local rc=$?
-  popd >/dev/null
-
-  if [[ "$GPU_ID" != "cpu" ]]; then
-    log "[GPU] 释放：GPU ${GPU_ID}（token=${GPU_LOCK_FILE})"
-  fi
-  release_gpu
-  (( rc == 0 )) || { return 1; }
-
-  # 3) 补齐缺帧
-  local EXT=""
-  if ls "$HAMER_OUT"/*_all.jpg >/dev/null 2>&1; then EXT="jpg"
-  elif ls "$HAMER_OUT"/*_all.png >/dev/null 2>&1; then EXT="png"
-  else EXT="png"; fi
-
-  "$PYTHON_BIN" - "$FRAMES" "$HAMER_OUT" "$FILLED" "$EXT" <<'PY'
-import os, sys, glob, shutil
-FRAMES, HAMER_OUT, FILLED, EXT = sys.argv[1:]
-imgs = sorted(glob.glob(os.path.join(FRAMES, '*.png')))
-N = len(imgs)
-if not EXT:
-    EXT = 'png'
-os.makedirs(FILLED, exist_ok=True)
-for i in range(1, N+1):
-    stem = f"{i:06d}"
-    src_all = os.path.join(HAMER_OUT, f"{stem}_all.{EXT}")
-    dst_all = os.path.join(FILLED,   f"{stem}_all.{EXT}")
-    if os.path.exists(src_all):
-        shutil.copy2(src_all, dst_all)
-    else:
-        shutil.copy2(os.path.join(FRAMES, f"{stem}.png"), dst_all)
-print("[Info] 补齐到目录：", FILLED)
-PY
-
-  # 4) 黑底 + 彩色（保持单线程同实现）
-  if ls "$FILLED"/*_all.jpg >/dev/null 2>&1; then EXT="jpg"
-  elif ls "$FILLED"/*_all.png >/dev/null 2>&1; then EXT="png"
-  else return 2; fi
-
-  "$PYTHON_BIN" - "$FRAMES" "$FILLED" "$ALIGNED_COLOR" "$EXT" <<'PY'
-import os, sys, glob
-import numpy as np
-from PIL import Image, ImageFilter
-
-FRAMES, FILLED, OUT, EXT = sys.argv[1:]
-os.makedirs(OUT, exist_ok=True)
-
-frames = sorted(glob.glob(os.path.join(FRAMES, '*.png')))
-N = len(frames)
-THR = 16
-
-def hsv_to_rgb_arr(h):
-    h6 = (h * 6.0).astype(np.float32)
-    i = np.floor(h6).astype(np.int32) % 6
-    f = h6 - np.floor(h6)
-    v = np.ones_like(h, dtype=np.float32)
-    s = np.ones_like(h, dtype=np.float32)
-    p = v*(1-s); q = v*(1-f*s); t = v*(1-(1-f)*s)
-    r = np.zeros_like(h, dtype=np.float32)
-    g = np.zeros_like(h, dtype=np.float32)
-    b = np.zeros_like(h, dtype=np.float32)
-    m0 = (i==0); r[m0]=v[m0]; g[m0]=t[m0]; b[m0]=p[m0]
-    m1 = (i==1); r[m1]=q[m1]; g[m1]=v[m1]; b[m1]=p[m1]
-    m2 = (i==2); r[m2]=p[m2]; g[m2]=v[m2]; b[m2]=t[m2]
-    m3 = (i==3); r[m3]=p[m3]; g[m3]=q[m3]; b[m3]=v[m3]
-    m4 = (i==4); r[m4]=t[m4]; g[m4]=p[m4]; b[m4]=v[m4]
-    m5 = (i==5); r[m5]=v[m5]; g[m5]=p[m5]; b[m5]=q[m5]
-    return np.stack([r,g,b], axis=2)
-
-for idx in range(1, N+1):
-    stem = f"{idx:06d}"
-    src_frame = os.path.join(FRAMES, f"{stem}.png")
-    src_all   = os.path.join(FILLED, f"{stem}_all.{EXT}")
-    dst_png   = os.path.join(OUT,    f"{stem}_all.png")
-
-    im0 = Image.open(src_frame).convert("RGB")
-    W, H = im0.size
-
-    if not os.path.exists(src_all):
-        Image.new("RGB", (W,H), (0,0,0)).save(dst_png)
-        continue
-
-    im = Image.open(src_all).convert("RGB")
-    if im.size != (W,H):
-        im = im.resize((W,H), Image.BILINEAR)
-
-    a = np.asarray(im , np.int16)
-    b = np.asarray(im0, np.int16)
-    diff = np.mean(np.abs(a - b), axis=2).astype(np.uint8)
-
-    mask = (diff > THR).astype(np.uint8)*255
-    mask_img = Image.fromarray(mask).filter(ImageFilter.MinFilter(3))
-    mask_np  = np.asarray(mask_img, np.uint8)
-    if mask_np.max() == 0:
-        Image.new("RGB", (W,H), (0,0,0)).save(dst_png)
-        continue
-
-    ys = np.linspace(0, 1, H, dtype=np.float32)[:, None]
-    hs = np.repeat(ys, W, axis=1)
-    h  = 0.66 * (1.0 - hs)
-    color = hsv_to_rgb_arr(h)
-
-    gray  = a.mean(axis=2).astype(np.float32) / 255.0
-    shade = 0.6 + 0.4 * gray
-    color = color * shade[..., None]
-
-    color_u8 = (np.clip(color, 0, 1) * 255).astype(np.uint8)
-    color_u8[mask_np==0] = 0
-
-    Image.fromarray(color_u8, mode="RGB").save(dst_png)
-
-print("[Info] 彩色黑底输出：", OUT)
-PY
-
-  # 5) 合成 mp4（保持原视频 FPS）
-  local FPS
-  FPS=$("$PYTHON_BIN" - <<PY
-fr = "${FPS_RAW}"
-try:
-    if "/" in fr:
-        n, d = fr.split("/")
-        print(float(n)/float(d))
-    else:
-        print(float(fr))
-except Exception:
-    print(30.0)
-PY
-)
-  run_pgroup "ffmpeg -y -framerate \"$FPS\" -start_number 1 -i \"$ALIGNED_COLOR/%06d_all.png\" -c:v libx264 -pix_fmt yuv420p \"$OUT_MP4\""
-
-  log "完成：$OUT_MP4"
-}
-
-########################################
-# 单文件模式（供并行 worker 调用）
-########################################
-if [[ "${1:-}" == "--one" ]]; then
-  shift
-  trap on_worker_signal INT TERM
-  trap 'cleanup_all' EXIT
-  process_one "$@"
-  exit $?
-fi
-
-########################################
-# 主控：扫描输入并并行处理
-########################################
-log "扫描目录：$SRC_DIR"
-shopt -s nullglob
-mapfile -d '' VIDEOS < <(find "$SRC_DIR" -maxdepth 1 -type f -iname '*.mp4' -print0 | sort -z)
-
-if (( ${#VIDEOS[@]} == 0 )); then
-  log "未发现 mp4 文件，退出。"
-  exit 0
-fi
-
-# 并行执行（优先 parallel，无则 xargs）
-if command -v parallel >/dev/null 2>&1; then
-  printf '%s\0' "${VIDEOS[@]}" \
-    | parallel -0 -P "$JOBS" --no-run-if-empty --halt now,fail=1 \
-        bash "$SCRIPT_PATH" --one {}
-else
-  printf '%s\0' "${VIDEOS[@]}" \
-    | xargs -0 -n1 -P "$JOBS" -I{} bash "$SCRIPT_PATH" --one "{}"
-fi
-
-cleanup_all

script/mgpu_mworker_hamer_batch.sh

@@ -1,444 +0,0 @@
-#!/usr/bin/env bash
-set -euo pipefail
-IFS=$'\n\t'
-unset BASH_ENV
-
-########################################
-# 选 Python（优先 conda:hamer）
-########################################
-PYTHON_BIN=""
-if command -v conda >/dev/null 2>&1; then
-  if __conda_setup="$('conda' 'shell.bash' 'hook' 2>/dev/null)"; then
-    eval "$__conda_setup"
-    unset __conda_setup
-  else
-    for csh in "$HOME/miniconda3/etc/profile.d/conda.sh" \
-               "$HOME/anaconda3/etc/profile.d/conda.sh" \
-               "/opt/conda/etc/profile.d/conda.sh"; do
-      [[ -f "$csh" ]] && . "$csh" && break
-    done
-  fi
-  PYTHON_BIN="$(conda run -n hamer python -c 'import sys;print(sys.executable)' 2>/dev/null || true)"
-fi
-[[ -n "${PYTHON_BIN:-}" ]] || PYTHON_BIN="$(command -v python || command -v python3)"
-
-########################################
-# 日志 & 工具
-########################################
-log(){ echo "[$(date +'%F %T')] $*"; }
-die(){ echo "[$(date +'%F %T')] ❌ $*" >&2; exit 1; }
-
-ensure_dir_writable() {
-  local d="$1"
-  mkdir -p "$d" || die "创建目录失败：$d"
-  test -w "$d" || die "目录不可写：$d"
-  local tf="$d/.write_test_$$"; : > "$tf" 2>/dev/null || die "无法在 $d 写入"
-  rm -f "$tf" || true
-}
-
-########################################
-# 路径 & 依赖
-########################################
-SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
-SCRIPT_PATH="$(readlink -f "${BASH_SOURCE[0]}")"
-
-command -v ffmpeg  >/dev/null 2>&1 || die "未找到 ffmpeg，请先安装：sudo apt-get install -y ffmpeg 或 conda install -c conda-forge ffmpeg"
-command -v ffprobe >/dev/null 2>&1 || die "未找到 ffprobe，请先安装：sudo apt-get install -y ffmpeg 或 conda install -c conda-forge ffmpeg"
-
-export HAMER_DIR="${SCRIPT_DIR}/../hamer"
-ensure_dir_writable "$HAMER_DIR/_DATA/cache"
-export FVCORE_CACHE="$HAMER_DIR/_DATA/cache"
-export IOPATH_CACHE_DIR="$HAMER_DIR/_DATA/cache"
-
-SRC_DIR="/mnt/data_nas/guanfb/Pose/tiktok/rgb"
-OUT_IMG_ROOT="${SCRIPT_DIR}/../hamer_img"
-OUT_RES_ROOT="${SCRIPT_DIR}/../hamer_result"
-LOG_DIR="${SCRIPT_DIR}/hamer_log"
-STATUS_DIR="${SCRIPT_DIR}/.status_hamer"
-
-ensure_dir_writable "$OUT_IMG_ROOT"
-ensure_dir_writable "$OUT_RES_ROOT"
-ensure_dir_writable "$LOG_DIR"
-ensure_dir_writable "$STATUS_DIR"
-
-########################################
-# 离屏渲染（与单线程一致）
-########################################
-unset DISPLAY
-export LD_PRELOAD=${LD_PRELOAD:-/usr/lib/x86_64-linux-gnu/libstdc++.so.6}
-_has_libegl(){ ldconfig -p 2>/dev/null | grep -qi 'libEGL\.so'; }
-if _has_libegl; then
-  export PYOPENGL_PLATFORM=egl
-else
-  export PYOPENGL_PLATFORM=osmesa
-  export LIBGL_ALWAYS_SOFTWARE=1
-  export MESA_GL_VERSION_OVERRIDE=3.3
-  export MESA_GLSL_VERSION_OVERRIDE=330
-fi
-
-########################################
-# HaMeR 运行参数（保持一致）
-########################################
-BATCH_SIZE=48
-SIDE_VIEW=1
-FULL_FRAME=1   # 手部像素更高；要全幅改 1
-SAVE_MESH=1
-
-########################################
-# 并发/GPU 自动计算（按显存）
-########################################
-GPUS="${GPUS:-}"                     # 为空自动探测
-JOB_MEM_GB="${JOB_MEM_GB:-13}"       # 单任务显存估计
-RESERVE_GB="${RESERVE_GB:-4}"        # 固定预留
-RESERVE_RATIO="${RESERVE_RATIO:-0.15}" # 比例预留
-SKIP_IF_DONE="${SKIP_IF_DONE:-1}"
-
-if [[ -z "$GPUS" ]] && command -v nvidia-smi >/dev/null 2>&1; then
-  NGPU="$(nvidia-smi --query-gpu=index --format=csv,noheader | wc -l | awk '{print $1}')"
-  (( NGPU > 0 )) && GPUS="$(seq -s, 0 $((NGPU-1)))" || true
-fi
-
-gpu_total_mib(){ nvidia-smi --query-gpu=memory.total --format=csv,noheader,nounits -i "$1" 2>/dev/null | head -n1; }
-gpu_free_mib(){  nvidia-smi --query-gpu=memory.free  --format=csv,noheader,nounits -i "$1" 2>/dev/null | head -n1; }
-
-calc_slots(){
-  local gid="$1"
-  local total=$(gpu_total_mib "$gid"); local free=$(gpu_free_mib "$gid")
-  [[ -z "$total" || -z "$free" ]] && { echo 0; return; }
-  local job=$(( JOB_MEM_GB * 1024 ))
-  local reserve_by_ratio=$(awk -v t="$total" -v r="$RESERVE_RATIO" 'BEGIN{printf("%d", t*r)}')
-  local reserve_by_abs=$(( RESERVE_GB * 1024 ))
-  local reserve=$(( reserve_by_ratio > reserve_by_abs ? reserve_by_ratio : reserve_by_abs ))
-  local avail_free=$(( free - reserve )); (( avail_free < 0 )) && avail_free=0
-  local avail_total=$(( total - reserve )); (( avail_total < 0 )) && avail_total=0
-  local a=$(( avail_free / job )); local b=$(( avail_total / job ))
-  local slots=$(( a < b ? a : b )); (( slots < 0 )) && slots=0
-  echo "$slots"
-}
-
-GPU_LOCK_DIR="${SCRIPT_DIR}/.gpu_locks"
-ensure_dir_writable "$GPU_LOCK_DIR"
-declare -A GPU_SLOTS=()
-
-init_gpu_tokens(){
-  rm -f "${GPU_LOCK_DIR}/gpu"*".lock" 2>/dev/null || true
-  local total_slots=0 mapping=""
-  if [[ -n "$GPUS" ]]; then
-    IFS=',' read -r -a GPU_ARR <<<"$GPUS"
-    for gid in "${GPU_ARR[@]}"; do
-      local s; s="$(calc_slots "$gid")"
-      GPU_SLOTS["$gid"]="$s"
-      if (( s > 0 )); then
-        for ((i=1;i<=s;i++)); do : > "${GPU_LOCK_DIR}/gpu${gid}.${i}.lock"; done
-        total_slots=$(( total_slots + s ))
-        mapping+=" GPU${gid}:${s}"
-      else
-        mapping+=" GPU${gid}:0"
-      fi
-    done
-  fi
-  if [[ -z "${JOBS:-}" ]]; then
-    JOBS=$(( total_slots > 0 ? total_slots : 1 ))
-  fi
-  log "[GPU] 自动并发（单任务≈${JOB_MEM_GB}GB，预留=max(${RESERVE_GB}GB, ${RESERVE_RATIO}×总显存)）：${mapping}  → 总并发=${JOBS}"
-}
-init_gpu_tokens
-
-########################################
-# 进程组清理（强力中止）
-########################################
-declare -a CHILD_PGIDS=()
-ADD_PGID(){ CHILD_PGIDS+=("$1"); }
-run_pgroup(){
-  if command -v setsid >/dev/null 2>&1; then
-    setsid bash -c "$*" &
-    local pid=$!; ADD_PGID "$pid"; wait "$pid"; return $?
-  else
-    bash -c "$*"; return $?
-  fi
-}
-CLEANED=0
-cleanup_all(){
-  (( CLEANED )) && return 0
-  CLEANED=1
-  for pg in "${CHILD_PGIDS[@]:-}"; do [[ -n "$pg" ]] && kill -TERM -- "-${pg}" 2>/dev/null || true; done
-  sleep 0.5
-  for pg in "${CHILD_PGIDS[@]:-}"; do [[ -n "$pg" ]] && kill -KILL -- "-${pg}" 2>/dev/null || true; done
-}
-on_master_signal(){ cleanup_all; kill -TERM -- "-$$" 2>/dev/null || true; }
-on_worker_signal(){ cleanup_all; exit 130; }
-trap on_master_signal INT TERM
-
-########################################
-# GPU token
-########################################
-GPU_LOCK_FD=-1
-GPU_LOCK_FILE=""
-GPU_ID=""
-acquire_gpu(){
-  if [[ -z "$GPUS" ]]; then GPU_ID="cpu"; unset CUDA_VISIBLE_DEVICES; return 0; fi
-  IFS=',' read -r -a GPU_ARR <<<"$GPUS"
-  while :; do
-    for gid in "${GPU_ARR[@]}"; do
-      local slots="${GPU_SLOTS[$gid]:-0}"; (( slots<=0 )) && continue
-      for ((s=1;s<=slots;s++)); do
-        local f="${GPU_LOCK_DIR}/gpu${gid}.${s}.lock"
-        exec {fd}> "$f" || continue
-        if flock -n "$fd"; then
-          GPU_LOCK_FD="$fd"; GPU_LOCK_FILE="$f"; GPU_ID="$gid"; export CUDA_VISIBLE_DEVICES="$gid"; return 0
-        else
-          exec {fd}>&-
-        fi
-      done
-    done
-    sleep 0.2
-  done
-}
-release_gpu(){
-  if [[ "$GPU_ID" == "cpu" || -z "$GPUS" ]]; then return 0; fi
-  if [[ "$GPU_LOCK_FD" -ge 0 ]]; then
-    flock -u "$GPU_LOCK_FD" || true; eval "exec ${GPU_LOCK_FD}>&-" || true
-    GPU_LOCK_FD=-1; GPU_LOCK_FILE=""; GPU_ID=""
-  fi
-}
-
-########################################
-# —— 核心：单视频处理（日志实时，产物一致）——
-########################################
-process_one() {
-  trap on_worker_signal INT TERM
-
-  local vid="$1"
-  local base="$(basename "$vid")"
-  local stem="${base%.*}"
-
-  local ROOT="$OUT_IMG_ROOT/$stem"
-  local FRAMES="$ROOT/frames"
-  local HAMER_OUT="$ROOT/hamer_vis"
-  local FILLED="$ROOT/hamer_vis_all_filled"
-  local ALIGNED_COLOR="$ROOT/hamer_vis_color_aligned"
-  local OUT_MP4="$OUT_RES_ROOT/hamer_color_aligned_${stem}.mp4"
-  local LOGF="$LOG_DIR/${stem}.log"
-
-  # 跳过已完成（不写视频日志，仅做状态标记）
-  if (( SKIP_IF_DONE )) && [[ -s "$OUT_MP4" ]]; then
-    : > "${STATUS_DIR}/${stem}.skip"
-    return 0
-  fi
-
-  # ↓↓↓ 从这里开始写入该视频日志（行缓冲实时刷入）
-  {
-    log "开始处理：$base"
-
-    ensure_dir_writable "$ROOT"
-    ensure_dir_writable "$FRAMES"
-    ensure_dir_writable "$HAMER_OUT"
-    ensure_dir_writable "$FILLED"
-    ensure_dir_writable "$ALIGNED_COLOR"
-    ensure_dir_writable "$OUT_RES_ROOT"
-
-    pushd "$ROOT" >/dev/null
-    trap 'popd >/dev/null || true' RETURN
-
-    # 1) 抽帧 —— 无损 PNG（行缓冲）
-    local FPS_RAW
-    FPS_RAW=$(ffprobe -v error -select_streams v:0 -show_entries stream=r_frame_rate \
-              -of default=nokey=1:noprint_wrappers=1 "$vid")
-    stdbuf -oL -eL ffmpeg -y -i "$vid" -vsync 0 "$FRAMES/%06d.png"
-    local TOTAL
-    TOTAL=$(ls -1 "$FRAMES"/*.png 2>/dev/null | wc -l)
-    log "[$stem] 源帧数: $TOTAL  (FPS raw=$FPS_RAW)"
-
-    # 2) HaMeR 推理（无缓冲 Python；记录 GPU 分配/释放）
-    [[ -d "$HAMER_DIR" ]] || { : > "${STATUS_DIR}/${stem}.fail"; echo "HaMeR 目录不存在：$HAMER_DIR"; exit 1; }
-    acquire_gpu
-    if [[ "$GPU_ID" == "cpu" ]]; then
-      log "[GPU] 分配：CPU（无可用 GPU）"
-      echo "gpu=cpu" > "${STATUS_DIR}/${stem}.running"
-    else
-      log "[GPU] 分配：GPU ${GPU_ID}（token=${GPU_LOCK_FILE})"
-      echo "gpu=${GPU_ID}" > "${STATUS_DIR}/${stem}.running"
-    fi
-
-    pushd "$HAMER_DIR" >/dev/null
-    stdbuf -oL -eL "$PYTHON_BIN" -u demo.py \
-        --img_folder "$FRAMES" \
-        --out_folder "$HAMER_OUT" \
-        --batch_size "$BATCH_SIZE" \
-        $([[ $SIDE_VIEW -eq 1 ]]  && echo --side_view) \
-        $([[ $SAVE_MESH -eq 1 ]]  && echo --save_mesh) \
-        $([[ $FULL_FRAME -eq 1 ]] && echo --full_frame)
-    local rc=$?
-    popd >/dev/null
-
-    if [[ "$GPU_ID" != "cpu" ]]; then
-      log "[GPU] 释放：GPU ${GPU_ID}（token=${GPU_LOCK_FILE})"
-    fi
-    release_gpu
-    (( rc == 0 )) || { : > "${STATUS_DIR}/${stem}.fail"; rm -f "${STATUS_DIR}/${stem}.running"; exit 1; }
-
-    # 3) 补齐缺帧（无缓冲）
-    local EXT=""
-    if ls "$HAMER_OUT"/*_all.jpg >/dev/null 2>&1; then EXT="jpg"
-    elif ls "$HAMER_OUT"/*_all.png >/dev/null 2>&1; then EXT="png"
-    else EXT="png"; fi
-
-    "$PYTHON_BIN" -u - "$FRAMES" "$HAMER_OUT" "$FILLED" "$EXT" <<'PY'
-import os, sys, glob, shutil
-FRAMES, HAMER_OUT, FILLED, EXT = sys.argv[1:]
-imgs = sorted(glob.glob(os.path.join(FRAMES, '*.png')))
-N = len(imgs)
-if not EXT: EXT = 'png'
-os.makedirs(FILLED, exist_ok=True)
-for i in range(1, N+1):
-    s=f"{i:06d}"
-    src_all=os.path.join(HAMER_OUT, f"{s}_all.{EXT}")
-    dst_all=os.path.join(FILLED,    f"{s}_all.{EXT}")
-    if os.path.exists(src_all): shutil.copy2(src_all, dst_all)
-    else: shutil.copy2(os.path.join(FRAMES, f"{s}.png"), dst_all)
-print("[Info] 补齐到目录：", FILLED, flush=True)
-PY
-
-    # 4) 黑底 + 彩色（无缓冲）
-    if ls "$FILLED"/*_all.jpg >/dev/null 2>&1; then EXT="jpg"
-    elif ls "$FILLED"/*_all.png >/dev/null 2>&1; then EXT="png"
-    else { : > "${STATUS_DIR}/${stem}.fail"; rm -f "${STATUS_DIR}/${stem}.running"; echo "缺少 *_all.{jpg,png}"; exit 2; }; fi
-
-    "$PYTHON_BIN" -u - "$FRAMES" "$FILLED" "$ALIGNED_COLOR" "$EXT" <<'PY'
-import os, sys, glob
-import numpy as np
-from PIL import Image, ImageFilter
-FRAMES, FILLED, OUT, EXT = sys.argv[1:]
-os.makedirs(OUT, exist_ok=True)
-frames = sorted(glob.glob(os.path.join(FRAMES, '*.png')))
-N = len(frames)
-THR = 16
-def hsv_to_rgb_arr(h):
-    h6 = (h * 6.0).astype(np.float32); i = np.floor(h6).astype(np.int32) % 6; f = h6 - np.floor(h6)
-    v = np.ones_like(h, dtype=np.float32); s = np.ones_like(h, dtype=np.float32)
-    p=v*(1-s); q=v*(1-f*s); t=v*(1-(1-f)*s)
-    r=np.zeros_like(h, np.float32); g=np.zeros_like(h, np.float32); b=np.zeros_like(h, np.float32)
-    m0=(i==0); r[m0]=v[m0]; g[m0]=t[m0]; b[m0]=p[m0]
-    m1=(i==1); r[m1]=q[m1]; g[m1]=v[m1]; b[m1]=p[m1]
-    m2=(i==2); r[m2]=p[m2]; g[m2]=v[m2]; b[m2]=t[m2]
-    m3=(i==3); r[m3]=p[m3]; g[m3]=q[m3]; b[m3]=v[m3]
-    m4=(i==4); r[m4]=t[m4]; g[m4]=p[m4]; b[m4]=v[m4]
-    m5=(i==5); r[m5]=v[m5]; g[m5]=p[m5]; b[m5]=q[m5]
-    return np.stack([r,g,b], axis=2)
-for idx in range(1, N+1):
-    s=f"{idx:06d}"; src0=os.path.join(FRAMES, f"{s}.png"); src=os.path.join(FILLED, f"{s}_all.{EXT}"); dst=os.path.join(OUT, f"{s}_all.png")
-    im0=Image.open(src0).convert("RGB"); W,H=im0.size
-    if not os.path.exists(src): Image.new("RGB",(W,H),(0,0,0)).save(dst); continue
-    im=Image.open(src).convert("RGB")
-    if im.size!=(W,H): im=im.resize((W,H), Image.BILINEAR)
-    a=np.asarray(im, np.int16); b=np.asarray(im0, np.int16)
-    diff=np.mean(np.abs(a-b), axis=2).astype(np.uint8)
-    mask=(diff>THR).astype(np.uint8)*255
-    mask_img=Image.fromarray(mask).filter(ImageFilter.MinFilter(3))
-    mask_np=np.asarray(mask_img, np.uint8)
-    if mask_np.max()==0: Image.new("RGB",(W,H),(0,0,0)).save(dst); continue
-    ys=np.linspace(0,1,H,dtype=np.float32)[:,None]; hs=np.repeat(ys,W,axis=1)
-    h=0.66*(1.0-hs); color=hsv_to_rgb_arr(h)
-    gray=a.mean(axis=2).astype(np.float32)/255.0; shade=0.6+0.4*gray
-    color=(color*shade[...,None]); color_u8=(np.clip(color,0,1)*255).astype(np.uint8)
-    color_u8[mask_np==0]=0; Image.fromarray(color_u8,"RGB").save(dst)
-print("[Info] 彩色黑底输出：", OUT, flush=True)
-PY
-
-    # 5) 合成 mp4（用 -u 解析 FPS，ffmpeg 行缓冲）
-    local FPS
-    FPS=$("$PYTHON_BIN" -u - <<PY
-fr = """${FPS_RAW}"""
-try:
-    if "/" in fr:
-        n, d = fr.split("/")
-        print(float(n)/float(d))
-    else:
-        print(float(fr))
-except Exception:
-    print(30.0)
-PY
-)
-    stdbuf -oL -eL ffmpeg -y -framerate "$FPS" -start_number 1 -i "$ALIGNED_COLOR/%06d_all.png" -c:v libx264 -pix_fmt yuv420p "$OUT_MP4"
-
-    log "完成：$OUT_MP4"
-  } >>"$LOGF" 2>&1
-
-  : > "${STATUS_DIR}/${stem}.done"
-  rm -f "${STATUS_DIR}/${stem}.running" "${STATUS_DIR}/${stem}.fail" "${STATUS_DIR}/${stem}.skip" 2>/dev/null || true
-  return 0
-}
-
-########################################
-# 单文件模式（给并行 worker 调用）
-########################################
-if [[ "${1:-}" == "--one" ]]; then
-  shift
-  trap on_worker_signal INT TERM
-  trap 'cleanup_all' EXIT
-  process_one "$@"
-  exit $?
-fi
-
-########################################
-# 主控：扫描 & 并行 + 终端实时进度
-########################################
-log "扫描目录：$SRC_DIR"
-shopt -s nullglob
-mapfile -d '' VIDEOS < <(find "$SRC_DIR" -maxdepth 1 -type f -iname '*.mp4' -print0 | sort -z)
-TOTAL=${#VIDEOS[@]}
-if (( TOTAL == 0 )); then log "未发现 mp4 文件，退出。"; exit 0; fi
-
-# 进度刷新（每 1.5s）
-progress_loop() {
-  tput civis 2>/dev/null || true
-  while :; do
-    local done fail skip run gpumap c
-    done=$(ls "$STATUS_DIR"/*.done 2>/dev/null | wc -l | awk '{print $1}')
-    fail=$(ls "$STATUS_DIR"/*.fail 2>/dev/null | wc -l | awk '{print $1}')
-    skip=$(ls "$STATUS_DIR"/*.skip 2>/dev/null | wc -l | awk '{print $1}')
-    run=$(ls "$STATUS_DIR"/*.running 2>/dev/null | wc -l | awk '{print $1}')
-    gpumap=""
-    if [[ -n "$GPUS" ]]; then
-      IFS=',' read -r -a GPU_ARR <<<"$GPUS"
-      for gid in "${GPU_ARR[@]}"; do
-        c=$(grep -h "^gpu=${gid}$" -s "$STATUS_DIR"/*.running 2>/dev/null | wc -l | awk '{print $1}')
-        gpumap+=" GPU${gid}:${c}"
-      done
-    else
-      gpumap+=" CPU:${run}"
-    fi
-    printf "\r[%s] Progress: %d/%d | Done:%d | Skip:%d | Run:%d | Fail:%d%s" \
-      "$(date +'%H:%M:%S')" "$((done+skip+fail))" "$TOTAL" "$done" "$skip" "$run" "$fail" "$gpumap"
-    if (( done+skip+fail >= TOTAL )) && (( run == 0 )); then
-      printf "\n"; break
-    fi
-    sleep 1.5
-  done
-  tput cnorm 2>/dev/null || true
-}
-progress_loop & PROG_PID=$!
-
-# 并行启动（parallel 优先，否则 xargs）
-if command -v parallel >/dev/null 2>&1; then
-  printf '%s\0' "${VIDEOS[@]}" \
-    | parallel -0 -P "${JOBS}" --no-run-if-empty --halt now,fail=1 \
-        bash "$SCRIPT_PATH" --one {}
-else
-  printf '%s\0' "${VIDEOS[@]}" \
-    | xargs -0 -n1 -P "${JOBS}" -I{} bash "$SCRIPT_PATH" --one "{}"
-fi
-
-wait "$PROG_PID" 2>/dev/null || true
-
-# 汇总
-DONE=$(ls "$STATUS_DIR"/*.done 2>/dev/null | wc -l | awk '{print $1}')
-FAIL=$(ls "$STATUS_DIR"/*.fail 2>/dev/null | wc -l | awk '{print $1}')
-SKIP=$(ls "$STATUS_DIR"/*.skip 2>/dev/null | wc -l | awk '{print $1}')
-echo "==============================="
-echo "🎯 完成：成功 $DONE ；失败 $FAIL ；跳过 $SKIP"
-echo "📂 结果目录：$OUT_RES_ROOT"
-echo "🗒 日志目录：$LOG_DIR"
-echo "==============================="
-
-cleanup_all