From 33bef36d1639e908aac74446b3c0e8ed61feb6a6 Mon Sep 17 00:00:00 2001 From: AskaEth Date: Wed, 11 Nov 2026 18:14:19 +0800 Subject: [PATCH] =?UTF-8?q?fix(audiod):=20M50=20=E8=93=9D=E7=89=99?= =?UTF-8?q?=E8=BE=93=E5=87=BA=E7=AB=AF=E5=88=B0=E7=AB=AF=20=E2=80=94=20?= =?UTF-8?q?=E5=86=85=E8=81=94=20DEV/CODEC=20=E6=89=93=E5=BC=80=20+=20?= =?UTF-8?q?=E5=A4=B1=E8=B4=A5=E5=BF=85=E5=9B=9E=E8=90=BD=20DAC=20+=20MAC?= =?UTF-8?q?=20=E8=A7=A3=E6=9E=90=E4=BF=AE=E6=AD=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit ① ALSA 正确用法（核心）：不再写 /usr/data/alsa.conf（HiBy 播放器数据文件、语法非法、 libasound 从不加载，改它对解析零影响）。改为 snd_pcm_open("bluealsa:DEV=, PROFILE=a2dp,CODEC=")，参数名严格取 /etc/alsa/conf.d/20-bluealsa.conf 的 pcm.bluealsa @args[DEV PROFILE CODEC VOL SOFTVOL DELAY SRV]（实测未知参数会被 alsa-lib 拒绝）；删掉 bt_apply_device_conf/bt_apply_codec_conf 两条改写分支。 ② 硬 bug：bt_dev_detect_mac() 旧逻辑取端点 token「最后一个 '/' 之后」——真机 bluealsa-cli list-pcms 输出是 D-Bus 路径 /org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/ a2dpsrc/source，旧代码会把 "source" 当 MAC（旧单测喂的是人造输入所以一直是绿的）。 改按 dev_XX_XX_XX_XX_XX_XX 段解析，兼容老式 a2dpsrc/。 ③ codec：settings bt.codec 经 bt_dev_codec_token() 归一成 bluealsa canonical 名 （v4.1.1 a2dp-codecs.c 别名表，strcasecmp）；auto/未知 → unchanged（不干预协商）。 ④ 失败必回落（硬验收）：新增 BT_ST_IDLE/OK/FAIL 状态机 —— 无端点/未连接/set_params 失败/写路径致命错（ENODEV 等）都回落 DAC 继续出声，绝不整机静音；回落前同步武装 numid=9（hbc3000 未烧+enable 开 PCM 会楔死整机）；STATE 增 bt=/btdev=/btcodec= 三键供面板显示「输出=蓝牙(失败)」，volctl 回落时报 dac。 ⑤ 防重试风暴：只在开流/重配边界重试，指数退避 2s→60s（bt_dev_should_try），写循环内 绝不重试；用户显式切目标才清退避。 ⑥ 音量：BT 真走 A2DP 时仍不下发 DAC 反转（回归确认），回落 DAC 时按 DAC 音量控； AVRCP 一键置最大从 100 改 127（bluealsa-cli volume 满量程 [0,127]，旧值只到 79%）。 ⑦ build_audiod.sh：ROOT/REPO 自动推导，ZIG/CC/LIBBT/ASOUND_SRC 可环境变量覆盖（旧 hiby_os_crack 路径在多数 checkout 里不存在），宿主链接 -l:libasound.so.2 失败退 -lasound；保留 M43 的 meow_audio time32 cli 目标。 宿主：test_bt_dev 51/51（真机 D-Bus 路径格式/别名表/退避），test_audiod_host 109/0， 0 warning。真机：新二进制 glibc-dynamic 上机正常，DAC 出声回归通过，无端点回落 DAC 出声（played/rms 实证），/usr/data/alsa.conf 全流程零写入；耳机出声一项待耳机上电。 不提交二进制、不改 fw_content.conf 钉值（按塔交付形态政策，由 M51 统一重编）。 --- patch_v2/meow_audiod/bt_dev.c | 265 ++++++++++------- patch_v2/meow_audiod/bt_dev.h | 58 +++- patch_v2/meow_audiod/build_audiod.sh | 54 +++- patch_v2/meow_audiod/meow_audiod.c | 365 ++++++++++++++---------- patch_v2/meow_audiod/test_audiod_host.c | 5 + patch_v2/meow_audiod/test_bt_dev.c | 197 ++++++++----- 6 files changed, 605 insertions(+), 339 deletions(-) diff --git a/patch_v2/meow_audiod/bt_dev.c b/patch_v2/meow_audiod/bt_dev.c index 2d1f059..2634fa9 100644 --- a/patch_v2/meow_audiod/bt_dev.c +++ b/patch_v2/meow_audiod/bt_dev.c @@ -1,18 +1,83 @@ -/* bt_dev.c — 蓝牙 A2DP 设备自识别（纯逻辑实现，见 bt_dev.h 契约）。 +/* bt_dev.c — 蓝牙 A2DP 端点选择 + PCM 名构造 + 回落退避（纯逻辑实现，见 bt_dev.h 契约）。 * * 纯 libc（string / stdlib），无任何 meow_* 调用、无 popen、无文件 I/O —— meow_audiod 负责 - * 读取 /usr/data/alsa.conf、执行 `bluealsa-cli list-pcms` 及写回。宿主单测零链路重。 + * 执行 `bluealsa-cli list-pcms`、调用 libasound 及维护运行时状态。 */ #include "bt_dev.h" #include #include #include +#include + +/* 是否 a2dpsrc / a2dp_source 端点行（bluealsa 4.1.1 list-pcms 的端点头） */ +static int is_src_line(const char *p) +{ + return strstr(p, "a2dpsrc") != NULL || strstr(p, "a2dp_source") != NULL; +} + +/* 从 D-Bus 对象路径取 MAC。bluealsa 4.1.1 的 PCM 路径是 + * /org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsrc/source + * （dev_%.2X_%.2X_%.2X_%.2X_%.2X_%.2X，见 src/ba-transport.c / src/shared/dbus-client.c）。 + * 返回 0=解析出 17 字符 MAC（大写、冒号分隔）。 */ +static int parse_dev_seg(const char *line, char *mac, size_t macsz) +{ + if (!line || !mac || macsz < 18) return -1; + const char *d = strstr(line, "dev_"); + if (!d) return -1; + const char *p = d + 4; + char out[18]; + size_t o = 0; + for (int i = 0; i < 6; i++) { + unsigned v = 0; + int digits = 0; + for (; digits < 2; digits++) { + char c = *p; + int h = -1; + if (c >= '0' && c <= '9') h = c - '0'; + else if (c >= 'A' && c <= 'F') h = c - 'A' + 10; + else if (c >= 'a' && c <= 'f') h = c - 'a' + 10; + if (h < 0) break; + v = v * 16u + (unsigned)h; + p++; + } + if (digits == 0) return -1; + o += (size_t)snprintf(out + o, sizeof out - o, (i == 0) ? "%02X" : ":%02X", v); + if (i < 5) { + if (*p != '_') return -1; + p++; + } + } + if (o != 17) return -1; + memcpy(mac, out, 18); + return 0; +} + +/* 兜底：端点 token 的最后一段直接是 MAC（老式/简化输出 `a2dpsrc/AA:BB:...`）。 */ +static int parse_tail_mac(const char *hit, char *mac, size_t macsz) +{ + const char *te = hit; + while (*te && *te != ' ' && *te != '\t' && *te != '\n') te++; + const char *slash = NULL; + for (const char *q = hit; q < te; q++) if (*q == '/') slash = q; + if (!slash || (slash + 1) >= te) return -1; + const char *start = slash + 1; + size_t len = (size_t)(te - start); + if (len != 17 || len >= macsz) return -1; + int colons = 0; + for (size_t i = 0; i < len; i++) if (start[i] == ':') colons++; + if (colons != 5) return -1; + memcpy(mac, start, len); + mac[len] = 0; + return 0; +} /* 解析 bluealsa-cli list-pcms 输出，取第一个 a2dpsrc/a2dp_source 端点的设备 MAC。 - * 端点形如 `a2dpsrc/AA:BB:CC:DD:EE:FF`（MAC 在端点 token 内最后一个 '/' 之后到空白前）。 + * 真实输出是 D-Bus 对象路径（每行一个）： + * /org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsrc/source + * MAC 取自 `dev_XX_XX_XX_XX_XX_XX` 段（下划线 → 冒号），另兼容简化形式 `a2dpsrc/AA:BB:...`。 * 逐个**有界行**匹配（strstr 必须在行内，避免跨换行误把后一行当本行端点——如行 1 - * "profile/aptx" 与行 3 "a2dp_source/..." 的经典误判）。 */ + * "hfphf/sink" 与行 3 "a2dpsrc/source" 的经典误判）。 */ int bt_dev_detect_mac(const char *listpcms, char *mac, size_t macsz) { if (!listpcms || !mac || macsz < 2) return -1; @@ -27,112 +92,112 @@ int bt_dev_detect_mac(const char *listpcms, char *mac, size_t macsz) memcpy(line, ln, linelen); line[linelen] = 0; const char *p = line; while (*p == ' ' || *p == '\t') p++; - const char *hit = strstr(p, "a2dpsrc"); - if (!hit) hit = strstr(p, "a2dp_source"); - if (hit) { - const char *te = hit; - while (*te && *te != ' ' && *te != '\t' && *te != '\n') te++; - const char *slash = NULL; - for (const char *q = hit; q < te; q++) if (*q == '/') slash = q; - if (slash && (slash + 1) < te) { - const char *start = slash + 1; - size_t len = (size_t)(te - start); - if (len > 0 && len < macsz) { - memcpy(mac, start, len); - mac[len] = 0; - return 0; - } - } + if (is_src_line(p)) { + if (parse_dev_seg(p, mac, macsz) == 0) return 0; + const char *hit = strstr(p, "a2dpsrc"); + if (!hit) hit = strstr(p, "a2dp_source"); + if (hit && parse_tail_mac(hit, mac, macsz) == 0) return 0; } if (!nl) break; ln = nl + 1; } + mac[0] = 0; return -1; } -/* 在单行内把 anchor（"DEV=" / "device"）后的 MAC 值替换为 mac，保留引号风格。 - * 行未含 anchor → 返回 1（out=原样）；含 anchor → 写回新行并返回 0。 */ -static int line_replace_mac(char *out, size_t outsz, const char *line, - const char *anchor, const char *mac) +int bt_dev_count_src(const char *listpcms) { - const char *at = strstr(line, anchor); - if (!at) { snprintf(out, outsz, "%s", line); return 1; } - const char *vp = at + strlen(anchor); - while (*vp == ' ' || *vp == '\t') vp++; - if (*vp == '"') vp++; /* 引号风格：值可带双引号 */ - const char *ve = vp; - while (*ve && *ve != ' ' && *ve != '\t' && *ve != '\n' && - *ve != '"' && *ve != '{' && *ve != '}') ve++; - size_t prefix = (size_t)(vp - line); /* 前段（含开引号，若带） */ - size_t tail = (size_t)(ve - line); /* 值终点（不含闭引号，若带） */ - /* 前段 + mac + 尾段（尾段保留闭引号与其后内容） */ - snprintf(out, outsz, "%.*s%s%s", (int)prefix, line, mac, line + tail); - return 0; -} - -/* 幂等改写 alsa.conf：只把 `pcm.bluealsa` 块内 `DEV=` 与 `device` 后的 MAC 换成 mac。 - * 逐行处理；无 pcm.bluealsa / 无 DEV= / device token → -1；两端已一致 → 1；改了 → 0。 */ -int bt_dev_rewrite(const char *in, size_t in_len, const char *mac, - char **out, size_t *out_len) -{ - if (!in || !mac || !mac[0] || !out || !out_len || in_len == 0) return -1; - if (!strstr(in, "pcm.bluealsa") || - (!strstr(in, "DEV=") && !strstr(in, "device"))) return -1; - - size_t cap = in_len + 128; - char *res = malloc(cap ? cap : 1); - if (!res) return -1; - size_t o = 0, changed = 0; - const char *p = in, *end = in + in_len; - - while (p < end) { - const char *nl = memchr(p, '\n', (size_t)(end - p)); - const char *le = nl ? nl : end; - size_t linelen = (size_t)(le - p); - char line[512], newline[512]; - if (linelen >= sizeof line) linelen = sizeof line - 1; - memcpy(line, p, linelen); line[linelen] = 0; - - const char *k = line; - while (*k == ' ' || *k == '\t') k++; - int anchored = 0; - if (strstr(k, "DEV=")) { - line_replace_mac(newline, sizeof newline, line, "DEV=", mac); - anchored = 1; - } else if (strncmp(k, "device", 6) == 0 && - (k[6] == ' ' || k[6] == '\t' || k[6] == 0)) { - line_replace_mac(newline, sizeof newline, line, "device", mac); - anchored = 1; - } - if (anchored) { - if (strcmp(line, newline) != 0) changed = 1; - size_t n = strlen(newline); - if (o + n + 2 > cap) { - cap = o + n + 256; - char *t = realloc(res, cap); - if (!t) { free(res); return -1; } - res = t; - } - memcpy(res + o, newline, n); o += n; - if (nl) res[o++] = '\n'; - } else { - size_t n = linelen; - if (o + n + 2 > cap) { - cap = o + n + 256; - char *t = realloc(res, cap); - if (!t) { free(res); return -1; } - res = t; - } - memcpy(res + o, p, n); o += n; - if (nl) res[o++] = '\n'; - } + if (!listpcms) return 0; + int n = 0; + const char *ln = listpcms; + while (ln && *ln) { + const char *nl = strchr(ln, '\n'); + const char *p = ln; + while (*p == ' ' || *p == '\t') p++; + if (is_src_line(p)) n++; if (!nl) break; - p = nl + 1; + ln = nl + 1; } + return n; +} - if (!changed) { free(res); return 1; } - res[o] = 0; - *out = res; - *out_len = o; +/* bluealsa 4.1.1 src/shared/a2dp-codecs.c 的 canonical 名与别名（strcasecmp 匹配）。 + * 只列本机可达的音频 codec；auto/unchanged/未知 → unchanged（不干预协商）。 */ +static const struct { + const char *canonical; + const char *aliases[4]; +} codecs[] = { + { "SBC", { "SBC", NULL } }, + { "MP3", { "MP3", "MPEG12", "MPEG", NULL } }, + { "AAC", { "AAC", "MPEG24", NULL } }, + { "ATRAC", { "ATRAC", NULL } }, + { "aptX", { "aptX", "apt-X", NULL } }, + { "aptX-AD", { "aptX-AD", "apt-X-AD", NULL } }, + { "aptX-HD", { "aptX-HD", "apt-X-HD", NULL } }, + { "aptX-LL", { "aptX-LL", "apt-X-LL", NULL } }, + { "aptX-TWS", { "aptX-TWS", "apt-X-TWS", NULL } }, + { "FastStream", { "FastStream", "FS", NULL } }, + { "LC3plus", { "LC3plus", NULL } }, + { "LDAC", { "LDAC", NULL } }, + { "LHDC", { "LHDC", NULL } }, +}; + +const char *bt_dev_codec_token(const char *setting, char *out, size_t outsz) +{ + const char *auto_tok = "unchanged"; + if (!out || outsz < 2) return auto_tok; + if (!setting || !setting[0]) { snprintf(out, outsz, "%s", auto_tok); return out; } + if (!strcasecmp(setting, "auto") || !strcasecmp(setting, "unchanged")) { + snprintf(out, outsz, "%s", auto_tok); + return out; + } + for (size_t i = 0; i < sizeof codecs / sizeof codecs[0]; i++) + for (size_t n = 0; n < 4 && codecs[i].aliases[n]; n++) + if (!strcasecmp(codecs[i].aliases[n], setting)) { + snprintf(out, outsz, "%s", codecs[i].canonical); + return out; + } + snprintf(out, outsz, "%s", auto_tok); /* 未知值：不干预协商（不把垃圾塞进 PCM 名） */ + return out; +} + +/* MAC 合法性：6 组两位十六进制，'/' 或 ':' 分隔都不接受（只认冒号，bluealsa 约定）。 */ +static int mac_valid(const char *mac) +{ + if (!mac || strlen(mac) != 17) return 0; + for (int i = 0; i < 17; i++) { + if ((i % 3) == 2) { if (mac[i] != ':') return 0; } + else { + char c = mac[i]; + int hex = (c >= '0' && c <= '9') || (c >= 'a' && c <= 'f') || (c >= 'A' && c <= 'F'); + if (!hex) return 0; + } + } + return 1; +} + +int bt_dev_pcm_name(const char *mac, const char *codec_token, char *out, size_t outsz) +{ + if (!out || outsz < 32 || !mac_valid(mac)) return -1; + const char *tok = (codec_token && codec_token[0]) ? codec_token : "unchanged"; + int n = snprintf(out, outsz, "bluealsa:DEV=%s,PROFILE=a2dp,CODEC=%s", mac, tok); + if (n < 0 || (size_t)n >= outsz) { out[0] = 0; return -1; } return 0; } + +unsigned bt_dev_backoff_ms(unsigned fails) +{ + if (fails == 0) return 0; + unsigned shift = fails - 1; + if (shift > 5) shift = 5; + unsigned long d = 2000UL << shift; /* 2s,4s,8s,16s,32s,64s */ + if (d > 60000UL) d = 60000UL; + return (unsigned)d; +} + +int bt_dev_should_try(unsigned fails, long long since_ms) +{ + if (fails == 0) return 1; + if (since_ms < 0) return 1; + return since_ms >= (long long)bt_dev_backoff_ms(fails) ? 1 : 0; +} diff --git a/patch_v2/meow_audiod/bt_dev.h b/patch_v2/meow_audiod/bt_dev.h index 8c6ed76..96a3219 100644 --- a/patch_v2/meow_audiod/bt_dev.h +++ b/patch_v2/meow_audiod/bt_dev.h @@ -1,12 +1,19 @@ -/* bt_dev.h — 蓝牙 A2DP 设备自识别（DEV 自动更新纯逻辑，宿主可单测）。 +/* bt_dev.h — 蓝牙 A2DP 端点选择 + PCM 名构造 + 回落退避（纯逻辑，宿主可单测）。 * - * 背景：/usr/data/alsa.conf 的 `pcm.bluealsa`（plug→bluealsa）需把 DEV/device 钉在当前 - * 连接的 A2DP sink 设备 MAC 上才能正确出声。本模块提供两段纯逻辑（无 meow_* / popen / 文件 - * I/O —— meow_audiod 负责读文件与执行系统命令）： - * - bt_dev_detect_mac：从 `bluealsa-cli list-pcms` 输出提取第一个 a2dpsrc 端点的设备 MAC； - * - bt_dev_rewrite：幂等改写 alsa.conf 文本，把 `pcm.bluealsa` 块内 `DEV=` 与 - * `device ` 两处换成目标 MAC（保留引号风格 / codec / 其余 token）。 - * 纯 libc（string / stdlib），独立编译，宿主零链接重。 + * 背景（M50 真机定案）：`/usr/data/alsa.conf` **不是** alsa 配置（是 HiBy 播放器的数据文件， + * libasound 从不加载），改它对实际解析零影响。真正生效的是 alsa-lib 自带的 + * `/etc/alsa/conf.d/20-bluealsa.conf`： + * + * pcm.bluealsa { + * @args [ DEV PROFILE CODEC VOL SOFTVOL DELAY SRV ] ← 只有这 7 个名字 + * ... type plug / slave.pcm { type bluealsa ... } + * } + * + * 其 `@args` 均可从 PCM 名内联传入（`snd_pcm_open("bluealsa:DEV=,PROFILE=a2dp, + * CODEC=")`），未声明的参数会被 alsa-lib 拒绝（parse_args: Unknown parameter）—— + * 所以本模块只生成这 7 个里的 3 个，且**不改任何文件**。 + * + * 纯 libc（string/stdlib），无 meow_* / popen / 文件 I/O —— meow_audiod 负责探测与打开。 */ #ifndef BT_DEV_H #define BT_DEV_H @@ -14,14 +21,35 @@ #include /* 解析 bluealsa-cli list-pcms 输出，取第一个 a2dpsrc/a2dp_source 端点的设备 MAC。 - * 返回 0=找到并写入 mac（NUL 结尾），-1=无 a2dpsrc 端点 / 参数非法。macsz 建议 ≥18。 */ + * 真实行为 D-Bus 对象路径（bluealsa 4.1.1）： + * /org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsrc/source + * 返回 0=找到并写入 mac（17 字符、大写冒号分隔，NUL 结尾），-1=无 a2dpsrc 端点 / 参数非法。 + * macsz ≥ 18。 */ int bt_dev_detect_mac(const char *listpcms, char *mac, size_t macsz); -/* 幂等改写 alsa.conf 文本（in_len 不含 NUL）：把 `pcm.bluealsa` 块内 `DEV=` 与 - * `device ` 两处 MAC 换成 mac（保留引号风格、codec/其它 token 原样）。 - * 返回 0=已改动（*out 与 *out_len 给出新文本，调用方负责 free）；1=无需改动（两端已一致）； - * -1=无 pcm.bluealsa / 无 DEV= 或 device token / 参数非法（不动）。 */ -int bt_dev_rewrite(const char *in, size_t in_len, const char *mac, - char **out, size_t *out_len); +/* 统计 list-pcms 输出里的 a2dpsrc/a2dp_source 端点数（0=无可用 A2DP 源端点）。 + * 用于「先探测端点、再决定是否打开」——无端点时省掉一次注定失败的 open。 */ +int bt_dev_count_src(const char *listpcms); + +/* settings.conf `bt.codec` → bluealsa CODEC 参数 token。 + * bluealsa 4.1.1 的 a2dp_codecs_codec_id_from_string() 用 strcasecmp 匹配 canonical 名与别名， + * 故大小写不敏感；本函数把它归一成 canonical 名（日志/STATE 用），未知值/auto/unchanged → + * "unchanged"（不改协商结果，等价 20-bluealsa.conf 的 defaults.bluealsa.codec）。 + * 返回 out（调用方给的 buf）。outsz 建议 ≥16。 */ +const char *bt_dev_codec_token(const char *setting, char *out, size_t outsz); + +/* 组 snd_pcm_open 的 PCM 名： + * bluealsa:DEV=,PROFILE=a2dp,CODEC= + * mac 非 6 组十六进制 → -1（不拼非法名字）；token 为空 → 用 "unchanged"。 + * 返回 0=写好（out NUL 结尾）。outsz 建议 ≥96。 */ +int bt_dev_pcm_name(const char *mac, const char *codec_token, char *out, size_t outsz); + +/* 回落退避：连续失败 fails 次后的重试间隔 ms（2s→4s→8s→16s→32s→60s 封顶；fails=0 → 0）。 + * 防重试风暴（M10 教训）：失败越多等越久，绝不每次 OPEN 都硬打一次 BT。 */ +unsigned bt_dev_backoff_ms(unsigned fails); + +/* 纯决策：此刻是否允许再尝试一次 BT。fails=0 → 允许；否则要求距上次失败 ≥ 退避间隔。 + * since_ms<0（时钟异常）按「允许」处理，避免永久卡死。 */ +int bt_dev_should_try(unsigned fails, long long since_ms); #endif /* BT_DEV_H */ diff --git a/patch_v2/meow_audiod/build_audiod.sh b/patch_v2/meow_audiod/build_audiod.sh index fc8ab8e..3f96e46 100755 --- a/patch_v2/meow_audiod/build_audiod.sh +++ b/patch_v2/meow_audiod/build_audiod.sh @@ -17,18 +17,40 @@ # ./build_audiod.sh # 交叉编译 → meow_audiod（mipsel glibc-dynamic，BT 直链 libasound） # ./build_audiod.sh cli # 交叉编译 meow_audio CLI → meow_audio（mipsel musl-static） # ./build_audiod.sh host # 宿主编译 *_host 并跑 test_audiod_host 回归（FILE sink） +# +# M50 蓝牙输出端到端：audiod 不再读写 /usr/data/alsa.conf（那是 HiBy 播放器的数据文件、语法非法、 +# libasound 从不加载），改为 snd_pcm_open("bluealsa:DEV=,PROFILE=a2dp,CODEC=") +# 内联参数（对应 /etc/alsa/conf.d/20-bluealsa.conf 的 pcm.bluealsa @args），失败必回落 DAC。 +# +# 环境变量覆盖：ROOT / REPO 自动推导，ZIG / CC / LIBBT / ASOUND_SRC / CC_HOST 可显式指定。 set -e cd "$(dirname "$0")" -ROOT="$HOME/Project/R3ProII" -CC="$ROOT/.tools/zig-mipsel-cc" -ZIG="$ROOT/.tools/zig-env/bin/zig" -INC="-I$ROOT/patch_v2/meow_launcherd" +# ---- 路径解析（M50：全部可被环境变量覆盖，不再硬绑某台机器的目录布局）---- +# ROOT 只用于可选的历史路径（旧 .tools/zig-env、hiby_os_crack 解包树）；缺省布局下不依赖它。 +ROOT="${ROOT:-$HOME/Project/R3ProII}" +REPO="$(cd "$(dirname "$0")/../.." && pwd)" # 仓库根（worktree 亦可） +# mipsel 静态 CC：优先显式环境变量 → 历史 zig 包装脚本 → PATH 里的 zig。 +CC="${CC:-}" +if [ -z "$CC" ]; then + if [ -x "$ROOT/.tools/zig-mipsel-cc" ]; then CC="$ROOT/.tools/zig-mipsel-cc"; else CC="zig cc --target=mipsel-linux-musleabi"; fi +fi +# 交叉编译用的 zig：显式 ZIG → 历史 zig-env → PATH。 +ZIG="${ZIG:-}" +if [ -z "$ZIG" ]; then + if [ -x "$ROOT/.tools/zig-env/bin/zig" ]; then ZIG="$ROOT/.tools/zig-env/bin/zig"; else ZIG="$(command -v zig || true)"; fi +fi +[ -n "$ZIG" ] || { echo "!! zig not found (set ZIG=/path/to/zig)"; exit 1; } +INC="-I$REPO/patch_v2/meow_launcherd" # 共享协议头（相对仓库根，不再绑 ROOT） if [ "$1" = "host" ]; then HOST_CC="${CC_HOST:-cc}" - # BT 目标直链宿主 libasound.so.2（无 asoundlib.h，原型内联于 meow_audiod.c；-l: 精确到版本， - # 不依赖 unversioned dev 链接）。删 -ldl：BT 不再用 dlopen。 - "$HOST_CC" $INC -Os -Wall -Wextra meow_audiod.c bt_dev.c -o meow_audiod_host -lpthread -l:libasound.so.2 + # BT 目标直链宿主 libasound（无 asoundlib.h，原型内联于 meow_audiod.c）。删 -ldl：BT 不再用 dlopen。 + # 优先 -l:libasound.so.2（精确到版本，不依赖 unversioned dev 链接）；宿主只装了无版本号 + # libasound.so（如 Termux）时退回 -lasound——两者符号集对我们用的 9 个原型等价。 + if ! "$HOST_CC" $INC -Os -Wall -Wextra meow_audiod.c bt_dev.c -o meow_audiod_host \ + -lpthread -l:libasound.so.2 2>/dev/null; then + "$HOST_CC" $INC -Os -Wall -Wextra meow_audiod.c bt_dev.c -o meow_audiod_host -lpthread -lasound + fi "$HOST_CC" $INC -Os -Wall -Wextra meow_audio.c -o meow_audio_host -lm "$HOST_CC" $INC -Os -Wall -Wextra test_audiod_host.c -o test_audiod_host -lm "$HOST_CC" -Os -Wall -Wextra test_bt_dev.c bt_dev.c -o test_bt_dev -lm @@ -59,15 +81,25 @@ fi # 当前钉在 fw_content.conf 的出货件则是旧工具链静态 musl，其 4403→ENOSYS→4263+宽度转换本身健康。 # 两种形态都不需要 meow_time32.c（其 __clock_* 接管针对 zig musl 内部符号）。musl-static 的 # meow_audio CLI 已链 time32。 -# 链接源 libbt/libasound.so.2.0.0（设备固件 libasound.so.2 副本）；缺失时从固件镜像自拷贝（idempotent）。 -LIBBT="libbt" -ASOUND_SRC="$ROOT/hiby_os_crack/r3proii/squashfs-root-example/usr/lib/libasound.so.2.0.0" +# 链接源 libbt/libasound.so.2.0.0（设备固件 libasound.so.2 副本）；缺失时从固件树自拷贝（idempotent）。 +# M50：LIBBT / ASOUND_SRC 可被环境变量覆盖；ASOUND_SRC 候选按「显式 → 历史解包树 → 仓内固件基线」 +# 顺序取第一个存在的（旧值 $ROOT/hiby_os_crack/... 在多数 checkout 里不存在，set -e 下会直接卡住构建）。 +LIBBT="${LIBBT:-libbt}" +if [ -z "$ASOUND_SRC" ]; then + for c in "$ROOT/hiby_os_crack/r3proii/squashfs-root-example/usr/lib/libasound.so.2.0.0" \ + "$REPO/devdocs/fw-baseline/squashfs-root/usr/lib/libasound.so.2.0.0" \ + "$REPO/fw_apps/build/squashfs-root/usr/lib/libasound.so.2.0.0"; do + [ -f "$c" ] && { ASOUND_SRC="$c"; break; } + done +fi +[ -n "$ASOUND_SRC" ] && [ -f "$ASOUND_SRC" ] || { + echo "!! libasound.so.2.0.0 not found (set ASOUND_SRC=/path/to/libasound.so.2.0.0)"; exit 1; } mkdir -p "$LIBBT" if [ ! -f "$LIBBT/libasound.so.2.0.0" ]; then cp "$ASOUND_SRC" "$LIBBT/libasound.so.2.0.0"; fi ln -sf libasound.so.2.0.0 "$LIBBT/libasound.so" ln -sf libasound.so.2.0.0 "$LIBBT/libasound.so.2" "$ZIG" cc --target=mipsel-linux-gnueabihf.2.22 $INC -Os -Wall -Wextra meow_audiod.c bt_dev.c -o meow_audiod \ - -lpthread -Llibbt -lasound + -lpthread -L"$LIBBT" -lasound echo "== meow_audiod (mipsel glibc-dynamic, BT links libasound.so.2) ==" ls -la meow_audiod md5sum meow_audiod diff --git a/patch_v2/meow_audiod/meow_audiod.c b/patch_v2/meow_audiod/meow_audiod.c index 5ae2e8d..cd3e9b3 100644 --- a/patch_v2/meow_audiod/meow_audiod.c +++ b/patch_v2/meow_audiod/meow_audiod.c @@ -59,7 +59,7 @@ #include #include #include "meow_ipc.h" -#include "bt_dev.h" /* P2：DEV 自识别（a2dpsrc 端点 → MAC → alsa.conf 幂等改写） */ +#include "bt_dev.h" /* M50：端点探测 / PCM 名构造 / 回落退避（纯逻辑，不改任何配置文件） */ #ifdef __linux__ #include @@ -76,9 +76,13 @@ #define SETTINGS_CONF "/usr/data/meow/settings.conf" #define DEFAULT_OUT_WAV "/tmp/meow_audiod.wav" -/* ---- 蓝牙 A2DP source（P2 输出目标 OUT_BT） ---- */ -#define BT_PCM_DEFAULT "pcm.bluealsa" /* alsa.conf `pcm.bluealsa`(plug→bluealsa)；aplay -D bluealsa 等价 */ -#define BT_PCM_FALLBACK "bluealsa" /* 部分配置只定义别名节点，防打开失败再试一次 */ +/* ---- 蓝牙 A2DP source（P2 输出目标 OUT_BT）---- + * M50 真机定案：**不写任何配置文件**。设备真正生效的是 alsa-lib 自带的 + * /etc/alsa/conf.d/20-bluealsa.conf 里的 `pcm.bluealsa`（type plug → slave type bluealsa， + * @args = DEV PROFILE CODEC VOL SOFTVOL DELAY SRV）。DEV/CODEC 直接从 PCM 名内联传入， + * 一次 snd_pcm_open 即完成「钉设备 + 钉 codec」，无需 DEV 自识别改写文件。 + * ⚠️ /usr/data/alsa.conf 是 HiBy 播放器的数据文件、语法非法、libasound 从不加载——不读也不写。 */ +#define BT_PCM_BARE "bluealsa" /* 兜底：仅当内联名失败时试一次配置缺省（DEV 通配） */ #define BT_CODEC_AUTO "auto" #define BT_VOL_FULL_PCM "/usr/bin/bluealsa-cli" /* 一键设 AVRCP 100%（best-effort，不存在则跳过） */ @@ -203,11 +207,25 @@ static int g_dev_dsd = 0; /* 当前打开设备为 DoP DSD（决 static int g_reconfig_pending = 0; /* ---- 蓝牙 A2DP source 运行时状态（g_mu 保护；仅 g_target==OUT_BT && g_sink==SINK_ALSA 时用） ---- - * 直接调用 libasound 插件 PCM（pcm.bluealsa）。audiod 以动态 glibc 链接设备 libasound.so.2 - * （见 bt_* 段注释），此处仅存 snd_pcm_t 不透明句柄。 */ + * 直接调用 libasound 插件 PCM（见 bt_* 段注释），此处仅存 snd_pcm_t 不透明句柄。 + * + * 失败状态机（M50 硬验收点：失败必回落 DAC，绝不整机静音）： + * BT_ST_IDLE —— 尚未尝试（启动初值 / 刚切到 BT 未开流） + * BT_ST_OK —— snd_pcm_open 成功，音频走 A2DP + * BT_ST_FAIL —— 最近一次尝试失败（无端点/未连接/set_params 失败/写路径致命错）， + * 音频已回落 DAC；重试按 bt_dev_backoff_ms() 指数退避（2s→60s）， + * 且只在「开流/重配」边界触发，绝不在写循环里重试（防 M10 重试风暴）。 */ +enum { BT_ST_IDLE = 0, BT_ST_OK = 1, BT_ST_FAIL = 2 }; static void *g_bt_hdl = NULL; /* snd_pcm_t *（libasound 不透明句柄） */ static int g_bt_open = 0; /* BT PCM 已打开 */ static int g_bt_vol_full_done = 0; /* 已对 AVRCP 置 100%（幂等，一次即可） */ +static int g_bt_state = BT_ST_IDLE; /* BT_ST_*（见上） */ +static unsigned g_bt_fail_n = 0; /* 连续失败次数（成功后归零） */ +static long long g_bt_last_fail_ms = 0; /* 上次失败时刻（CLOCK_MONOTONIC ms） */ +static char g_bt_mac[20] = ""; /* 已打开/最近探测到的 A2DP 端点 MAC */ +static char g_bt_tok[16] = "unchanged"; /* 实际下发的 CODEC token（canonical） */ +static int g_bt_fail_req = 0; /* 写路径判死：请求播放线程下一拍重配（回落 DAC） */ +static int g_bt_dev = 0; /* 当前「设备」是 BT PCM（dev_close 分流；g_mu 保护） */ /* ---- 数字域电平表（DAC 实时监控；CS43198 无模拟电平回读，播放线程看 PCM 样本） ---- * 播放线程对从 ring 取出的每块 PCM 做纯整数累加（归一到 16bit 域：S24/S32 >>16）， @@ -378,10 +396,12 @@ static int target_grant_fmt(int native_fmt) return AUDIO_FMT_S16; } -/* 音量控制归属（QUERY volctl=）：dac=反转控制；avrcp=蓝牙 AVRCP 侧控。 */ +/* 音量控制归属（QUERY volctl=）：dac=反转控制；avrcp=蓝牙 AVRCP 侧控。 + * BT 回落 DAC（bt=fail）时实际由 DAC 控，故报 dac——面板据此显示「蓝牙(失败)」。 */ static const char *volctl_name(void) { - return (g_target == AUDIO_OUT_BT) ? "avrcp" : "dac"; + if (g_target != AUDIO_OUT_BT) return "dac"; + return (g_bt_state == BT_ST_FAIL) ? "dac" : "avrcp"; } /* 整数开平方（uint64→uint32，逐位法；替代软浮点 sqrt） */ @@ -860,7 +880,8 @@ static int settings_get_output_target(void) } /* P2 蓝牙：读 settings.conf `bt.codec`（auto/SBC/AAC/aptX/LDAC…）→ g_bt_codec。缺省 auto。 - * codec 经 /usr/data/alsa.conf 的 `pcm.bluealsa` codec 参数生效（audiod BT 打开前 best-effort sync）。 */ + * 生效路径（M50）：bt_dev_codec_token() 归一成 bluealsa canonical 名后，作为 CODEC 参数内联进 + * PCM 名（bluealsa:DEV=…,PROFILE=a2dp,CODEC=…）；auto/未知 → unchanged（不干预协商）。 */ static const char *settings_get_bt_codec(void) { char buf[24]; @@ -926,137 +947,108 @@ const char *snd_strerror(int errnum); static void bt_close(void); /* 前向：bt_write 判死路径要用 */ static void bt_vol_full(void); /* 前向：bt_open 成功时促成 AVRCP 100% */ -/* bt.codec 生效：bluealsa 的 codec 是 config-time 参数（/usr/data/alsa.conf `pcm.bluealsa` 块的 - * `codec "X"`）。audiod 在 BT 打开前做一次**幂等且外科式**的 token 替换：只把 bluealsa 块内的 - * `codec "..."` 改成 `codec ""`（其余字符不动）。仅真机且文件可写时执行； - * 宿主/只读/找不到 codec token → 跳过（绝不破坏 alsa.conf——audiod 只调整既有 token，不新建结构）。 */ -static void bt_apply_codec_conf(void) +/* 单调时钟 ms（退避计时；CLOCK_MONOTONIC 不受系统时间跳变影响） */ +static long long now_ms(void) { - if (!g_bt_codec[0] || !strcmp(g_bt_codec, BT_CODEC_AUTO) || !strcmp(g_bt_codec, "unchanged")) return; - const char *path = "/usr/data/alsa.conf"; - /* 先探测是否已有 codec token：无则不动（避免误建/无权写） */ - { - FILE *pf = fopen(path, "r"); - if (!pf) return; - int hit = 0; char l[160]; - while (fgets(l, sizeof l, pf)) { - char *k = l; while (*k==' '||*k=='\t') k++; - if (strncmp(k, "codec", 5) == 0) { hit = 1; break; } - } - fclose(pf); - if (!hit) return; - } - FILE *f = fopen(path, "r"); - if (!f) return; - char *data = NULL; size_t len = 0; - fseek(f, 0, SEEK_END); long sz = ftell(f); - if (sz <= 0 || sz > 64 * 1024) { fclose(f); return; } - fseek(f, 0, SEEK_SET); - data = malloc((size_t)sz + 1); - if (!data) { fclose(f); return; } - len = fread(data, 1, (size_t)sz, f); data[len] = 0; - fclose(f); - char *out = malloc(len + 64); - if (!out) { free(data); return; } - out[0] = 0; size_t o = 0; int changed = 0; - char *save = NULL; - char *ln = strtok_r(data, "\n", &save); - while (ln) { - char *k = ln; while (*k==' '||*k=='\t') k++; - int is_codec = (strncmp(k, "codec", 5) == 0); - if (is_codec && !changed) { - int n = snprintf(out + o, len + 64 - o, "codec \"%s\"\n", g_bt_codec); - if (n > 0) o += (size_t)n; - changed = 1; - } else { - int n = snprintf(out + o, len + 64 - o, "%s\n", ln); - if (n > 0) o += (size_t)n; - } - ln = strtok_r(NULL, "\n", &save); - } - free(data); - if (changed) { - int fd = open(path, O_WRONLY | O_TRUNC, 0644); - if (fd >= 0) { if (write(fd, out, o) < 0) { } close(fd); logmsg("bt: codec conf %s -> %s", path, g_bt_codec); } - else logmsg("bt: codec conf %s not writable, skip", path); - } - free(out); + struct timespec ts; + clock_gettime(CLOCK_MONOTONIC, &ts); + return (long long)ts.tv_sec * 1000 + (long long)(ts.tv_nsec / 1000000); } -/* P2 BT DEV 自识别：把 /usr/data/alsa.conf 的 `pcm.bluealsa` DEV/device 自动改为**当前连接的 - * A2DP sink 设备** MAC（bluealsa-cli list-pcms 的 a2dpsrc 端点）。幂等（设备未变不重写）、 - * 无设备/失败跳过；只改 DEV/device 两处、保留 codec/其余 token。BT 打开前调用，实现 - * 「连哪个设备就播哪个」。跟 bt_apply_codec_conf 同构（外科式 token 替换，绝不建结构）。 */ -static void bt_apply_device_conf(void) +/* 记录一次 BT 失败：状态置 FAIL（→ 回落 DAC）+ 失败计数递增（退避依据）+ 日志。 + * 只在「开流/重配」边界或写路径判死时调用；写循环内绝不重试（防 M10 重试风暴）。 */ +static void bt_note_fail(const char *why) { - char mac[32] = ""; + g_bt_state = BT_ST_FAIL; + g_bt_fail_n++; + g_bt_last_fail_ms = now_ms(); + logmsg("bt: FAIL (%s) -> fallback DAC; fail#%u, next retry in %ums", + why ? why : "?", g_bt_fail_n, bt_dev_backoff_ms(g_bt_fail_n)); +} + +/* 成功：状态 OK、失败计数归零。 */ +static void bt_note_ok(void) +{ + g_bt_state = BT_ST_OK; + g_bt_fail_n = 0; +} + +/* 探测当前可用的 A2DP source 端点（bluealsa-cli list-pcms，1.5s 有界 popen）。 + * 返回端点数量；mac 非空时写入第一个 a2dpsrc 端点的设备 MAC。 + * 注意：bluealsa-cli v4.1.1 **没有** `a2dp list` 子命令，只有 list-pcms/list-services。 */ +static int bt_probe(char *mac, size_t macsz) +{ + if (mac && macsz) mac[0] = 0; char *o = popen_read_tmo(1500, "bluealsa-cli list-pcms 2>/dev/null"); - if (!o) { logmsg("bt: dev conf skipped (no bluealsa-cli)"); return; } - if (bt_dev_detect_mac(o, mac, sizeof mac) != 0) { - logmsg("bt: dev conf skipped (no a2dpsrc pcm)"); - return; - } - logmsg("bt: current a2dp dev %s", mac); - const char *path = "/usr/data/alsa.conf"; - FILE *f = fopen(path, "r"); - if (!f) return; - fseek(f, 0, SEEK_END); long sz = ftell(f); - if (sz <= 0 || sz > 64 * 1024) { fclose(f); return; } - fseek(f, 0, SEEK_SET); - char *data = malloc((size_t)sz + 1); - if (!data) { fclose(f); return; } - size_t rl = fread(data, 1, (size_t)sz, f); data[rl] = 0; - fclose(f); - char *outdata = NULL; size_t outlen = 0; - int rc = bt_dev_rewrite(data, rl, mac, &outdata, &outlen); - free(data); - if (rc == 0) { - int fd = open(path, O_WRONLY | O_TRUNC, 0644); - if (fd >= 0) { - if (write(fd, outdata, outlen) < 0) { } - close(fd); - logmsg("bt: dev conf auto-updated %s -> %s", path, mac); - } else { - logmsg("bt: dev conf %s not writable, skip", path); - } - } else if (rc == 1) { - logmsg("bt: dev conf ok (already %s)", mac); - } else { - logmsg("bt: dev conf skip (no pcm.bluealsa/no DEV token)"); - } - if (outdata) free(outdata); + if (!o) { logmsg("bt: probe skipped (no bluealsa-cli)"); return 0; } + int n = bt_dev_count_src(o); + if (n > 0 && mac && macsz && bt_dev_detect_mac(o, mac, macsz) != 0) mac[0] = 0; + return n; } -/* BT 打开：libasound → snd_pcm_open(pcm.bluealsa/bluealsa, PLAYBACK, NONBLOCK) → - * set_params(S16_LE, RW, ch, rate, soft_resample, 100ms)。返回 0=ok。失败置 g_bt_open=0。 */ -static int bt_open(void) +/* 按 PCM 名打开（libasound → NONBLOCK open + set_params S16/RW/ch/rate/soft_resample/100ms）。 + * 返回 0=ok（g_bt_hdl/g_bt_open/g_dev_* 已置位），-1=失败（句柄已 close，未记账）。 */ +static int bt_open_pcm(const char *name) { void *pcm = NULL; - const char *names[2] = { BT_PCM_DEFAULT, BT_PCM_FALLBACK }; - int r = -1; - for (int i = 0; i < 2; i++) { - r = snd_pcm_open(&pcm, names[i], SND_PCM_STREAM_PLAYBACK, SND_PCM_NONBLOCK); - if (r == 0) { logmsg("bt: opened %s", names[i]); break; } - logmsg("bt: snd_pcm_open %s: %s", names[i], snd_strerror(r)); - pcm = NULL; + int r = snd_pcm_open(&pcm, name, SND_PCM_STREAM_PLAYBACK, SND_PCM_NONBLOCK); + if (r != 0) { + logmsg("bt: snd_pcm_open %s: %s", name, snd_strerror(r)); + return -1; } - if (r != 0) return -1; - g_bt_hdl = pcm; snd_pcm_nonblock(pcm, 1); unsigned rate = g_st.rate ? g_st.rate : 44100; unsigned ch = g_st.ch ? g_st.ch : 2; r = snd_pcm_set_params(pcm, SND_PCM_FORMAT_S16_LE, SND_PCM_ACCESS_RW_INTERLEAVED, ch, rate, 1, 100000); if (r < 0) { - logmsg("bt: set_params %u/%u/S16: %s", rate, ch, snd_strerror(r)); - snd_pcm_close(pcm); g_bt_hdl = NULL; return -1; + logmsg("bt: set_params %u/%u/S16 (%s): %s", rate, ch, name, snd_strerror(r)); + snd_pcm_close(pcm); + return -1; } + g_bt_hdl = pcm; g_bt_open = 1; - logmsg("bt: PCM ready rate=%u ch=%u fmt=S16 codec=%s", rate, ch, g_bt_codec); - bt_vol_full(); /* best-effort AVRCP 100%（一次性；失败仅日志） */ + g_dev_rate = rate; g_dev_ch = ch; g_dev_fmt = AUDIO_FMT_S16; + logmsg("bt: PCM ready name=%s rate=%u ch=%u fmt=S16 codec=%s", name, rate, ch, g_bt_tok); return 0; } +/* 尝试把输出打开到 BT：退避门 → 端点探测（list-pcms）→ 内联 DEV/CODEC 打开 → + * 兜底裸 "bluealsa"（配置缺省 DEV 通配）→ 记账失败。 + * 返回 0=BT 就绪（音频走 A2DP）；-1=本次不可用（调用方负责回落 DAC）。 + * ⚠️ 在 playback 线程持 g_mu 时执行（popen ≤1.5s + snd_pcm_open），所以只允许在开流/重配 + * 边界调用；连续失败由退避门（2s→60s）挡住，不会形成重试风暴。 */ +static int bt_try_open(void) +{ + long long since = now_ms() - g_bt_last_fail_ms; + if (!bt_dev_should_try(g_bt_fail_n, since)) { + static unsigned s_skip = 0; + if ((s_skip++ % 16) == 0) + logmsg("bt: retry gated (fail#%u, need %ums, elapsed %lldms)", + g_bt_fail_n, bt_dev_backoff_ms(g_bt_fail_n), since); + return -1; + } + char mac[20] = ""; + int eps = bt_probe(mac, sizeof mac); + if (eps <= 0 || !mac[0]) { bt_note_fail("no a2dp endpoint (device not connected?)"); return -1; } + snprintf(g_bt_mac, sizeof g_bt_mac, "%s", mac); + bt_dev_codec_token(g_bt_codec, g_bt_tok, sizeof g_bt_tok); + char name[96]; + if (bt_dev_pcm_name(g_bt_mac, g_bt_tok, name, sizeof name) != 0) { bt_note_fail("bad endpoint MAC"); return -1; } + logmsg("bt: endpoint %s (x%d) codec setting=%s -> token=%s", g_bt_mac, eps, g_bt_codec, g_bt_tok); + const char *opened = NULL; + if (bt_open_pcm(name) == 0) opened = name; + else if (bt_open_pcm(BT_PCM_BARE) == 0) opened = BT_PCM_BARE; + if (opened) { + bt_note_ok(); + g_bt_vol_full_done = 0; /* 新设备/PCM：允许再促成一次 AVRCP 100% */ + bt_vol_full(); + return 0; + } + bt_note_fail("snd_pcm_open/set_params failed"); + return -1; +} + /* BT 写：非阻塞 writei + wait 超时（镜像 DAC O_NONBLOCK+poll 护栏），xrun recover。 * 设备停摆/无连接 → 丢帧（g_played_frames 照记），绝不把播放线程永久压进 libasound。 */ static void bt_write(uint8_t *buf, size_t n) @@ -1084,13 +1076,18 @@ static void bt_write(uint8_t *buf, size_t n) if (pr == 0) { /* 无空间超时 → 停摆计数（镜像 DAC stall） */ g_stall++; stalls++; if (stalls >= ALSA_STALL_MAX) { - logmsg("bt WEDGED: %d consecutive waits, close + drop until next OPEN", stalls); + logmsg("bt WEDGED: %d consecutive waits, close + fallback DAC", stalls); bt_close(); g_bt_open = 0; g_dev_open = 0; + g_bt_fail_req = 1; /* 播放线程下一拍重配 → 回落 DAC（不静音） */ g_played_frames += n / fs; return; } continue; } - if (pr < 0 && errno != EINTR) { logmsg("bt wait err: %s", strerror(errno)); break; } + if (pr < 0 && errno != EINTR) { + logmsg("bt wait err: %s -> fallback DAC", strerror(errno)); + bt_close(); g_bt_open = 0; g_dev_open = 0; g_bt_fail_req = 1; + break; + } continue; } if (err == EPIPE || err == ESTRPIPE) { /* xrun：recover 后继续 */ @@ -1099,7 +1096,10 @@ static void bt_write(uint8_t *buf, size_t n) snd_pcm_recover(g_bt_hdl, err, 1); continue; } - logmsg("bt writei err: %s", snd_strerror(err)); + /* 端点消失/设备断开（ENODEV/ENXIO/EIO/ESHUTDOWN…）：关 PCM 并请求回落 DAC。 + * **不在这里重试**（写循环内重试 = M10 重试风暴）；退避重试在下次开流/重配边界。 */ + logmsg("bt writei err: %s -> fallback DAC", snd_strerror(err)); + bt_close(); g_bt_open = 0; g_dev_open = 0; g_bt_fail_req = 1; break; } if (w == 0) break; @@ -1119,14 +1119,15 @@ static void bt_close(void) } /* 音量隔离（PLAN §五）：路由=BT 时**不下发 DAC 音量反转**（音量由 AVRCP/耳机侧控）。 - * 仅记录 DAC 音量（g_vol_pct 语义=本地 DAC 音量）；BT 侧 best-effort 促成 AVRCP 100% - * （避免"窃听音量误解"——耳机侧音量钉到最响，设备侧滑块即绝对控制）。 */ + * BT 侧 best-effort 促成 AVRCP 最大音量（127 = bluealsa-cli volume 的满量程 [0,127]； + * 旧代码发 100 只到 79%，耳机偏轻的隐性原因之一），设备侧滑块即绝对控制。 + * PCM-PATH 取 list-pcms 的整行（D-Bus 对象路径）——bluealsa-cli 要的就是它，不是 MAC。 */ static void bt_vol_full(void) { if (g_bt_vol_full_done) return; g_bt_vol_full_done = 1; char *o = popen_read_tmo(1500, "bluealsa-cli list-pcms 2>/dev/null"); - if (!o) { logmsg("bt: avrcp set-100 skipped (no bluealsa-cli)"); return; } + if (!o) { logmsg("bt: avrcp set-max skipped (no bluealsa-cli)"); return; } char pcm[128] = ""; const char *ln = o; while (ln && *ln) { @@ -1143,22 +1144,45 @@ static void bt_vol_full(void) if (!nl) break; ln = nl + 1; } - if (!pcm[0]) { logmsg("bt: avrcp set-100 skipped (no a2dpsrc pcm found)"); return; } + if (!pcm[0]) { logmsg("bt: avrcp set-max skipped (no a2dpsrc pcm found)"); return; } char cmd[256]; - snprintf(cmd, sizeof cmd, "%s volume %s 100 >/dev/null 2>&1", BT_VOL_FULL_PCM, pcm); + snprintf(cmd, sizeof cmd, "%s volume %s 127 >/dev/null 2>&1", BT_VOL_FULL_PCM, pcm); char *r = popen_read_tmo(1500, cmd); - logmsg("bt: avrcp volume set 100%% (%s)%s", pcm, r ? " ok" : " (exec failed; AVRCP still controls)"); + logmsg("bt: avrcp volume set max(127) (%s)%s", pcm, r ? " ok" : " (exec failed; AVRCP still controls)"); } -/* 音量应用（含 BT 隔离）：BT → 只通知 AVRCP（best-effort），绝不动 DAC numid=1/2、不持久化 - * audio.volume（那是 DAC 音量键）；DAC → 原感知锥度反转 + 持久化。 +/* 实际输出是否真的在蓝牙上（BT_ST_OK）。STATE/路由/音量都以「实际」而非「请求」为准判断， + * 但 target= 仍报用户请求值（面板据此显示「输出=蓝牙（失败）」）。 */ +static int bt_effective_bt(void) +{ + return g_target == AUDIO_OUT_BT && g_sink == SINK_ALSA && g_bt_state == BT_ST_OK; +} + +/* 请求了 BT 但当前回落 DAC（STATE 的 bt=fail；此时 DAC 音量/路由语义生效）。 */ +static int bt_fallback_active(void) +{ + return g_target == AUDIO_OUT_BT && g_bt_state == BT_ST_FAIL; +} + +static const char *bt_state_name(void) +{ + switch (g_bt_state) { + case BT_ST_OK: return "ok"; + case BT_ST_FAIL: return "fail"; + default: return "idle"; + } +} + +/* 音量应用（含 BT 隔离）：BT（真实走 A2DP）→ 只通知 AVRCP（best-effort），绝不动 DAC numid=1/2、 + * 不持久化 audio.volume（那是 DAC 音量键）；DAC 及「BT 回落 DAC」→ 原感知锥度反转 + 持久化 + * （回落时声音实际从 DAC 出，音量必须由 DAC 控，否则面板拖动无感）。 * target 为调用方在持锁下快照的 g_target；本函数不持 g_mu 执行（g_vol_pct 为 plain int * 松散写，同 route_thread 的 g_route_cur 语义，MIPS32 int 写天然原子）。 */ static void vol_apply(int pct, int target) { if (pct < 0) pct = 0; if (pct > 100) pct = 100; - if (target == AUDIO_OUT_BT) { + if (target == AUDIO_OUT_BT && g_bt_state != BT_ST_FAIL) { logmsg("vol -> %d%% (BT/AVRCP, DAC numid=1/2 NOT written)", pct); return; } @@ -1176,6 +1200,10 @@ static void target_set(int target) if (g_target == target) { logmsg("output: target already %d", target); return; } logmsg("output: target %d -> %d (%s)", g_target, target, target == AUDIO_OUT_BT ? "BT" : "DAC"); g_target = target; + /* 用户显式切目标：清 BT 退避（切 BT 时立刻尝试一次；仍失败就按退避回落，不死缠蓝牙） */ + g_bt_fail_n = 0; + g_bt_last_fail_ms = 0; + g_bt_state = BT_ST_IDLE; if (g_st.active) g_reconfig_pending = 1; pthread_cond_signal(&g_cond); } @@ -1302,18 +1330,37 @@ static void wav_header(int fd, int rate, int ch, int bits, uint32_t data_len) /* ---- 播放线程设备管理（dev_open/close/write 皆在播放线程调用） ---- */ static void dev_close(void); /* 前向：dev_write 的 wedge 判死路径要用 */ +/* DAC 回落前的端口武装（复制 route_thread 的 boot-arm 语义，但同步执行）。 + * 为什么必须同步：hbc3000 FPGA 未烧录 + enable 时开 PCM 会在第二次 hbc3000_start 死锁整机 + * （M2.91 事故）。BT→DAC 回落是**流内**切换，不能等路由线程 1s 节拍，否则 PCM 可能先开。 */ +static void dac_fallback_arm(void) +{ + int hb = read_switch("/sys/class/switch/headset/state"); + int bal = read_switch("/sys/class/switch/balance/state"); + int port = (bal == 1) ? 3 : (hb == 1) ? 2 : 4; + int cur = amixer_get(9, 1); + if (cur == port) { + g_route_cur = port; + logmsg("bt: fallback arm skipped (numid=9 already %d)", port); + return; + } + logmsg("bt: fallback arm numid=9 -> %d (was %d)", port, cur); + apply_route(port); +} + static int dev_open(void) { - /* 输出目标=BT 且走真机 ALSA：打开 libasound 的 pcm.bluealsa（不开 hw:0,0）。 - * 宿主即 FILE/NULL sink 时不走此支——因此宿主可测「目标选择/音量隔离/格式归一」逻辑， - * 真实 bluealsa 传输留给真机（见 bt_* 注释）。失败 → 降级丢帧（自感知兜底 §五）。 */ + /* 输出目标=BT 且走真机 ALSA：打开 libasound 的 bluealsa PCM（内联 DEV/CODEC，不开 hw:0,0）。 + * 宿主即 FILE/NULL sink 时不走此支——因此宿主可测「目标选择/音量隔离/格式归一」逻辑。 + * **失败必回落 DAC**（M50 硬验收：没有 A2DP 端点时整机不许静音；同时区间由 bt_note_fail + * 记账退避，STATE 报 bt=fail 供面板显示「输出=蓝牙(失败)」）。 */ if (g_target == AUDIO_OUT_BT && g_sink == SINK_ALSA) { - bt_apply_device_conf(); /* P2：DEV 幂等自更新到当前连接 A2DP 设备（连哪台播哪台） */ - bt_apply_codec_conf(); - if (bt_open() == 0) return 0; /* g_bt_open=1；返回 0=逻辑已开（真实句柄在 g_bt_hdl） */ - logmsg("bt: open failed (degrade: drop PCM until next OPEN)"); - return -1; + if (bt_try_open() == 0) { g_bt_dev = 1; return 0; } /* g_bt_open=1（真实句柄在 g_bt_hdl） */ + logmsg("bt: open unavailable -> DAC fallback (audio continues)"); + dac_fallback_arm(); + /* 落到下面的 DAC 打开路径（grant fmt 已是 S16，DAC 支持） */ } + g_bt_dev = 0; uint32_t rate = g_st.rate, ch = g_st.ch, fmt = g_st.fmt; int bits = fmt_bps((int)fmt) * 8; if (g_sink == SINK_ALSA) { @@ -1362,7 +1409,7 @@ static void dev_write(uint8_t *buf, size_t n) } g_dev_bytes += n; } - if (g_target == AUDIO_OUT_BT && g_sink == SINK_ALSA) { bt_write(buf, n); return; } + if (bt_effective_bt()) { bt_write(buf, n); return; } if (g_sink == SINK_NULL) { g_played_frames += n / (size_t)frame_size(); return; } if (g_sink == SINK_ALSA) { #ifdef AUDIOD_HAVE_ALSA @@ -1428,7 +1475,9 @@ static void dev_write(uint8_t *buf, size_t n) static void dev_close(void) { - if (g_bt_open) { bt_close(); g_dev_fd = -1; g_dev_open = 0; return; } + /* 分流用 g_bt_dev（而非 g_bt_open）：写路径判死时 bt_write 已 bt_close()（g_bt_open=0）， + * 若此时按 g_bt_open 走 DAC 分支会把 g_dev_fd(=0) 当成真 fd 关掉（误关 stdin）。 */ + if (g_bt_dev) { bt_close(); g_bt_dev = 0; g_dev_fd = -1; g_dev_open = 0; return; } if (g_sink == SINK_FILE && g_dev_fd >= 0 && g_dev_fd != -2) { off_t end = lseek(g_dev_fd, 0, SEEK_END); if (end > 44) { @@ -1484,7 +1533,8 @@ static void reconfigure_locked(void) g_dev_rate = rate; g_dev_ch = ch; g_dev_fmt = fmt; if (g_dev_fd == -2) g_dev_fd = -1; /* NULL sink：无真实 fd */ g_dev_dsd = (do_dsd_seq && new_dsd); - if (g_target == AUDIO_OUT_DAC && g_sink == SINK_ALSA) dac_vol_set(saved_vol); /* 复原（含 DSD_VOLUME） */ + if ((g_target == AUDIO_OUT_DAC || bt_fallback_active()) && g_sink == SINK_ALSA) + dac_vol_set(saved_vol); /* 复原（含 DSD_VOLUME）；BT 回落 DAC 时同样要落 DAC 音量 */ logmsg("device open ok: %u/%u/%s sink=%d target=%s%s", (unsigned)rate, (unsigned)ch, fmt_name((int)fmt), g_sink, tgt, g_dev_dsd ? " dsd" : ""); } else { @@ -1541,6 +1591,19 @@ static void *playback_thread(void *arg) pthread_mutex_unlock(&g_mu); if (n == 0) continue; dev_write(buf, n); + /* BT 写路径判死（端点消失/耳机断电/wedge）→ 下一拍重配回落 DAC。 + * 记账/状态在持锁下做；退避门保证这次重配不会立刻再打一次 BT（不形成重试风暴）。 */ + if (g_bt_fail_req) { + pthread_mutex_lock(&g_mu); + if (g_bt_fail_req) { + g_bt_fail_req = 0; + g_bt_dev = 0; + bt_note_fail("write path fatal (endpoint gone?)"); + g_reconfig_pending = 1; + pthread_cond_signal(&g_cond); + } + pthread_mutex_unlock(&g_mu); + } } pthread_mutex_lock(&g_mu); if (g_dev_open) dev_close(); @@ -1706,9 +1769,9 @@ static void dispatch(struct client *c, uint16_t type, uint32_t req_id, const uin a.grant_fmt = g_st.fmt; a.err = MEOW_OK; send_frame(c->fd, MSG_AUDIO_OPEN_ACK, req_id, &a, sizeof a); - logmsg("OPEN grant: sid=%u app=%s rate=%u ch=%u fmt=%s target=%s codec=%s", + logmsg("OPEN grant: sid=%u app=%s rate=%u ch=%u fmt=%s target=%s bt=%s codec=%s", (unsigned)sid, g_st.app_id, (unsigned)o.rate, (unsigned)g_st.ch, - fmt_name((int)g_st.fmt), target_name(), g_bt_codec); + fmt_name((int)g_st.fmt), target_name(), bt_state_name(), g_bt_codec); break; } case MSG_AUDIO_WRITE: { @@ -1749,15 +1812,19 @@ static void dispatch(struct client *c, uint16_t type, uint32_t req_id, const uin } case MSG_AUDIO_QUERY: { char txt[1024]; + char bttok[16]; /* 路由口用缓存值 g_route_cur（路由线程维护），不在 IO 热路径 popen amixer—— * 驱动 wedge 时 amixer 虽有界但仍会拖慢 IO 循环 1.5s/次。 */ int rb = g_route_cur; int vol = g_vol_pct; + /* btcodec= 报「当前设置归一后的 token」（不是上次打开用的），便于面板/CLI 直接核对 + * settings bt.codec 到底会被下发放什么；纯函数，无 I/O。 */ + bt_dev_codec_token(g_bt_codec, bttok, sizeof bttok); snprintf(txt, sizeof txt, "active=%d app=%s sid=%u rate=%u ch=%u fmt=%s dsd=%d " "written=%llu played=%llu underrun=%u dropped=%llu stall=%u txdrop=%u paused=%d " "route_mode=%s port=%d vol=%d volctl=%s rms=%d peak=%d lvlseq=%u " - "target=%s codec=%s\n", + "target=%s bt=%s btdev=%s btcodec=%s codec=%s\n", g_st.active ? 1 : 0, g_st.active ? g_st.app_id : "-", (unsigned)g_st.sid, (unsigned)g_st.rate, (unsigned)g_st.ch, @@ -1772,7 +1839,8 @@ static void dispatch(struct client *c, uint16_t type, uint32_t req_id, const uin (g_route_manual != -1 ? g_route_manual : rb), vol, volctl_name(), g_lvl_rms_db10, g_lvl_peak_db10, (unsigned)g_lvl_seq, - target_name(), g_bt_codec); + target_name(), bt_state_name(), g_bt_mac[0] ? g_bt_mac : "-", + bttok, g_bt_codec); send_frame(c->fd, MSG_AUDIO_STATE, req_id, txt, (uint32_t)strlen(txt) + 1); break; } @@ -2009,8 +2077,11 @@ static void *route_thread(void *arg) pthread_mutex_lock(&g_mu); int manual = g_route_manual; /* 快照后放锁：amixer popen 不持 g_mu（防 wedge 级联） */ int tgt = g_target; /* 输出目标快照（决定是否武装 FPGA） */ + /* M50：BT 失败回落 DAC 时 **必须武装**（否则 FPGA 未烧 + enable 下开 PCM 会楔死整机）。 + * 只有「请求 BT 且 BT 真的在用」才跳过 numid=9。 */ + int bt_hold = (tgt == AUDIO_OUT_BT && g_bt_state != BT_ST_FAIL); pthread_mutex_unlock(&g_mu); - if (tgt == AUDIO_OUT_BT) { + if (bt_hold) { static int s_logged = 0; if (!s_logged) { s_logged = 1; logmsg("route: output=BT, numid=9/FPGA not armed (DAC dormant)"); } need_arm = 1; /* 回 DAC 后补一次武装 */ diff --git a/patch_v2/meow_audiod/test_audiod_host.c b/patch_v2/meow_audiod/test_audiod_host.c index 1644eaf..2bcaccd 100644 --- a/patch_v2/meow_audiod/test_audiod_host.c +++ b/patch_v2/meow_audiod/test_audiod_host.c @@ -810,6 +810,11 @@ int main(void) check(strstr(q11, "codec=SBC") != NULL, "settings bt.codec=SBC -> codec=SBC"); check(strstr(q11, "volctl=avrcp") != NULL, "bt -> volctl=avrcp (AVRCP vol control)"); check(strstr(q11, "fmt=S16") != NULL, "bt grant fmt=S16 (format normalize)"); + /* M50：BT 运行时状态三键（面板据此显示「输出=蓝牙(失败)」）。FILE sink 从不尝试 BT 打开 + * → bt=idle 且 btdev=-（无端点）；token 由 settings bt.codec=SBC 归一（canonical 同名）。 */ + check(strstr(q11, "bt=idle") != NULL, "bt=idle before any open attempt (FILE sink)"); + check(strstr(q11, "btdev=-") != NULL, "btdev=- when no endpoint opened"); + check(strstr(q11, "btcodec=SBC") != NULL, "btcodec=SBC (settings token normalized)"); /* BT/file sink 写一段流（应正常落盘到 WAV） */ do_write(&b11, pcm, (uint32_t)gen_sine(pcm, sizeof pcm, (int)(ack11.grant_fmt ? ack11.grant_fmt : AUDIO_FMT_S16), 600, 440, 44100)); usleep(150000); diff --git a/patch_v2/meow_audiod/test_bt_dev.c b/patch_v2/meow_audiod/test_bt_dev.c index 6fa1957..cbbd317 100644 --- a/patch_v2/meow_audiod/test_bt_dev.c +++ b/patch_v2/meow_audiod/test_bt_dev.c @@ -1,10 +1,17 @@ -/* test_bt_dev.c — 蓝牙 DEV 自识别宿主验证（纯逻辑，bt_dev.c）。 +/* test_bt_dev.c — 蓝牙端点选择 / PCM 名构造 / 回落退避 宿主验证（纯逻辑，bt_dev.c）。 * - * 覆盖矩阵（对齐任务B 宿主测试要求）： - * D1 bt_dev_detect_mac：a2dpsrc/ 端点 → 提取 MAC（含 a2dp_source、多空行、多设备取第一个、 - * 无 a2dpsrc / 空输出 / NULL → -1）。 - * D2 bt_dev_rewrite：真实 alsa.conf 文本 → DEV=、device 两处 MAC 换成目标，保留 codec/其余 token； - * 同值 → 1（无需改动）；无 pcm.bluealsa / 无 DEV= → -1；带引号风格保留。 + * 输入全部取自**真机实测格式**（bluealsa v4.1.1，设备 /usr/bin/bluealsa 的 + * `dev_%.2X_%.2X_%.2X_%.2X_%.2X_%.2X` + src/ba-transport.c 的 `/a2dpsrc/source`）： + * /org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsrc/source + * + * 覆盖矩阵： + * D1 bt_dev_detect_mac：真实 D-Bus 路径 → MAC；多端点/多设备取第一个 a2dpsrc； + * hfphf/a2dpsnk 不算；简化 `a2dpsrc/` 兼容；空/无源端点/NULL/坏 dev_ 段 → -1。 + * D2 bt_dev_count_src：0/1/2 个源端点。 + * D3 bt_dev_codec_token：settings bt.codec → bluealsa canonical（4.1.1 别名表 strcasecmp）； + * auto/空/unchanged/垃圾 → unchanged。 + * D4 bt_dev_pcm_name：内联 DEV/PROFILE/CODEC；坏 MAC/小缓冲 → -1。 + * D5 bt_dev_backoff_ms / should_try：2s→60s 封顶 + 门控（防重试风暴）。 * * 编译（在 patch_v2/meow_audiod 下）： * cc -Wall -Wextra -o test_bt_dev test_bt_dev.c bt_dev.c @@ -26,91 +33,149 @@ int main(void) { setbuf(stdout, NULL); - /* ---- D1 设备列表 → 选中 a2dpsrc 连接设备 ---- */ + /* ==== D1 设备列表 → 选中 a2dpsrc 连接设备（真实 D-Bus 路径格式） ==== */ { char mac[32] = ""; int rc = bt_dev_detect_mac( - "a2dpsrc/E0:42:6D:79:C5:98\na2dpsnk/E0:42:6D:79:C5:98\n", mac, sizeof mac); - check(rc == 0 && strcmp(mac, "E0:42:6D:79:C5:98") == 0, "D1a a2dpsrc/ -> extract MAC"); + "/org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsrc/source\n", mac, sizeof mac); + check(rc == 0 && strcmp(mac, "33:DE:2E:21:AD:30") == 0, + "D1a real D-Bus path -> MAC (dev_ underscores -> colons)"); } { char mac[32] = ""; int rc = bt_dev_detect_mac( - "profile/aptx\n\na2dp_source/33:DE:2E:21:AD:30\n", mac, sizeof mac); - check(rc == 0 && strcmp(mac, "33:DE:2E:21:AD:30") == 0, "D1b a2dp_source/ -> extract MAC"); + "/org/bluealsa/hci0/dev_E0_42_6D_79_C5_98/hfphf/source\n" + "/org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsnk/sink\n" + "/org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsrc/source\n", mac, sizeof mac); + check(rc == 0 && strcmp(mac, "33:DE:2E:21:AD:30") == 0, + "D1b hfphf/a2dpsnk skipped -> first a2dpsrc"); } { char mac[32] = ""; int rc = bt_dev_detect_mac( - "a2dpsrc/AA:BB:CC:DD:EE:FF 0\na2dpsrc/11:22:33:44:55:66 1\n", mac, sizeof mac); + "/org/bluealsa/hci0/dev_AA_BB_CC_DD_EE_FF/a2dpsrc/source\n" + "/org/bluealsa/hci0/dev_11_22_33_44_55_66/a2dpsrc/source\n", mac, sizeof mac); check(rc == 0 && strcmp(mac, "AA:BB:CC:DD:EE:FF") == 0, "D1c multi-device -> first a2dpsrc"); } { char mac[32] = ""; - int rc = bt_dev_detect_mac("\n", mac, sizeof mac); - check(rc == -1, "D1d empty output -> -1"); + int rc = bt_dev_detect_mac("a2dpsrc/E0:42:6D:79:C5:98\n", mac, sizeof mac); + check(rc == 0 && strcmp(mac, "E0:42:6D:79:C5:98") == 0, "D1d legacy a2dpsrc/ still parsed"); } { char mac[32] = ""; - int rc = bt_dev_detect_mac("a2dpsnk/11:22:33:44:55:66\n", mac, sizeof mac); - check(rc == -1, "D1e only sink (no a2dpsrc) -> -1"); + int rc = bt_dev_detect_mac("", mac, sizeof mac); + check(rc == -1, "D1e empty output -> -1"); + } + { + char mac[32] = ""; + int rc = bt_dev_detect_mac( + "/org/bluealsa/hci0/dev_11_22_33_44_55_66/a2dpsnk/sink\n", mac, sizeof mac); + check(rc == -1, "D1f only sink (no a2dpsrc) -> -1"); } { char mac[32] = ""; int rc = bt_dev_detect_mac(NULL, mac, sizeof mac); - check(rc == -1, "D1f NULL input -> -1"); + check(rc == -1, "D1g NULL input -> -1"); + } + { + char mac[32] = ""; + int rc = bt_dev_detect_mac( + "/org/bluealsa/hci0/dev_ZZ_42_6D_79_C5_98/a2dpsrc/source\n", mac, sizeof mac); + check(rc == -1 && mac[0] == 0, "D1h malformed dev_ seg -> -1 (no garbage MAC)"); + } + { + char mac[32] = ""; + int rc = bt_dev_detect_mac( + "/org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsrc/source 1\n", mac, sizeof mac); + check(rc == 0 && strcmp(mac, "33:DE:2E:21:AD:30") == 0, "D1i trailing token tolerated"); } - /* ---- D2 DEV 串入 / 保留其它 token ---- */ + /* ==== D2 源端点计数（有无 A2DP 端点的快速判定） ==== */ + check(bt_dev_count_src("") == 0, "D2a empty -> 0"); + check(bt_dev_count_src( + "/org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsnk/sink\n") == 0, + "D2b only sink -> 0"); + check(bt_dev_count_src( + "/org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsrc/source\n") == 1, + "D2c one a2dpsrc -> 1"); + check(bt_dev_count_src( + "/org/bluealsa/hci0/dev_AA_BB_CC_DD_EE_FF/a2dpsrc/source\n" + "/org/bluealsa/hci0/dev_11_22_33_44_55_66/a2dpsrc/source\n") == 2, + "D2d two a2dpsrc -> 2"); + + /* ==== D3 settings bt.codec → bluealsa canonical token ==== */ { - const char *conf = - "pcm.bluealsa:DEV=E0:42:6D:79:C5:98 {\n" - " type plug\n" - " slave {\n" - " pcm {\n" - " type bluealsa\n" - " device E0:42:6D:79:C5:98\n" - " profile \"a2dp\"\n" - " codec \"LDAC\"\n" - " ldac_eqmid \"LDAC_ABR\"\n" - " }\n" - " }\n" - "}\n"; - char *out = NULL; size_t olen = 0; - int rc = bt_dev_rewrite(conf, strlen(conf), "33:DE:2E:21:AD:30", &out, &olen); - check(rc == 0 && out != NULL, "D2a rewrite returns changed"); - check(out && strstr(out, ":DEV=33:DE:2E:21:AD:30 {"), "D2b DEV= updated"); - check(out && strstr(out, "device 33:DE:2E:21:AD:30\n"), "D2c device updated"); - check(out && strstr(out, "codec \"LDAC\"") && strstr(out, "ldac_eqmid \"LDAC_ABR\""), - "D2d codec/other tokens preserved"); - /* 旧 MAC 不再出现 */ - check(out && !strstr(out, "E0:42:6D:79:C5:98"), "D2e old MAC gone"); - free(out); - } - { - const char *conf = - "pcm.bluealsa:DEV=33:DE:2E:21:AD:30 {\n" - " type plug\n slave {\n pcm {\n" - " type bluealsa\n device 33:DE:2E:21:AD:30\n" - " profile \"a2dp\"\n codec \"LDAC\"\n }\n }\n}\n"; - char *out = NULL; size_t olen = 0; - int rc = bt_dev_rewrite(conf, strlen(conf), "33:DE:2E:21:AD:30", &out, &olen); - check(rc == 1 && out == NULL, "D2f same MAC -> unchanged (idempotent)"); - } - { - const char *conf = "pcm.bluealsa {\n type bluealsa\n device \"E0:42:6D:79:C5:98\"\n}\n"; - char *out = NULL; size_t olen = 0; - int rc = bt_dev_rewrite(conf, strlen(conf), "33:DE:2E:21:AD:30", &out, &olen); - check(rc == 0 && out && strstr(out, "device \"33:DE:2E:21:AD:30\""), - "D2g quoted device preserved (no DEV= token)"); - free(out); - } - { - char *out = NULL; size_t olen = 0; - int rc = bt_dev_rewrite("pcm.hw {\n type hw\n}\n", 21, "33:DE:2E:21:AD:30", &out, &olen); - check(rc == -1 && out == NULL, "D2h no pcm.bluealsa -> -1"); + struct { const char *in; const char *want; const char *name; } t[] = { + { "LDAC", "LDAC", "D3a LDAC passthrough" }, + { "ldac", "LDAC", "D3b lowercase ldac -> canonical" }, + { "SBC", "SBC", "D3c SBC" }, + { "AAC", "AAC", "D3d AAC" }, + { "MPEG24", "AAC", "D3e MPEG24 alias -> AAC" }, + { "aptX", "aptX", "D3f aptX" }, + { "apt-X", "aptX", "D3g apt-X alias -> aptX" }, + { "aptx-hd", "aptX-HD", "D3h aptx-hd -> aptX-HD" }, + { "MPEG", "MP3", "D3i MPEG alias -> MP3" }, + { "MP3", "MP3", "D3j MP3" }, + { "FastStream", "FastStream", "D3k FastStream" }, + { "FS", "FastStream", "D3l FS alias -> FastStream" }, + { "auto", "unchanged", "D3m auto -> unchanged (do not touch negotiation)" }, + { "", "unchanged", "D3n empty -> unchanged" }, + { "unchanged", "unchanged", "D3o unchanged -> unchanged" }, + { "BOGUS", "unchanged", "D3p unknown -> unchanged (never inject junk)" }, + }; + for (size_t i = 0; i < sizeof t / sizeof t[0]; i++) { + char tok[16] = ""; + const char *r = bt_dev_codec_token(t[i].in, tok, sizeof tok); + check(r == tok && strcmp(tok, t[i].want) == 0, t[i].name); + } + char tok[16] = ""; + check(bt_dev_codec_token(NULL, tok, sizeof tok) == tok && !strcmp(tok, "unchanged"), + "D3q NULL setting -> unchanged"); } - printf(g_fail ? "\nRESULT: %d FAIL(S)\n" : "\nRESULT: ALL PASS\n", g_fail); - return g_fail; + /* ==== D4 PCM 名构造（20-bluealsa.conf @args 只认 DEV/PROFILE/CODEC 这套名字） ==== */ + { + char n[96] = ""; + int rc = bt_dev_pcm_name("33:DE:2E:21:AD:30", "LDAC", n, sizeof n); + check(rc == 0 && strcmp(n, "bluealsa:DEV=33:DE:2E:21:AD:30,PROFILE=a2dp,CODEC=LDAC") == 0, + "D4a name = bluealsa:DEV=,PROFILE=a2dp,CODEC="); + } + { + char n[96] = ""; + int rc = bt_dev_pcm_name("33:DE:2E:21:AD:30", "", n, sizeof n); + check(rc == 0 && strstr(n, "CODEC=unchanged") != NULL, "D4b empty token -> CODEC=unchanged"); + } + { + char n[96] = ""; + int rc = bt_dev_pcm_name("33:DE:2E:21:AD:30", NULL, n, sizeof n); + check(rc == 0 && strstr(n, "CODEC=unchanged") != NULL, "D4c NULL token -> CODEC=unchanged"); + } + { + char n[96] = ""; + check(bt_dev_pcm_name("33:DE:2E:21:AD", "LDAC", n, sizeof n) == -1, "D4d short MAC -> -1"); + check(bt_dev_pcm_name("GG:DE:2E:21:AD:30", "LDAC", n, sizeof n) == -1, "D4e non-hex MAC -> -1"); + check(bt_dev_pcm_name(NULL, "LDAC", n, sizeof n) == -1, "D4f NULL MAC -> -1"); + check(bt_dev_pcm_name("33:DE:2E:21:AD:30", "LDAC", n, 16) == -1, "D4g tiny buffer -> -1"); + } + + /* ==== D5 回落退避（防重试风暴：M10 教训） ==== */ + check(bt_dev_backoff_ms(0) == 0, "D5a fails=0 -> 0ms (immediate)"); + check(bt_dev_backoff_ms(1) == 2000, "D5b fails=1 -> 2s"); + check(bt_dev_backoff_ms(2) == 4000, "D5c fails=2 -> 4s"); + check(bt_dev_backoff_ms(3) == 8000, "D5d fails=3 -> 8s"); + check(bt_dev_backoff_ms(4) == 16000, "D5e fails=4 -> 16s"); + check(bt_dev_backoff_ms(5) == 32000, "D5f fails=5 -> 32s"); + check(bt_dev_backoff_ms(6) == 60000, "D5g fails=6 -> 60s (capped)"); + check(bt_dev_backoff_ms(99) == 60000, "D5h fails=99 -> 60s (capped)"); + check(bt_dev_should_try(0, 0) == 1, "D5i never failed -> try now"); + check(bt_dev_should_try(1, 1999) == 0, "D5j fail#1 @1999ms -> gated"); + check(bt_dev_should_try(1, 2000) == 1, "D5k fail#1 @2000ms -> allowed"); + check(bt_dev_should_try(3, 7999) == 0, "D5l fail#3 @7999ms -> gated"); + check(bt_dev_should_try(3, 8000) == 1, "D5m fail#3 @8000ms -> allowed"); + check(bt_dev_should_try(2, -1) == 1, "D5n clock anomaly (negative) -> allowed (no deadlock)"); + + printf(g_fail ? "\nRESULT: %d FAIL(S)\n" : "\nRESULT: ALL PASS (%d checks)\n", + g_fail ? g_fail : g_pass); + return g_fail ? 1 : 0; }