From df58bc78d0d68c33e9882517e54bc88d03b2ced2 Mon Sep 17 00:00:00 2001 From: wind Date: Sat, 5 Sep 2026 23:08:39 +0800 Subject: [PATCH] =?UTF-8?q?perf:=20=E4=BC=98=E5=8C=96=E6=96=87=E4=BB=B6?= =?UTF-8?q?=E4=BC=A0=E8=BE=93=E9=80=9F=E5=BA=A6=EF=BC=8C=E7=A7=BB=E9=99=A4?= =?UTF-8?q?=E9=A2=91=E7=B9=81flush?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 移除writeSourcePayload中每64KB一次的flush调用 - 让BufferedSink自动缓冲合并多个DATA块 - 利用TCP Nagle算法和滑动窗口提升传输效率 --- dadb/src/main/kotlin/dadb/AdbSync.kt | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/dadb/src/main/kotlin/dadb/AdbSync.kt b/dadb/src/main/kotlin/dadb/AdbSync.kt index 023c255..5228635 100644 --- a/dadb/src/main/kotlin/dadb/AdbSync.kt +++ b/dadb/src/main/kotlin/dadb/AdbSync.kt @@ -196,7 +196,8 @@ class AdbSyncStream( writeFrameHeader(DATA, read.toInt()) val sent = writeAll(this@AdbSyncStream.buffer) check(read == sent) - flush() + // 优化:不要每 64KB 就 flush,让 BufferedSink 自动缓冲合并, + // 减少网络发送次数,提升传输速度 } } stream.sink.apply {