ewilliams28/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-08-12 21:53:00 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix(meeting-bot): coalesce realtime output backlog

Browse Source
This commit is contained in:
Vincent Koc
2026-07-31 08:26:14 +08:00
parent f6eaf3fd7d
commit f4fbff7682
1 changed files with 25 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/meeting-bot/realtime-engine.ts
+25 -3
View File
@@ -94,6 +94,7 @@ export const MEETING_AGENT_TRANSCRIPT_DEBOUNCE_MS = 900;
export const MEETING_OUTPUT_ECHO_SUPPRESSION_TAIL_MS = 3_000;
export const MEETING_TRANSCRIPT_ECHO_LOOKBACK_MS = 45_000;
const MEETING_REALTIME_OUTPUT_MAX_PENDING_MS = 2_000;
const MEETING_REALTIME_OUTPUT_MAX_WRITE_MS = 500;
const MEETING_REALTIME_OUTPUT_MAX_PENDING_FRAMES = 256;
const MEETING_REALTIME_CANCELLATION_RACE_DETAIL = "Cancellation failed: no active response found";
@@ -138,6 +139,9 @@ export async function startMeetingRealtimeEngine(params: {
const outputMaxPendingBytes =
meetingOutputBytesPerMs(params.config.chrome.audioFormat) *
MEETING_REALTIME_OUTPUT_MAX_PENDING_MS;
const outputMaxWriteBytes =
meetingOutputBytesPerMs(params.config.chrome.audioFormat) *
MEETING_REALTIME_OUTPUT_MAX_WRITE_MS;
const realtimeLogScope = params.logPrefix ? `${params.logPrefix} realtime` : "realtime";
const invalidateOutputQueue = () => {
@@ -249,13 +253,31 @@ export async function startMeetingRealtimeEngine(params: {
pumpOutputQueue();
return;
}
const batch = [next.audio];
let batchBytes = next.audio.byteLength;
let batchFrames = 1;
while (batchBytes < outputMaxWriteBytes) {
const queued = outputQueue[0];
if (
!queued ||
queued.generation !== next.generation ||
queued.audio.byteLength > outputMaxWriteBytes - batchBytes
) {
break;
}
outputQueue.shift();
batch.push(queued.audio);
batchBytes += queued.audio.byteLength;
batchFrames += 1;
}
const audio = batch.length === 1 ? next.audio : Buffer.concat(batch, batchBytes);
outputWriteActive = true;
void Promise.resolve()
.then(async () => {
if (stopped || next.generation !== outputGeneration) {
return;
}
await params.transport.writeOutput(next.audio);
await params.transport.writeOutput(audio);
})
.catch((error: unknown) => {
if (stopped || next.generation !== outputGeneration) {
@@ -269,8 +291,8 @@ export async function startMeetingRealtimeEngine(params: {
.finally(() => {
outputWriteActive = false;
if (next.generation === outputGeneration) {
outputPendingBytes -= next.audio.byteLength;
outputPendingFrames -= 1;
outputPendingBytes -= batchBytes;
outputPendingFrames -= batchFrames;
}
if (outputClearAfterActive && !stopped) {
outputClearAfterActive = false;