AskaEth/MeowOS-For-R3P2
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(audiod): M50 r3 评审 P2 三条 — fd 卫生 / 端点路径按 MAC 精确匹配 / 多 ACL 逐个试开

Browse Source 
评审 r1（p2-3items/merge，reviewed 26c6077）三条：

① P2-1 dev_close() 在「BT 写路径判死 → 回落」这条路上会 close(0) 误关 stdin：
   播放线程处理 g_bt_fail_req 时**提前把 g_bt_dev 清 0**，下拍 dev_close() 就落到
   close(g_dev_fd) 分支，而 BT 打开成功时 dev_open() 返回 0（g_dev_fd==0）。
   - 去掉那行提前清零（让 dev_close 走 BT 分支自己清），并同时置 g_dev_fd = -1 做第二道保险；
   - 把关闭决策抽成纯函数 bt_dev_close_kind(bt_dev, fd)（0=NONE/1=BT/2=FD）：**fd 0/1/2
     一律不当设备 fd 关**，宿主单测 D10 覆盖（含 bt_dev=0+fd=0 这条回归用例）；
   - 补不变式「设备 fd 恒 >2」：dev_open 的 DAC/WAV open 过 fd_high()（0..2 时 F_DUPFD 升位，
     dup 失败则关掉并报打开失败——绝不留 stdio 区间里没人认领的设备 fd）；
   - dev_close 注释改成诚实版：不再声称「已消除」，写明「BT 分支内自行清理；调用方不得
     提前清 g_bt_dev」。

② P2-2 g_bt_pcm 只写一次 → 换耳机 A→B 后 volume/info 打在 A 的端点上：
   - bt_refresh_endpoint() 每次先清空再探测，并用新 bt_dev_pick_endpoint() **按 g_bt_mac
     精确挑端点**（找不到就留空，宁可跳过 volume/info 也不串台）；
   - bt_vol_full() 删除「拿 list-pcms 第一条端点凑数」的兜底（同样会串台）；
   - 单测 D9：两条端点里按 MAC 分别取 A/B、未知 MAC 返回 -1。

③ P2-3 bt_dev_acl_mac() 只取第一条 ACL，多设备（手机/手柄并存，M49 正在测 BT 控制面）
   会挑错设备 → 耳机连着却回落 DAC：
   - 改名/重写为 bt_dev_acl_macs()：收集**全部** ACL MAC（去重、上限由调用方给）；
   - bt_find_mac() → bt_collect_candidates()：①list-pcms 里已有端点的设备优先（真 A2DP）
     ②其后全部 ACL 设备；候选按可信度排序、去重；
   - bt_try_open() 改为对候选**轮流试开**，3 次尝试、300ms 间隔（1 候选=A,A,A 与 r2 语义
     相同；2 候选=A,B,A；3 候选=A,B,C），仍受退避门控；**删除裸 "bluealsa" 兜底**
     （那会落到「最近连接」的错设备，review §P2-3 明确指出）；
   - 单测 D8c/D8d：两条 ACL 全取到且保序、三条含重复时去重并受上限裁剪。

顺带清死代码（评审「其余观察 2」）：删除 bt_dev_count_src()、bt_dev_endpoint_path()
（生产路径已无调用者，前者早已只剩单测）。

宿主：test_bt_dev 71/71（新增 D8c/D8d/D9/D10 共 10 条），test_audiod_host 109/0，
交叉编译 0 warning（68604B，md5 9f58b2197ed91d24951918d41a78cf29，NEEDED 三条、
interpreter /lib/ld.so.1、GLIBC≤2.17），test_time32_abi.sh --builds 里
`build meow_audio src=yes macro=yes` 保持。真机项（耳机）未动：本轮不连蓝牙、不扫设备。
This commit is contained in:
AskaEth committed 2026-11-11 19:37:03 +08:00
1 parent 6e7c0d00c0
commit 6e67c74fe6
4 files changed
+222 -168
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

patch_v2/meow_audiod/bt_dev.c
+52 -45
View File
@@ -26,17 +26,21 @@ static int line_is_src(const char *ln)
return strstr(p, "a2dpsrc") != NULL || strstr(p, "a2dp_source") != NULL;
}
/* 从 `hcitool con` 输出取第一条 ACL 连接的对端 BD_ADDR。
/* 从 `hcitool con` 输出收集**所有** ACL 连接的对端 BD_ADDR（按出现顺序去重）。
* 内核 ACL 是「设备是否真的连着」的权威（M45/M49 结论）；bluealsa 的 list-pcms 只在
* profile 配置好后的**秒级窗口**里存在，不能当 MAC 的唯一来源（M50 真机实测）。
* ⚠️ 多条 ACL 是常态（手机/手柄/第二个耳机同时连着）——**不能只取第一条**：
* 取错设备会 snd_pcm_open 失败 → 有耳机却回落 DAC（M50 r1 评审 P2-3）。
* 行形如：`\t< ACL 33:DE:2E:21:AD:30 handle 12 state 1 lm MASTER AUTH ENCRYPT`
* 返回 0=找到（17 字符大写冒号分隔），-1=无 ACL 连接/参数非法。 */
int bt_dev_acl_mac(const char *hcitool_con, char *mac, size_t macsz)
* 返回找到的条数（0=无 ACL 连接）。macs 是 [max][18] 的二维数组，元素写成 NUL 结尾
* 17 字符大写冒号 MAC。 */
int bt_dev_acl_macs(const char *hcitool_con, char (*macs)[18], int max)
{
if (!hcitool_con || !mac || macsz < 18) return -1;
mac[0] = 0;
if (!hcitool_con || !macs || max <= 0) return 0;
for (int i = 0; i < max; i++) macs[i][0] = 0;
int n = 0;
const char *ln = hcitool_con;
while (ln && *ln) {
while (ln && *ln && n < max) {
const char *nl = strchr(ln, '\n');
const char *le = nl ? nl : (ln + strlen(ln));
size_t linelen = (size_t)(le - ln);
@@ -44,8 +48,7 @@ int bt_dev_acl_mac(const char *hcitool_con, char *mac, size_t macsz)
if (linelen >= sizeof line) linelen = sizeof line - 1;
memcpy(line, ln, linelen); line[linelen] = 0;
if (strstr(line, "ACL")) {
/* 行内找合法的 MAC token（6 组 2 位十六进制，冒号分隔） */
for (const char *p = line; *p; p++) {
for (const char *p = line; *p && n < max; p++) {
int ok = 1;
for (int i = 0; i < 17 && ok; i++) {
if ((i % 3) == 2) { if (p[i] != ':') ok = 0; }
@@ -54,24 +57,27 @@ int bt_dev_acl_mac(const char *hcitool_con, char *mac, size_t macsz)
if (!((c >= '0' && c <= '9') || (c >= 'A' && c <= 'F') || (c >= 'a' && c <= 'f'))) ok = 0;
}
}
/* 必须是完整 token：前一个字符不是十六进制/冒号，后一个不是 */
if (ok && (p == line || !(p[-1] == ':' || (p[-1] >= '0' && p[-1] <= '9') ||
(p[-1] >= 'A' && p[-1] <= 'F') || (p[-1] >= 'a' && p[-1] <= 'f')))
&& !(p[17] == ':' || (p[17] >= '0' && p[17] <= '9') ||
(p[17] >= 'A' && p[17] <= 'F') || (p[17] >= 'a' && p[17] <= 'f'))) {
for (int i = 0; i < 17; i++) {
char c = p[i];
mac[i] = (c >= 'a' && c <= 'f') ? (char)(c - 'a' + 'A') : c;
}
mac[17] = 0;
return 0;
if (!ok ||
!(p == line || !(p[-1] == ':' || (p[-1] >= '0' && p[-1] <= '9') ||
(p[-1] >= 'A' && p[-1] <= 'F') || (p[-1] >= 'a' && p[-1] <= 'f'))) ||
(p[17] == ':' || (p[17] >= '0' && p[17] <= '9') ||
(p[17] >= 'A' && p[17] <= 'F') || (p[17] >= 'a' && p[17] <= 'f')))
continue;
char mac[18];
for (int i = 0; i < 17; i++) {
char c = p[i];
mac[i] = (c >= 'a' && c <= 'f') ? (char)(c - 'a' + 'A') : c;
}
mac[17] = 0;
int dup = 0; /* 同一设备可能在多行/多 profile 出现 */
for (int i = 0; i < n; i++) if (strcmp(macs[i], mac) == 0) { dup = 1; break; }
if (!dup) memcpy(macs[n++], mac, 18);
}
}
if (!nl) break;
ln = nl + 1;
}
return -1;
return n;
}
/* 从 D-Bus 对象路径取 MAC。bluealsa 4.1.1 的 PCM 路径是
@@ -163,37 +169,27 @@ int bt_dev_detect_mac(const char *listpcms, char *mac, size_t macsz)
return -1;
}
int bt_dev_count_src(const char *listpcms)
/* 在 list-pcms 里按「设备 MAC」精确挑端点路径（A→B 换耳机后不能拿 A 的路径去发 volume/info）。
* 返回 0=找到（写到 out），-1=列表里没有该 MAC 的端点。 */
int bt_dev_pick_endpoint(const char *listpcms, const char *mac, char *out, size_t outsz)
{
if (!listpcms) return 0;
int n = 0;
const char *ln = listpcms;
while (ln && *ln) {
const char *nl = strchr(ln, '\n');
if (line_is_src(ln)) n++;
if (!nl) break;
ln = nl + 1;
}
return n;
}
/* 取第一个 a2dpsrc/a2dp_source 端点的**完整 D-Bus 路径**（`bluealsa-cli volume|info` 要的就是它，
* 不是 MAC）。行内按空白截断（含 \r，防 CRLF 把换行带进命令）；越界/无端点 → -1。 */
int bt_dev_endpoint_path(const char *listpcms, char *out, size_t outsz)
{
if (!listpcms || !out || outsz < 2) return -1;
if (!listpcms || !mac || !mac[0] || !out || outsz < 2) return -1;
out[0] = 0;
const char *ln = listpcms;
while (ln && *ln) {
const char *nl = strchr(ln, '\n');
const char *p = ln;
while (*p == ' ' || *p == '\t') p++;
if (line_is_src(ln)) {
const char *le = nl ? nl : (ln + strlen(ln));
size_t linelen = (size_t)(le - ln);
char line[256], lmac[18];
if (linelen >= sizeof line) linelen = sizeof line - 1;
memcpy(line, ln, linelen); line[linelen] = 0;
if (line_is_src(line) && parse_dev_seg(line, lmac, sizeof lmac) == 0 &&
strcasecmp(lmac, mac) == 0) {
const char *p = line;
while (*p == ' ' || *p == '\t') p++;
size_t n = 0;
while (p[n] && p[n] != ' ' && p[n] != '\t' && p[n] != '\n' && p[n] != '\r' && n + 1 < outsz) {
out[n] = p[n];
n++;
}
while (p[n] && p[n] != ' ' && p[n] != '\t' && p[n] != '\n' && p[n] != '\r' &&
n + 1 < outsz) { out[n] = p[n]; n++; }
out[n] = 0;
return n ? 0 : -1;
}
@@ -203,6 +199,17 @@ int bt_dev_endpoint_path(const char *listpcms, char *out, size_t outsz)
return -1;
}
/* 关闭决策（纯函数，宿主可单测）：当前「设备」该关谁。
* bt_dev=1 → 关 BT PCM（句柄在 audiod 的 g_bt_hdl），**不碰 fd**；
* 否则 fd>2 才当设备 fd 关；**0/1/2 一律不动**——BT 打开成功时 dev_open() 返回 0，
* 任何「提前清 bt_dev」的路径都会落到 close(g_dev_fd) 上误关 stdin（M50 r1 评审 P2-1）。
* 返回 0=NONE / 1=BT / 2=FD。 */
int bt_dev_close_kind(int bt_dev, int fd)
{
if (bt_dev) return 1;
return fd > 2 ? 2 : 0;
}
/* 从 `bluealsa-cli info <path>` 输出取实际协商到的 codec（"Selected codec: AAC" → "AAC"）。
* 只认行首 "Selected codec:"（"Available codecs: SBC AAC" 那行不能误匹配）。 */
int bt_dev_info_codec(const char *info_out, char *out, size_t outsz)
patch_v2/meow_audiod/bt_dev.h
+12 -10
View File
@@ -20,9 +20,11 @@
#include <stddef.h>
/* 从 `hcitool con` 输出取第一条 ACL 连接的对端 BD_ADDR（**MAC 主来源**：内核 ACL 是连接权威，
* list-pcms 只在 profile 配置后的秒级窗口内存在）。返回 0=找到，-1=无 ACL/参数非法。 */
int bt_dev_acl_mac(const char *hcitool_con, char *mac, size_t macsz);
/* 从 `hcitool con` 输出收集**所有** ACL 连接的对端 BD_ADDR（按出现顺序去重；MAC 主来源：
* 内核 ACL 是连接权威，list-pcms 只在 profile 配置后的秒级窗口内存在）。
* 多设备是常态，调用方要**逐个试开**而不是只取第一条（M50 r1 评审 P2-3）。
* macs 为 [max][18]；返回条数（0=无 ACL）。 */
int bt_dev_acl_macs(const char *hcitool_con, char (*macs)[18], int max);
/* 解析 bluealsa-cli list-pcms 输出，取第一个 a2dpsrc/a2dp_source 端点的设备 MAC
* （**兜底来源**：list-pcms 可见时用）。
@@ -32,14 +34,14 @@ int bt_dev_acl_mac(const char *hcitool_con, char *mac, size_t macsz);
* macsz ≥ 18。 */
int bt_dev_detect_mac(const char *listpcms, char *mac, size_t macsz);
/* 统计 list-pcms 输出里的 a2dpsrc/a2dp_source 端点数（0=无可用 A2DP 源端点）。
* 用于「先探测端点、再决定是否打开」——无端点时省掉一次注定失败的 open。 */
int bt_dev_count_src(const char *listpcms);
/* 取 list-pcms 里第一个 a2dpsrc/a2dp_source 端点的完整 D-Bus 路径
* （/org/bluealsa/hci0/dev_XX_../a2dpsrc/sink）——`bluealsa-cli volume|info` 要的是它，不是 MAC。
* 返回 0=写好（out NUL 结尾），-1=无端点/参数非法。outsz 建议 ≥96。 */
int bt_dev_endpoint_path(const char *listpcms, char *out, size_t outsz);
/* 在 list-pcms 里按设备 MAC 精确挑端点路径（换耳机 A→B 后不能拿 A 的路径发 volume/info）。
* 返回 0=找到，-1=该 MAC 无端点。 */
int bt_dev_pick_endpoint(const char *listpcms, const char *mac, char *out, size_t outsz);
/* 关闭决策（纯函数）：bt_dev=1 → 关 BT PCM；否则 fd>2 才关；0/1/2 一律不动（护 stdin）。
* 返回 0=NONE / 1=BT / 2=FD。 */
int bt_dev_close_kind(int bt_dev, int fd);
/* 从 `bluealsa-cli info` 输出取实际协商 codec：行首 "Selected codec: AAC" → "AAC"。
* 返回 0=找到，-1=无该行/参数非法。 */
patch_v2/meow_audiod/meow_audiod.c
+89 -53
View File
@@ -82,7 +82,6 @@
* @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，不存在则跳过） */
@@ -976,39 +975,52 @@ static void bt_note_ok(void)
g_bt_fail_n = 0;
}
/* 找「现在要往哪台设备播」的 MAC。**主来源 = 内核 ACL（hcitool con）**：
* 这是「耳机真的连着」的权威，且开销极小；bluealsa 的 list-pcms 只在 profile 配置后的
* 秒级窗口里才列出端点（M50 真机：无人开 PCM 时 1~3s 就消失），**不能当唯一来源**
* （否则探针一错过窗口就 bt=fail 回落）。list-pcms 仅作兜底，并顺手记下端点 D-Bus 路径
* （volume/info 要用；PCM 被撑住后它才稳定，见 bt_refresh_endpoint）。
* 返回 1=找到 MAC（写入 mac），0=当前没有可播的蓝牙设备。 */
static int bt_find_mac(char *mac, size_t macsz)
/* 收集「可以试着往它播」的设备 MAC 候选（按可信度排序，去重）：
* ① list-pcms 里**已经存在端点**的设备 —— 那就是真的 A2DP 连接（最可信，窗口内命中时用它）；
* ② `hcitool con` 的**全部** ACL 设备 —— 内核权威，覆盖「profile 还没配置好、端点还没出现」。
* ⚠️ 多条 ACL 是常态（手机/手柄/第二副耳机）；只取第一条会挑错设备 → 耳机连着却回落 DAC
* （M50 r1 评审 P2-3）。候选交给 bt_try_open 逐个试开（上限 3 次尝试）。
* 返回候选数（0=当前没有可播的蓝牙设备）。 */
static int bt_collect_candidates(char (*cand)[18], int max)
{
if (mac && macsz) mac[0] = 0;
char *o = popen_read_tmo(1200, "hcitool con 2>/dev/null");
if (o && bt_dev_acl_mac(o, mac, macsz) == 0) {
logmsg("bt: ACL device %s (source=hcitool con)", mac);
return 1;
if (!cand || max <= 0) return 0;
int n = 0;
char *o = popen_read_tmo(1500, "bluealsa-cli list-pcms 2>/dev/null");
if (o && o[0]) {
char m[18];
if (bt_dev_detect_mac(o, m, sizeof m) == 0) {
memcpy(cand[n++], m, 18);
logmsg("bt: candidate#%d %s (source=list-pcms endpoint)", n, m);
}
}
o = popen_read_tmo(1500, "bluealsa-cli list-pcms 2>/dev/null");
if (!o) { logmsg("bt: no ACL and no bluealsa-cli"); return 0; }
char path[128];
if (bt_dev_endpoint_path(o, path, sizeof path) == 0) snprintf(g_bt_pcm, sizeof g_bt_pcm, "%s", path);
if (bt_dev_detect_mac(o, mac, macsz) == 0) {
logmsg("bt: a2dp dev %s (source=list-pcms fallback)", mac);
return 1;
o = popen_read_tmo(1200, "hcitool con 2>/dev/null");
if (o) {
char macs[4][18];
int k = bt_dev_acl_macs(o, macs, 4);
for (int i = 0; i < k && n < max; i++) {
int dup = 0;
for (int j = 0; j < n; j++) if (strcmp(cand[j], macs[i]) == 0) { dup = 1; break; }
if (dup) continue;
memcpy(cand[n++], macs[i], 18);
logmsg("bt: candidate#%d %s (source=hcitool con ACL)", n, macs[i]);
}
}
return 0;
return n;
}
/* PCM 已打开后刷新端点路径（此时 bluealsa 的端点对象是稳定的），供 info/volume 用。 */
/* 用当前 g_bt_mac 精确刷新端点路径（PCM 已打开后 bluealsa 端点对象才稳定）。
* **必须按 MAC 匹配**：换耳机 A→B 后若沿用 A 的路径，volume/info 会打到旧设备上
* （M50 r1 评审 P2-2）。找不到本设备的端点就留空（宁可跳过 volume/info 也不串台）。 */
static void bt_refresh_endpoint(void)
{
if (g_bt_pcm[0]) return;
g_bt_pcm[0] = 0;
char *o = popen_read_tmo(1500, "bluealsa-cli list-pcms 2>/dev/null");
if (!o) return;
char path[128];
if (bt_dev_endpoint_path(o, path, sizeof path) == 0) snprintf(g_bt_pcm, sizeof g_bt_pcm, "%s", path);
if (bt_dev_pick_endpoint(o, g_bt_mac, path, sizeof path) == 0)
snprintf(g_bt_pcm, sizeof g_bt_pcm, "%s", path);
else
logmsg("bt: endpoint for %s not listed yet (volume/info skipped)", g_bt_mac);
}
/* 按 PCM 名打开（libasound → NONBLOCK open + set_params S16/RW/ch/rate/soft_resample/100ms）。
@@ -1053,28 +1065,29 @@ static int bt_try_open(void)
g_bt_fail_n, bt_dev_backoff_ms(g_bt_fail_n), since);
return -1;
}
char mac[20] = "";
if (!bt_find_mac(mac, sizeof mac)) { bt_note_fail("no connected BT device (hcitool con empty)"); return -1; }
snprintf(g_bt_mac, sizeof g_bt_mac, "%s", mac);
char cand[3][18];
int ncand = bt_collect_candidates(cand, 3);
if (ncand <= 0) { bt_note_fail("no BT device (no a2dp endpoint, no ACL)"); return -1; }
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 device MAC"); return -1; }
logmsg("bt: try open %s (codec setting=%s -> token=%s)", name, g_bt_codec, g_bt_tok);
/* 3 次 × 300ms 短重试：ACL 刚建立时 BlueZ 可能还没把 A2DP profile 配置完，
* 这一下会返回 ENODEV/EBUSY；等 300ms 再来通常就通了。3 次仍失败才记账进退避
* （短重试上限 600ms，不会在播放线程里形成长时间阻塞）。 */
/* 3 次尝试、每次间隔 300ms（ACL 刚建立时 BlueZ 可能还没配置完 A2DP profile，等一拍就通）。
* 多候选时轮流试：1 个候选→A,A,A（=r2 语义）；2 个→A,B,A；3 个→A,B,C。
* 候选都来自「真的连着」的集合，每次尝试都有意义；总耗时上限 ≈600ms + open 时延。
* **不再用裸 "bluealsa" 兜底**：那会落到「最近连接」的设备上，多设备时等于挑错人。 */
const char *opened = NULL;
for (int i = 0; i < 3 && !opened; i++) {
if (i) {
struct timespec ts = { 0, 300 * 1000000L };
nanosleep(&ts, NULL);
const char *mac = cand[i % ncand];
if (i) { struct timespec ts = { 0, 300 * 1000000L }; nanosleep(&ts, NULL); }
char name[96];
if (bt_dev_pcm_name(mac, g_bt_tok, name, sizeof name) != 0) continue;
logmsg("bt: try#%d open %s (codec setting=%s -> token=%s)", i + 1, name, g_bt_codec, g_bt_tok);
if (bt_open_pcm(name) == 0) {
opened = name;
snprintf(g_bt_mac, sizeof g_bt_mac, "%s", mac);
}
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_fail("snd_pcm_open/set_params failed (3 tries)"); return -1; }
bt_note_ok();
bt_refresh_endpoint(); /* PCM 已撑住：端点对象稳定，取路径给 info/volume */
bt_refresh_endpoint(); /* 端点对象此时稳定；按 MAC 精确取路径（换设备不串台） */
bt_read_used_codec();
g_bt_vol_full_done = 0; /* 新设备/PCM：允许再促成一次 AVRCP 满量程 */
bt_vol_full();
@@ -1158,15 +1171,11 @@ static void bt_vol_full(void)
{
if (g_bt_vol_full_done) return;
g_bt_vol_full_done = 1;
/* 只用 bt_refresh_endpoint() 按 MAC 精确取到的路径；为空就**跳过**——
* 宁可这一次不顶音量，也不拿别的设备的端点发 volume（换耳机 A→B 串台，评审 P2-2）。 */
char pcm[128];
snprintf(pcm, sizeof pcm, "%s", g_bt_pcm); /* bt_probe 已取到端点路径（省一次 popen） */
if (!pcm[0]) {
char *o = popen_read_tmo(1500, "bluealsa-cli list-pcms 2>/dev/null");
if (!o) { logmsg("bt: avrcp set-max skipped (no bluealsa-cli)"); return; }
if (bt_dev_endpoint_path(o, pcm, sizeof pcm) != 0) {
logmsg("bt: avrcp set-max skipped (no a2dpsrc pcm found)"); return;
}
}
snprintf(pcm, sizeof pcm, "%s", g_bt_pcm);
if (!pcm[0]) { logmsg("bt: avrcp set-max skipped (no endpoint path for %s)", g_bt_mac); return; }
char cmd[256];
snprintf(cmd, sizeof cmd, "%s volume %s 127 >/dev/null 2>&1", BT_VOL_FULL_PCM, pcm);
char *r = popen_read_tmo(1500, cmd);
@@ -1392,6 +1401,24 @@ static void dac_fallback_arm(void)
apply_route(port);
}
/* 把设备 fd 升到 ≥3：BT 打开成功时 dev_open() 返回 0，而 0/1/2 是 stdio——把设备 fd
* 钉在 0..2 上等于给「谁误清了 g_bt_dev」埋地雷（dev_close 的 close_kind 守卫会跳过 0..2）。
* open() 只在 stdio 被关掉时才可能返回 <3；这里 dup 一次让「设备 fd 恒 >2」成为不变式。
* dup 也失败（极端 EMFILE）时把原 fd 关掉并报失败——绝不留一个「在 stdio 区间又没人认领」
* 的设备 fd（那会变成打开的设备泄漏，比关一次 stdin 更糟）。 */
static int fd_high(int fd)
{
if (fd < 0 || fd > 2) return fd;
int nfd = fcntl(fd, F_DUPFD, 3);
if (nfd < 0) {
logmsg("fd %d in stdio range and dup failed: %s -> treat as open failure", fd, strerror(errno));
close(fd);
return -1;
}
close(fd);
return nfd;
}
static int dev_open(void)
{
/* 输出目标=BT 且走真机 ALSA：打开 libasound 的 bluealsa PCM（内联 DEV/CODEC，不开 hw:0,0）。
@@ -1411,7 +1438,7 @@ static int dev_open(void)
#ifdef AUDIOD_HAVE_ALSA
/* O_NONBLOCK：写路径走 poll(POLLOUT)+限时（dev_write），write 本身永不睡眠——
* 驱动 wedge 时绝不能把播放线程永久压进内核（真机长流卡死根因防线）。 */
int fd = open(DEV_PCM, O_RDWR | O_NONBLOCK);
int fd = fd_high(open(DEV_PCM, O_RDWR | O_NONBLOCK));
if (fd < 0) { logmsg("dev open %s: %s", DEV_PCM, strerror(errno)); return -1; }
if (alsa_hw_params(fd, rate, ch, alsa_fmt_to_snd((int)fmt)) != 0) {
logmsg("dev hw_params %u/%u/%s failed", (unsigned)rate, (unsigned)ch, fmt_name((int)fmt));
@@ -1425,7 +1452,7 @@ static int dev_open(void)
#endif
}
if (g_sink == SINK_FILE) {
int fd = open(g_out_wav, O_WRONLY | O_CREAT | O_TRUNC, 0644);
int fd = fd_high(open(g_out_wav, O_WRONLY | O_CREAT | O_TRUNC, 0644));
if (fd < 0) { logmsg("dev open wav %s: %s", g_out_wav, strerror(errno)); return -1; }
wav_header(fd, (int)rate, (int)ch, bits, 0);
return fd;
@@ -1519,9 +1546,15 @@ static void dev_write(uint8_t *buf, size_t n)
static void dev_close(void)
{
/* 分流用 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; }
/* 关设备的决策交给 bt_dev_close_kind()（纯函数，宿主可单测）：
* - **BT 分支内自行清理**：认的是 g_bt_dev（不是 g_bt_open——写路径判死时 bt_write 已
* bt_close()，g_bt_open 已是 0），进来后把 g_bt_dev/g_dev_fd 一起复位；
* - ⚠️ **调用方不得提前清 g_bt_dev**：BT 打开成功时 dev_open() 返回 0，谁提前清 0，
* 这里就会落到下面 close(g_dev_fd) 分支上误关 stdin（M50 r1 评审 P2-1 就是这么复现的）；
* - 非 BT 分支只关 fd>2 的真 fd（0/1/2 一律不动，第二道保险）。 */
int kind = bt_dev_close_kind(g_bt_dev, g_dev_fd);
if (kind == 1) { bt_close(); g_bt_dev = 0; g_dev_fd = -1; g_dev_open = 0; return; }
if (kind == 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) {
@@ -1641,7 +1674,10 @@ static void *playback_thread(void *arg)
pthread_mutex_lock(&g_mu);
if (g_bt_fail_req) {
g_bt_fail_req = 0;
g_bt_dev = 0;
/* **不要**在这里清 g_bt_dev：dev_close() 靠它认出「当前设备是 BT PCM」并走
* BT 分支清理；提前清 0 会让它落到 close(g_dev_fd)，而 BT 打开时 g_dev_fd==0
* →误关 stdin（M50 r1 评审 P2-1）。g_dev_fd 同时置 -1 做第二道保险。 */
g_dev_fd = -1;
bt_note_fail("write path fatal (endpoint gone?)");
g_reconfig_pending = 1;
pthread_cond_signal(&g_cond);
patch_v2/meow_audiod/test_bt_dev.c
+69 -60
View File
@@ -8,14 +8,16 @@
* 覆盖矩阵：
* D1 bt_dev_detect_mac：真实 D-Bus 路径 → MAC；多端点/多设备取第一个 a2dpsrc；
* hfphf/a2dpsnk 不算；简化 `a2dpsrc/<MAC>` 兼容；空/无源端点/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 封顶 + 门控（防重试风暴）。
* D6 bt_dev_endpoint_path：取整条 D-Bus 路径给 bluealsa-cli volume|info（真机行含 /sink）。
* D7 bt_dev_info_codec：真机 `bluealsa-cli info` 原文 → Selected codec（不能误吃 Available 行）。
* D8 bt_dev_acl_mac：真机 `hcitool con` 原文 → ACL 对端 MAC（MAC 主来源；list-pcms 只在秒级窗口存在）。
* D8 bt_dev_acl_macs：真机 `hcitool con` 原文 → **全部** ACL 对端 MAC（多设备一等公民：
* 只取第一条会在手机/手柄同时连着时挑错设备，导致有耳机却回落 DAC）。
* D9 bt_dev_pick_endpoint：按 MAC 精确挑端点（换耳机 A→B 后不能拿 A 的路径发 volume/info）。
* D10 bt_dev_close_kind：关闭决策（BT 分支 / 真 fd / **0-2 一律不动**=护 stdin，P2-1 回归）。
*
* 编译（在 patch_v2/meow_audiod 下）：
* cc -Wall -Wextra -o test_bt_dev test_bt_dev.c bt_dev.c
@@ -95,24 +97,6 @@ int main(void)
check(rc == 0 && strcmp(mac, "33:DE:2E:21:AD:30") == 0, "D1i trailing token tolerated");
}
/* ==== 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");
/* 行内判定回归：hfphf 行在 a2dpsrc 行之前，不能被算成源端点（整串 strstr 会误判） */
check(bt_dev_count_src(
"/org/bluealsa/hci0/dev_E0_42_6D_79_C5_98/hfphf/source\n"
"/org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsrc/sink\n") == 1,
"D2e hfphf line before a2dpsrc -> count 1 (per-line match, not whole-buffer)");
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 ==== */
{
struct { const char *in; const char *want; const char *name; } t[] = {
@@ -168,30 +152,6 @@ int main(void)
check(bt_dev_pcm_name("33:DE:2E:21:AD:30", "LDAC", n, 16) == -1, "D4g tiny buffer -> -1");
}
/* ==== D6 端点完整路径（volume/info 要 D-Bus 路径，不是 MAC） ==== */
{
char path[128] = "";
int rc = bt_dev_endpoint_path(
"/org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsrc/sink\n", path, sizeof path);
check(rc == 0 && strcmp(path, "/org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsrc/sink") == 0,
"D6a real /a2dpsrc/sink line -> full path (trailing newline trimmed)");
}
{
char path[128] = "";
int rc = bt_dev_endpoint_path(
"/org/bluealsa/hci0/dev_E0_42_6D_79_C5_98/hfphf/source\n"
"/org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsrc/sink\r\n", path, sizeof path);
check(rc == 0 && strcmp(path, "/org/bluealsa/hci0/dev_33_DE_2E_21_AD_30/a2dpsrc/sink") == 0,
"D6b skips hfphf, strips CRLF (no newline leaks into popen cmd)");
}
{
char path[128] = "";
check(bt_dev_endpoint_path("/org/bluealsa/hci0/dev_11_22_33_44_55_66/a2dpsnk/sink\n",
path, sizeof path) == -1, "D6c no a2dpsrc -> -1");
check(bt_dev_endpoint_path("", path, sizeof path) == -1, "D6d empty -> -1");
check(bt_dev_endpoint_path(NULL, path, sizeof path) == -1, "D6e NULL -> -1");
}
/* ==== D7 实际协商 codec（真机 info 原文：MOONDROP Pudding 只有 SBC/AAC，请求 LDAC 实际选 AAC） ==== */
{
const char *info =
@@ -226,36 +186,85 @@ int main(void)
check(bt_dev_info_codec(NULL, codec, sizeof codec) == -1, "D7d NULL -> -1");
}
/* ==== D8 hcitool con → ACL MAC（真机原文；MAC 主来源） ==== */
/* ==== D8 hcitool con → 全部 ACL MAC（真机原文；MAC 主来源，多设备是常态） ==== */
{
const char *con =
"Connections:\n"
"\t< ACL 33:DE:2E:21:AD:30 handle 12 state 1 lm MASTER AUTH ENCRYPT \n";
char mac[32] = "";
check(bt_dev_acl_mac(con, mac, sizeof mac) == 0 && strcmp(mac, "33:DE:2E:21:AD:30") == 0,
"D8a real hcitool con (state 1 AUTH ENCRYPT) -> ACL MAC");
char m[4][18];
check(bt_dev_acl_macs(con, m, 4) == 1 && strcmp(m[0], "33:DE:2E:21:AD:30") == 0,
"D8a real hcitool con (state 1 AUTH ENCRYPT) -> 1 ACL MAC");
}
{
const char *con =
"Connections:\n"
"\t< ACL 33:DE:2E:21:AD:30 handle 0 state 5 lm MASTER \n";
char mac[32] = "";
check(bt_dev_acl_mac(con, mac, sizeof mac) == 0 && strcmp(mac, "33:DE:2E:21:AD:30") == 0,
char m[4][18];
check(bt_dev_acl_macs(con, m, 4) == 1 && strcmp(m[0], "33:DE:2E:21:AD:30") == 0,
"D8b half-open ACL (state 5) still gives MAC (kernel is authority)");
}
{
const char *con = "Connections:\n";
char mac[32] = "";
check(bt_dev_acl_mac(con, mac, sizeof mac) == -1 && mac[0] == 0, "D8c no ACL -> -1");
check(bt_dev_acl_mac(NULL, mac, sizeof mac) == -1, "D8d NULL -> -1");
/* 多设备：第二副耳机 + 手机同时连着 —— 两条都要拿到，且顺序=输出顺序 */
const char *con =
"Connections:\n"
"\t< ACL 33:DE:2E:21:AD:30 handle 12 state 1 lm MASTER AUTH ENCRYPT \n"
"\t< ACL 5C:FB:7C:11:22:33 handle 5 state 1 lm SLAVE \n";
char m[4][18];
int n = bt_dev_acl_macs(con, m, 4);
check(n == 2 && strcmp(m[0], "33:DE:2E:21:AD:30") == 0 && strcmp(m[1], "5C:FB:7C:11:22:33") == 0,
"D8c two ACLs -> both MACs in order (not just the first one)");
}
{
/* 小写输入归一为大写（bluealsa DEV 参数按大写比较） */
const char *con = "\t< ACL aa:bb:cc:dd:ee:ff handle 3 state 1 lm SLAVE \n";
char mac[32] = "";
check(bt_dev_acl_mac(con, mac, sizeof mac) == 0 && strcmp(mac, "AA:BB:CC:DD:EE:FF") == 0,
"D8e lowercase -> uppercase canonical");
/* 三设备 + 上限裁剪 + 去重（同一设备多 profile 行重复出现） */
const char *con =
"Connections:\n"
"\t< ACL AA:BB:CC:DD:EE:01 handle 1 state 1 lm MASTER \n"
"\t< ACL AA:BB:CC:DD:EE:01 handle 2 state 1 lm SLAVE \n"
"\t< ACL AA:BB:CC:DD:EE:02 handle 3 state 1 lm MASTER \n"
"\t< ACL AA:BB:CC:DD:EE:03 handle 4 state 1 lm MASTER \n";
char m[3][18];
int n = bt_dev_acl_macs(con, m, 3);
check(n == 3 && strcmp(m[0], "AA:BB:CC:DD:EE:01") == 0 &&
strcmp(m[1], "AA:BB:CC:DD:EE:02") == 0 && strcmp(m[2], "AA:BB:CC:DD:EE:03") == 0,
"D8d dedup + cap at max (3 distinct)");
}
{
char m[4][18];
check(bt_dev_acl_macs("Connections:\n", m, 4) == 0, "D8e no ACL -> 0");
check(bt_dev_acl_macs(NULL, m, 4) == 0, "D8f NULL -> 0");
check(bt_dev_acl_macs("\t< ACL aa:bb:cc:dd:ee:ff handle 3 state 1 lm SLAVE \n", m, 4) == 1 &&
strcmp(m[0], "AA:BB:CC:DD:EE:FF") == 0, "D8g lowercase -> uppercase canonical");
}
/* ==== D9 按 MAC 精确挑端点（换耳机 A→B 不串台） ==== */
{
const char *pcms =
"/org/bluealsa/hci0/dev_AA_BB_CC_DD_EE_01/a2dpsrc/sink\n"
"/org/bluealsa/hci0/dev_AA_BB_CC_DD_EE_02/a2dpsrc/sink\n";
char path[128] = "";
check(bt_dev_pick_endpoint(pcms, "AA:BB:CC:DD:EE:02", path, sizeof path) == 0 &&
strcmp(path, "/org/bluealsa/hci0/dev_AA_BB_CC_DD_EE_02/a2dpsrc/sink") == 0,
"D9a picks B's path when MAC=B (not the first endpoint)");
check(bt_dev_pick_endpoint(pcms, "AA:BB:CC:DD:EE:01", path, sizeof path) == 0 &&
strcmp(path, "/org/bluealsa/hci0/dev_AA_BB_CC_DD_EE_01/a2dpsrc/sink") == 0,
"D9b picks A's path when MAC=A");
check(bt_dev_pick_endpoint(pcms, "AA:BB:CC:DD:EE:03", path, sizeof path) == -1 &&
path[0] == 0, "D9c unknown MAC -> -1 (never borrow another device's path)");
check(bt_dev_pick_endpoint("/org/bluealsa/hci0/dev_AA_BB_CC_DD_EE_01/hfphf/source\n",
"AA:BB:CC:DD:EE:01", path, sizeof path) == -1,
"D9d non-a2dpsrc endpoint -> -1");
check(bt_dev_pick_endpoint(NULL, "AA:BB:CC:DD:EE:01", path, sizeof path) == -1, "D9e NULL -> -1");
}
/* ==== D10 关闭决策（P2-1 回归：0/1/2 永不当设备 fd 关） ==== */
check(bt_dev_close_kind(1, 0) == 1, "D10a bt_dev=1 + fd=0 -> close BT only (never fd 0)");
check(bt_dev_close_kind(1, 5) == 1, "D10b bt_dev=1 + fd=5 -> close BT only");
check(bt_dev_close_kind(0, 0) == 0, "D10c bt_dev=0 + fd=0 -> NONE (stdin guard, P2-1)");
check(bt_dev_close_kind(0, 1) == 0, "D10d bt_dev=0 + fd=1 -> NONE (stdout guard)");
check(bt_dev_close_kind(0, 2) == 0, "D10e bt_dev=0 + fd=2 -> NONE (stderr guard)");
check(bt_dev_close_kind(0, 3) == 2, "D10f bt_dev=0 + fd=3 -> close FD");
check(bt_dev_close_kind(0, -1) == 0, "D10g bt_dev=0 + fd=-1 -> NONE");
check(bt_dev_close_kind(0, -2) == 0, "D10h bt_dev=0 + fd=-2 (NULL sink) -> NONE");
/* ==== D5 回落退避（防重试风暴：M10 教训） ==== */
check(bt_dev_backoff_ms(0) == 0, "D5a fails=0 -> 0ms (immediate)");