michael/scrypted
1
0
Fork 0
mirror of https://github.com/koush/scrypted.git synced 2026-05-11 16:10:32 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

rebroadcast: use highwatermark for nvr perf improvement

Browse Source
This commit is contained in:
Koushik Dutta
2023-05-11 10:20:28 -07:00
parent 3893ccd776
commit 90c9efc8a6
3 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
plugins/prebuffer-mixin/package-lock.json generated
View File

@@ -1,12 +1,12 @@
{
"name": "@scrypted/prebuffer-mixin",
"version": "0.9.86",
"version": "0.9.87",
"lockfileVersion": 2,
"requires": true,
"packages": {
"": {
"name": "@scrypted/prebuffer-mixin",
"version": "0.9.86",
"version": "0.9.87",
"license": "Apache-2.0",
"dependencies": {
"@scrypted/common": "file:../../common",

2
plugins/prebuffer-mixin/package.json
View File

@@ -1,6 +1,6 @@
{
"name": "@scrypted/prebuffer-mixin",
"version": "0.9.86",
"version": "0.9.87",
"description": "Video Stream Rebroadcast, Prebuffer, and Management Plugin for Scrypted.",
"author": "Scrypted",
"license": "Apache-2.0",

7
plugins/prebuffer-mixin/src/file-rtsp-server.ts
View File

@@ -4,6 +4,8 @@ import fs from 'fs';
import { format } from "path";
import { Duplex } from "stream";
const highWaterMark = 1024 * 1024;
// non standard extension that dumps the rtp payload to a file.
export class FileRtspServer extends RtspServer {
writeStream: fs.WriteStream;
@@ -56,6 +58,7 @@ export class FileRtspServer extends RtspServer {
await fs.promises.rename(truncate, file);
truncateWriteStream = fs.createWriteStream(undefined, {
fd,
highWaterMark,
})
// this.writeConsole?.log('truncating', truncate);
}
@@ -72,7 +75,9 @@ export class FileRtspServer extends RtspServer {
this.cleanup();
this.segmentBytesWritten = 0;
this.writeStream = truncateWriteStream || fs.createWriteStream(file);
this.writeStream = truncateWriteStream || fs.createWriteStream(file, {
highWaterMark,
});
this.writeStream.on('error', e => {
this.writeConsole?.error('RTSP WRITE error', e);
});