macOSのキャッシュ有無におけるストレージ性能を視覚化。自作スクリプトで見るApple Siliconの物理特性とインメモリの実効レート

#!/bin/zsh

# =======================================================================
# Script Name : mac_storage_benchmark.sh
# Version     : 1.0.0 (Enterprise Refined Edition)
# License     : MIT License (Copyright (c) 2026 ohllengeapplication.com 管理人)
# Description : macOS専用 ストレージ物理・キャッシュ体感性能プロファイラー
#  【免責事項】
#   本スクリプトの使用によるデータ損失やシステム不具合等の損害について、
#   作者は一切の責任を負いません。すべて自己責任でご利用ください。
# =======================================================================
#
# 【概要 / Description】
#   本ツールは、プロセス生成によるオーバーヘッドやOSキャッシュの影響をコード
#   レベルで排除、あるいはコントロールしてストレージ本来の物理的な実効性能を
#   客観的に捉えるために設計された、macOS専用の高精度な性能プロファイラーです。
# 
#   連続I/O（シーケンシャル）およびマルチスレッド分散シークI/O（ランダム4K）の
#   負荷テストを通じ、macOSの強力なバッファリング効果（インメモリレート）と、
#   それらを完全にパージしたストレージ本来のハードウェア特性（物理層実効レート）を
#   厳密に仕分け、システム全体の協調動作の構造を正確に可視化します。
#
# 【本スクリプトの特徴 / Key Features】
#   1. デュアルフェーズ測定 : OSキャッシュを強制解放した「物理層の素の速度」と、
#                            キャッシュを効かせた「実用上の体感速度」を分離して測定可能。
#   2. CUI/CLI自動化対応    : 画面操作が不要なため、複数パスの連続測定や定期バッチ処理、
#                            SSH経由で遠隔地にあるMac mini等の測定にも使えます。
#   3. 非圧縮データテスト   : コントローラーによるインライン圧縮が効かない擬似乱数データを
#                            低レイヤ（Perl内製I/O）で高速処理し、純粋な物理限界を正確に評価。
#
# 【使用方法 / Usage】
#   本スクリプトは、正確なディスクキャッシュ強制解放（purge）および
#   システム情報の完全な抽出を行うため、管理者権限（sudo）と環境変数の引き継ぎ（-E）が必要です。
#
#   $ sudo -E ./mac_storage_benchmark.sh <測定対象パス1> [測定対象パス2] ...
#
#   (例) 内蔵SSDのホームディレクトリと外付けSSDを同時に測定する場合:
#   $ sudo -E ./mac_storage_benchmark.sh ~/ /Volumes/ExternalSSD
#
# 【出力および処理仕様 / Outputs & Specifications】
#   1. 統計データの永続化 : 実行毎に詳細テキストログ(.log)と、時系列比較用のCSV(.csv)を自動生成。
#   2. 高精度な統計抽出   : 指定したサンプリング回数の平均・最高・最低レートを自動算出。
#   3. 安全容量ガード     : 安全マージンを計算し、ストレージ溢れを未然に防ぐ自動スキップ。
#   4. 自動クリーンアップ : 測定に用いた一時ファイル・ディレクトリは処理終了時に自動消去。
# =======================================================================

# ーー 測定エンジン静的パラメータ設定（マジックナンバー徹底排除） ーー
typeset -r -i BLOCK_SIZE_KB=4          # ランダムI/Oのブロックサイズ (KB)
typeset -r -i RANDOM_TEST_BLOCKS=1000  # 1スレッドあたりのI/O実行回数 (4000回フォークバグ対策済)
typeset -r -i THREADS=4                # マルチスレッド並列実行数
typeset -r -i LARGE_FILE_SIZE=1024     # シーケンシャルテストファイルサイズ (MB)
typeset -r -i ITERATIONS=3             # サンプリング合計測定回数
typeset -r -i ENABLE_CACHE_TEST=1      # 1=キャッシュ有効テストも実行、0=解放ありのみ
typeset -r    SAFETY_MULTIPLIER="2.5"  # 必要容量の安全マージン係数

# ーー 環境パスの安全なクリーン復旧 ーー
export PATH="/usr/bin:/bin:/usr/sbin:/sbin:/usr/local/bin:$PATH"

# ーー 実行権限および引数バリデーション ーー
if [ "$#" -lt 1 ]; then
  echo "Error: 測定対象パスを指定してください。"
  echo "Usage: sudo -E $0 <測定対象パス1> [測定対象パス2] ..."
  exit 1
fi

if [ "$EUID" -ne 0 ]; then
  echo "Error: 権限が不足しています。sudo -E $0 <パス> で実行してください。"
  exit 1
fi

# ーー ログファイル・CSVファイルの動的パス設定 ーー
typeset -r LOG_DIR=$(dirname "${0:a}")
typeset -r CURRENT_DATE=$(date +%Y%m%d)
typeset -r LOG_FILE="${LOG_DIR}/benchmark_${CURRENT_DATE}.log"
typeset -r CSV_FILE="${LOG_DIR}/benchmark_${CURRENT_DATE}.csv"

# 出力ディレクトリの作成
mkdir -p "$LOG_DIR" 2>/dev/null

# CSVヘッダーの永続化初期化
if [ ! -f "$CSV_FILE" ]; then
  echo "Timestamp,Model,TargetLabel,Path,State,SeqWrite_Zero_Avg(MB/s),SeqWrite_Zero_Max(MB/s),SeqWrite_Zero_Min(MB/s),SeqWrite_Rand_Avg(MB/s),SeqWrite_Rand_Max(MB/s),SeqWrite_Rand_Min(MB/s),SeqRead_Zero_Avg(MB/s),SeqRead_Zero_Max(MB/s),SeqRead_Zero_Min(MB/s),SeqRead_Rand_Avg(MB/s),SeqRead_Rand_Max(MB/s),SeqRead_Rand_Min(MB/s),RandWrite_Avg(MB/s),RandWrite_Max(MB/s),RandWrite_Min(MB/s),RandWrite_IOPS,RandRead_Avg(MB/s),RandRead_Max(MB/s),RandRead_Min(MB/s),RandRead_IOPS" > "$CSV_FILE"
fi
# =======================================================================
# ーーー macOSシステムスペック動的抽出 ーーー
# =======================================================================
typeset -r mac_model=$(sysctl -n hw.model 2>/dev/null)
typeset -r mac_cpu=$(sysctl -n machdep.cpu.brand_string 2>/dev/null || sysctl -n hw.brand_string 2>/dev/null)
typeset -r mac_total_cores=$(sysctl -n hw.ncpu 2>/dev/null)
typeset -r mac_p_cores=$(sysctl -n hw.perflevel0.physicalcpu 2>/dev/null)
typeset -r mac_e_cores=$(sysctl -n hw.perflevel1.physicalcpu 2>/dev/null)
typeset -r mac_mem_gb=$(( $(sysctl -n hw.memsize 2>/dev/null) / 1024 / 1024 / 1024 ))
typeset -r mac_os_name=$(sw_vers -productName 2>/dev/null)
typeset -r mac_os_ver=$(sw_vers -productVersion 2>/dev/null)
typeset -r mac_os_build=$(sw_vers -buildVersion 2>/dev/null)

typeset val_smart
val_smart=$(diskutil info / 2>/dev/null | awk -F': ' '/SMART Status/ {print $2; exit}' | xargs)
[[ -z "$val_smart" ]] && val_smart="Verified"

typeset mac_trim_status
mac_trim_status=$(system_profiler SPStorageDataType 2>/dev/null | awk -F': ' '/TRIM Support/ {print $2; exit}' | xargs)
[[ -z "$mac_trim_status" ]] && mac_trim_status="Unknown / N/A"

typeset mac_controller_name
mac_controller_name=$(system_profiler SPNVMEDataType 2>/dev/null | awk -F': ' '/Device Name|Model/ {print $2; exit}' | xargs)
[[ -z "$mac_controller_name" ]] && mac_controller_name="Apple NVMe Controller Native"

# レポートヘッダー出力関数
print_header() {
  echo "=================================================="
  echo " STORAGE BENCHMARK REPORT (Dual-Pattern Full Stats)"
  echo "--------------------------------------------------"
  echo " [Execution Date] : $(date '+%Y-%m-%d %H:%M:%S')"
  echo " [System Information]"
  echo "   Model    : ${mac_model}"
  echo "   CPU      : ${mac_cpu}"
  echo "   Topology : Performance ${mac_p_cores:-0} Cores / Efficiency ${mac_e_cores:-0} Cores (Total ${mac_total_cores} Threads)"
  echo "   Memory   : ${mac_mem_gb} GB Unified Memory"
  echo "   OS       : ${mac_os_name} ${mac_os_ver} (Build ${mac_os_build})"
  echo "--------------------------------------------------"
  echo " [Hardware Specs]"
  echo "   S.M.A.R.T. Health: ${val_smart}"
  echo "   TRIM Support     : ${mac_trim_status}"
  echo "   Controller Type  : ${mac_controller_name}"
  echo "--------------------------------------------------"
  echo " [Execution Specs]"
  echo "   Large File Size  : ${LARGE_FILE_SIZE} MB"
  echo "   Random Block     : ${BLOCK_SIZE_KB} KB"
  echo "   Concurrency      : ${THREADS} Parallel Threads"
  echo "   Sampling Engine  : Iterations=${ITERATIONS}"
  echo "   Mode Switching   : Cache-Test Execution = ${ENABLE_CACHE_TEST}"
  echo "=================================================="
}

# キャッシュ解放関数（物理性能測定用）
clear_cache() {
  sync && sync && purge
  sleep 3
}
# =======================================================================
# ーーー コア計測パイプライン（計測エンジン） ーーー
# =======================================================================
execute_core_loop() {
  local target_path="$1"
  local test_dir="$2"
  local target_label="$3"
  local state_label="$4"       
  local -i trigger_purge="$5"  

  local file_seq_zero="${test_dir}/seq_zero_${state_label}.dat"
  local file_seq_rand="${test_dir}/seq_rand_${state_label}.dat"

  local -F total_rnd_mb
  (( total_rnd_mb = (BLOCK_SIZE_KB * RANDOM_TEST_BLOCKS * THREADS) / 1024.0 ))

  local -F sum_w_zero=0.0 sum_w_rand=0.0 sum_r_zero=0.0 sum_r_rand=0.0 sum_rw=0.0 sum_rr=0.0
  local -F peak_w_zero=0.0 peak_w_rand=0.0 peak_r_zero=0.0 peak_r_rand=0.0 peak_rw=0.0 peak_rr=0.0
  local -F bot_w_zero=999999.0 bot_w_rand=999999.0 bot_r_zero=999999.0 bot_r_rand=999999.0 bot_rw=999999.0 bot_rr=999999.0

  local -i loop
  for (( loop=1; loop<=ITERATIONS; loop++ )); do
printf "\r\033[K  ⏱️  プロファイリング中... %s (%d/%d)\033[K" "$state_label" "$loop" "$ITERATIONS" >/dev/tty
    
    # 1-A. Sequential Write (Zero埋め)
    (( trigger_purge == 1 )) && clear_cache
    local t_start=$(perl -MTime::HiRes=time -e 'print time')
    dd if=/dev/zero of="$file_seq_zero" bs=1M count=$LARGE_FILE_SIZE conv=sync status=none 2>/dev/null && sync
    local t_end=$(perl -MTime::HiRes=time -e 'print time')
    local -F cur_w_zero=$(( (LARGE_FILE_SIZE * 1.0) / (t_end - t_start) ))
    sum_w_zero+=$cur_w_zero
    (( cur_w_zero > peak_w_zero )) && peak_w_zero=$cur_w_zero
    (( cur_w_zero < bot_w_zero )) && bot_w_zero=$cur_w_zero

    # 1-B. Sequential Write (非圧縮リアルランダム)
    (( trigger_purge == 1 )) && clear_cache
    t_start=$(perl -MTime::HiRes=time -e 'print time')
    perl -e '
      open(my $fh, ">", "'"${file_seq_rand}"'") or die $!;
      my $buf = pack("C*", map { int(rand(256)) } 1..1048576);
      for (1..'"${LARGE_FILE_SIZE}"') { syswrite($fh, $buf); }
      close($fh);
    ' && sync
    t_end=$(perl -MTime::HiRes=time -e 'print time')
    local -F cur_w_rand=$(( (LARGE_FILE_SIZE * 1.0) / (t_end - t_start) ))
    sum_w_rand+=$cur_w_rand
    (( cur_w_rand > peak_w_rand )) && peak_w_rand=$cur_w_rand
    (( cur_w_rand < bot_w_rand )) && bot_w_rand=$cur_w_rand

    # 2-A. Sequential Read (Zeroファイル)
    (( trigger_purge == 1 )) && clear_cache
    t_start=$(perl -MTime::HiRes=time -e 'print time')
    dd if="$file_seq_zero" of=/dev/null bs=1M count=$LARGE_FILE_SIZE status=none 2>/dev/null
    t_end=$(perl -MTime::HiRes=time -e 'print time')
    local -F cur_r_zero=$(( (LARGE_FILE_SIZE * 1.0) / (t_end - t_start) ))
    sum_r_zero+=$cur_r_zero
    (( cur_r_zero > peak_r_zero )) && peak_r_zero=$cur_r_zero
    (( cur_r_zero < bot_r_zero )) && bot_r_zero=$cur_r_zero

    # 2-B. Sequential Read (純ストレージリード)
    (( trigger_purge == 1 )) && clear_cache
    t_start=$(perl -MTime::HiRes=time -e 'print time')
    dd if="$file_seq_rand" of=/dev/null bs=1M count=$LARGE_FILE_SIZE status=none 2>/dev/null
    t_end=$(perl -MTime::HiRes=time -e 'print time')
    local -F cur_r_rand=$(( (LARGE_FILE_SIZE * 1.0) / (t_end - t_start) ))
    sum_r_rand+=$cur_r_rand
    (( cur_r_rand > peak_r_rand )) && peak_r_rand=$cur_r_rand
    (( cur_r_rand < bot_r_rand )) && bot_r_rand=$cur_r_rand

    # 3. Random Write (マルチスレッド分散シーク書き込み)
    (( trigger_purge == 1 )) && clear_cache
    local -i max_blocks=$(( LARGE_FILE_SIZE * (1024 / BLOCK_SIZE_KB) ))
    t_start=$(perl -MTime::HiRes=time -e 'print time')
    local -i t
    for (( t=1; t<=THREADS; t++ )); do
      perl -e '
        open(my $fh, "+<", "'"${file_seq_rand}"'") or die $!;
        my $block = pack("C*", map { int(rand(256)) } 1..'"$((BLOCK_SIZE_KB * 1024))"');
        for (1..'"${RANDOM_TEST_BLOCKS}"') {
            my $seek_pos = int(rand('"${max_blocks}"')) * '"$((BLOCK_SIZE_KB * 1024))"';
            sysseek($fh, $seek_pos, 0);
            syswrite($fh, $block);
        }
        close($fh);
      ' &
    done
    wait && sync
    t_end=$(perl -MTime::HiRes=time -e 'print time')
    local -F cur_rw=$(( total_rnd_mb / (t_end - t_start) ))
    sum_rw+=$cur_rw
    (( cur_rw > peak_rw )) && peak_rw=$cur_rw
    (( cur_rw < bot_rw )) && bot_rw=$cur_rw

    # 4. Random Read (マルチスレッド分散シーク読み込み)
    (( trigger_purge == 1 )) && clear_cache
    t_start=$(perl -MTime::HiRes=time -e 'print time')
    for (( t=1; t<=THREADS; t++ )); do
      perl -e '
        open(my $fh, "<", "'"${file_seq_rand}"'") or die $!;
        my $buf;
        for (1..'"${RANDOM_TEST_BLOCKS}"') {
            my $skip_pos = int(rand('"${max_blocks}"')) * '"$((BLOCK_SIZE_KB * 1024))"';
            sysseek($fh, $skip_pos, 0);
            sysread($fh, $buf, '"$((BLOCK_SIZE_KB * 1024))"');
        }
        close($fh);
      ' &
    done
    wait
    t_end=$(perl -MTime::HiRes=time -e 'print time')
    local -F cur_rr=$(( total_rnd_mb / (t_end - t_start) ))
    sum_rr+=$cur_rr
    (( cur_rr > peak_rr )) && peak_rr=$cur_rr
    (( cur_rr < bot_rr )) && bot_rr=$cur_rr

    rm -f "${test_dir}"/*.dat 2>/dev/null
  done

  printf "\r\033[K" >/dev/tty
  
  local -F avg_w_zero=$(( sum_w_zero / ITERATIONS ))
  local -F avg_w_rand=$(( sum_w_rand / ITERATIONS ))
  local -F avg_r_zero=$(( sum_r_zero / ITERATIONS ))
  local -F avg_r_rand=$(( sum_r_rand / ITERATIONS ))
  local -F avg_rw=$(( sum_rw / ITERATIONS ))
  local -F avg_rr=$(( sum_rr / ITERATIONS ))

  local -i iops_avg_w=$(( (avg_rw * 1024) / BLOCK_SIZE_KB ))
  local -i iops_avg_r=$(( (avg_rr * 1024) / BLOCK_SIZE_KB ))

  {
    echo "  📊 [連続I/O（シーケンシャル性能）- ${state_label}]"
    printf "    - インライン圧縮データ (書き込み): 平均 %8.2f MB/s | 最高 %8.2f MB/s | 最低 %8.2f MB/s\n" $avg_w_zero $peak_w_zero $bot_w_zero
    printf "    - 非圧縮リアルランダム (書き込み): 平均 %8.2f MB/s | 最高 %8.2f MB/s | 最低 %8.2f MB/s\n" $avg_w_rand $peak_w_rand $bot_w_rand
    printf "    - インライン圧縮データ (読み込み): 平均 %8.2f MB/s | 最高 %8.2f MB/s | 最低 %8.2f MB/s\n" $avg_r_zero $peak_r_zero $bot_r_zero
    printf "    - 非圧縮リアルランダム (読み込み): 平均 %8.2f MB/s | 最高 %8.2f MB/s | 最低 %8.2f MB/s\n" $avg_r_rand $peak_r_rand $bot_r_rand
    echo "  📊 [ランダムI/O（分散シーク性能）- ${state_label}]"
    printf "    - マルチスレッド並行上書き   (並列%d): 平均 %8.2f MB/s | 最高 %8.2f MB/s | 最低 %8.2f MB/s [ %5d IOPS ]\n" $THREADS $avg_rw $peak_rw $bot_rw $iops_avg_w
    printf "    - マルチスレッド並行読み込み (並列%d): 平均 %8.2f MB/s | 最高 %8.2f MB/s | 最低 %8.2f MB/s [ %5d IOPS ]\n" $THREADS $avg_rr $peak_rr $bot_rr $iops_avg_r
    echo ""
  } | tee -a "$LOG_FILE"

  local timestamp=$(date '+%Y-%m-%d %H:%M:%S')
  printf "%s,%s,%s,\"%s\",\"%s\",%.2f,%.2f,%.2f,%.2f,%.2f,%.2f,%.2f,%.2f,%.2f,%.2f,%.2f,%.2f,%.2f,%.2f,%.2f,%d,%.2f,%.2f,%.2f,%d\n" \
    "$timestamp" "$mac_model" "$target_label" "$target_path" "$state_label" \
    $avg_w_zero $peak_w_zero $bot_w_zero \
    $avg_w_rand $peak_w_rand $bot_w_rand \
    $avg_r_zero $peak_r_zero $bot_r_zero \
    $avg_r_rand $peak_r_rand $bot_r_rand \
    $avg_rw $peak_rw $bot_rw $iops_avg_w \
    $avg_rr $peak_rr $bot_rr $iops_avg_r >> "$CSV_FILE"
}

# =======================================================================
# ーーー パスターゲットオーケストレーター ーーー
# =======================================================================
measure_target() {
  local target_path="$1"
  local target_label="$2"
  
  {
    echo "\n▶ [Analyzing Enterprise Workload] ${target_label}"
    echo "  (Path: ${target_path})"
  } | tee -a "$LOG_FILE"
  
  local test_dir="${target_path}/.m5_iobench_tmp_$(date +%H%M%S)"
  mkdir -p "$test_dir" 2>/dev/null
  if [ ! -w "$test_dir" ]; then
    echo "  [INFO] 書き込み権限がないため測定をスキップします。" | tee -a "$LOG_FILE"
    return 1
  fi

  # ーー 空き容量ガード（Zshのint関数エラーを完全修正） ーー
  local -i avail_mb=$(( $(df -kP "$target_path" | awk 'NR==2 {print $4}') / 1024 ))
  local -i multiplier=1
  (( ENABLE_CACHE_TEST == 1 )) && multiplier=2
  
  # 浮動小数点を整数変数に代入することで、Zshネイティブに安全な型丸め（キャスト）を実行
  local -F required_mb_float=$(( LARGE_FILE_SIZE * multiplier * SAFETY_MULTIPLIER ))
  local -i required_mb_int=$required_mb_float
  local -i required_mb=$(( required_mb_int + 100 ))

  if (( avail_mb < required_mb )); then
    {
      echo "  ❌ [ERROR] ストレージの空き容量が不足しているため、測定をスキップします。"
      echo "    - 測定対象パス : ${target_path}"
      echo "    - 現在の空き容量: ${avail_mb} MB"
      echo "    - 必要最小容量  : ${required_mb} MB"
    } | tee -a "$LOG_FILE"
    rm -rf "$test_dir" 2>/dev/null
    return 1
  fi

  # パターン1: キャッシュ解放あり (物理性能)
  execute_core_loop "$target_path" "$test_dir" "$target_label" "キャッシュ無効状態（物理層実効レート）" 1

  # パターン2: キャッシュ解放なし (メモリ性能)
  if (( ENABLE_CACHE_TEST == 1 )); then
    echo "" | tee -a "$LOG_FILE"
    execute_core_loop "$target_path" "$test_dir" "$target_label" "キャッシュ有効状態（インメモリレート）" 0
  fi

  rm -rf "$test_dir" 2>/dev/null
}

# =======================================================================
# ーーー エントリポイント (メイン実行ルーチン) ーーー
# =======================================================================
print_header | tee -a "$LOG_FILE"

typeset -i target_idx=1
typeset arg

for arg in "$@"; do
  if [ -d "$arg" ]; then
    local abs_arg="${arg:a}"
    local label="Target-${target_idx}"

    # 精密な前方一致・完全一致の分類条件式
    if [[ "$abs_arg" =~ "RAMDisk" ]]; then
      label="RAMDisk"
    elif [[ "$abs_arg" == "$(cd ~ 2>/dev/null && pwd)" ]]; then
      label="Internal-SSD(Home)"
    elif [[ "$abs_arg" == "/" ]]; then
      label="Internal-Macintosh_HD"
    elif [[ "$abs_arg" == "$(pwd)" ]]; then
      label="Internal-SSD(Current)"
    elif [[ "$abs_arg" =~ "^/Volumes/" ]]; then
      label="External-[${abs_arg#/Volumes/}]"
    fi

    measure_target "$abs_arg" "$label"
    target_idx=$((target_idx + 1))
  else
    echo "\n[WARNING] 無効なディレクトリパスをスキップしました: $arg" | tee -a "$LOG_FILE"
  fi
done

{
  echo "\n=================================================="
  echo " フルスタッツ・性能プロファイリング診断が完了しました。"
  echo " [LOG SAVED] : ${LOG_FILE}"
  echo " [CSV SAVED] : ${CSV_FILE}"
  echo "=================================================="
} | tee -a "$LOG_FILE"

exit 0

# =======================================================================
# ーーー エントリポイント (メイン実行ルーチン) ーーー
# =======================================================================
print_header | tee -a "$LOG_FILE"

typeset -i target_idx=1
typeset arg

for arg in "$@"; do
  if [ -d "$arg" ]; then
    local abs_arg="${arg:a}"
    local label="Target-${target_idx}"

    # 精密な前方一致・完全一致の分類条件式
    if [[ "$abs_arg" =~ "RAMDisk" ]]; then
      label="RAMDisk"
    elif [[ "$abs_arg" == "$(cd ~ 2>/dev/null && pwd)" ]]; then
      label="Internal-SSD(Home)"
    elif [[ "$abs_arg" == "/" ]]; then
      label="Internal-Macintosh_HD"
    elif [[ "$abs_arg" == "$(pwd)" ]]; then
      label="Internal-SSD(Current)"
    elif [[ "$abs_arg" =~ "^/Volumes/" ]]; then
      label="External-[${abs_arg#/Volumes/}]"
    fi

    measure_target "$abs_arg" "$label"
    target_idx=$((target_idx + 1))
  else
    echo "\n[WARNING] 無効なディレクトリパスをスキップしました: $arg" | tee -a "$LOG_FILE"
  fi
done

{
  echo "\n=================================================="
  echo " フルスタッツ・性能プロファイリング診断が完了しました。"
  echo " [LOG SAVED] : ${LOG_FILE}"
  echo " [CSV SAVED] : ${CSV_FILE}"
  echo "=================================================="
} | tee -a "$LOG_FILE"

exit 0