sky/app-starlock
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix:调整切换清晰度逻辑

Browse Source
This commit is contained in:
liyi 2025-06-23 16:00:37 +08:00
parent ce193a2195
commit 293716f146
1 changed files with 34 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
lib/talk/starChart/views/native/talk_view_native_decode_logic.dart
View File

@ -52,6 +52,15 @@ class TalkViewNativeDecodeLogic extends BaseGetXController {
int audioBufferSize = 2; // 音频默认缓冲2帧 int audioBufferSize = 2; // 音频默认缓冲2帧
// 回绕阈值，动态调整，frameSeq较小时阈值也小
int _getFrameSeqRolloverThreshold(int lastSeq) {
if (lastSeq > 2000) {
return 1000;
} else {
return (lastSeq / 2).round();
}
}
// 定义音频帧缓冲和发送函数 // 定义音频帧缓冲和发送函数
final List<int> _bufferedAudioFrames = <int>[]; final List<int> _bufferedAudioFrames = <int>[];
@ -163,28 +172,35 @@ class TalkViewNativeDecodeLogic extends BaseGetXController {
int frameSeqI, int frameSeqI,
ScpMessage scpMessage, ScpMessage scpMessage,
) { ) {
// 检测frameSeq回绕，且为I帧
// 动态回绕阈值判断，frameSeq较小时阈值也小
if (!_pendingStreamReset && if (!_pendingStreamReset &&
_lastFrameSeq != null && _lastFrameSeq != null &&
frameType == TalkDataH264Frame_FrameTypeE.I && frameType == TalkDataH264Frame_FrameTypeE.I &&
frameSeq < _lastFrameSeq!) { frameSeq < _lastFrameSeq!) {
// 检测到新流I帧，进入loading并重置所有本地状态 int dynamicThreshold = _getFrameSeqRolloverThreshold(_lastFrameSeq!);
AppLog.log( if ((_lastFrameSeq! - frameSeq) > dynamicThreshold) {
'检测到新流I帧，frameSeq回绕，进入loading并重置: frameSeq=$frameSeq, lastFrameSeq=$_lastFrameSeq'); // 检测到新流I帧，frameSeq大幅回绕，进入loading并重置所有本地状态
Future.microtask(() => state.isLoading.value = true); AppLog.log('检测到新流I帧，frameSeq大幅回绕，进入loading并重置: frameSeq=$frameSeq, lastFrameSeq=$_lastFrameSeq, 阈值=$dynamicThreshold');
_pendingStreamReset = true; Future.microtask(() => state.isLoading.value = true);
// 先暂停帧处理定时器，防止竞态 _pendingStreamReset = true;
_stopFrameProcessTimer(); // 先暂停帧处理定时器，防止竞态
// 先释放并重新初始化解码器 _stopFrameProcessTimer();
_resetDecoderForNewStream(_pendingResetWidth, _pendingResetHeight); // 先释放并重新初始化解码器
// 重置所有本地状态 _resetDecoderForNewStream(_pendingResetWidth, _pendingResetHeight);
_lastFrameSeq = null; // 重置所有本地状态
_decodedIFrames.clear(); _lastFrameSeq = null;
state.h264FrameBuffer.clear(); _decodedIFrames.clear();
// 再恢复帧处理定时器 state.h264FrameBuffer.clear();
_startFrameProcessTimer(); // 再恢复帧处理定时器
// 不return，直接用该I帧初始化解码器并解码 _startFrameProcessTimer();
// 继续往下执行 // 不return，直接用该I帧初始化解码器并解码
// 继续往下执行
} else {
// 小幅度乱序，直接丢弃
AppLog.log('检测到I帧乱序（未超过回绕阈值$dynamicThreshold），丢弃: frameSeq=$frameSeq, lastFrameSeq=$_lastFrameSeq');
return;
}
} }
// 如果处于pendingStreamReset，等待新I帧 // 如果处于pendingStreamReset，等待新I帧
if (_pendingStreamReset) { if (_pendingStreamReset) {