legop3/MultiRoombaRover
1
0
Fork 0
mirror of https://github.com/legop3/MultiRoombaRover.git synced 2026-09-17 10:00:46 -04:00
Code Issues Actions Packages Projects Releases Wiki Activity

ugh

Browse Source
This commit is contained in:
legop3
2026-01-13 18:37:27 -05:00
parent fb00467106
commit b7a79b03c9
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/src/services/roomCameraSnapshotService.js
+7 -2
View File
@@ -91,7 +91,7 @@ function startStream(camera) {
res.on('data', (chunk) => { res.on('data', (chunk) => {
buffer = Buffer.concat([buffer, chunk]); buffer = Buffer.concat([buffer, chunk]);
while (true) { while (true) {
const start = buffer.indexOf(JPEG_START); let start = buffer.indexOf(JPEG_START);
if (start === -1) { if (start === -1) {
if (buffer.length > 2 * 1024 * 1024) { if (buffer.length > 2 * 1024 * 1024) {
buffer = buffer.slice(-1024 * 1024); buffer = buffer.slice(-1024 * 1024);
@@ -100,10 +100,11 @@ function startStream(camera) {
} }
if (start > 0) { if (start > 0) {
buffer = buffer.slice(start); buffer = buffer.slice(start);
start = 0;
} }
const end = buffer.indexOf(JPEG_END, 2); const end = buffer.indexOf(JPEG_END, 2);
if (end === -1) break; if (end === -1) break;
const frame = buffer.slice(start, end + 2); const frame = buffer.slice(0, end + 2);
buffer = buffer.slice(end + 2); buffer = buffer.slice(end + 2);
const ts = Date.now(); const ts = Date.now();
markState(camera.id, { frame, ts, error: null, failures: 0 }); markState(camera.id, { frame, ts, error: null, failures: 0 });
@@ -113,6 +114,10 @@ function startStream(camera) {
res.on('end', () => { res.on('end', () => {
scheduleStreamReconnect(camera); scheduleStreamReconnect(camera);
}); });
res.on('aborted', () => {
handleStreamError(camera, new Error('stream aborted'));
scheduleStreamReconnect(camera);
});
res.on('error', (err) => { res.on('error', (err) => {
handleStreamError(camera, err); handleStreamError(camera, err);
scheduleStreamReconnect(camera); scheduleStreamReconnect(camera);