Skip to content

Commit

Permalink
style: LD-6968 do changes after review
Browse files Browse the repository at this point in the history
  • Loading branch information
vlad-livedigital committed Aug 2, 2024
1 parent d1b2c57 commit 0a5d950
Show file tree
Hide file tree
Showing 4 changed files with 10 additions and 9 deletions.
4 changes: 2 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ import WebRTCIssueDetector, {
NetworkMediaSyncIssueDetector,
AvailableOutgoingBitrateIssueDetector,
UnknownVideoDecoderImplementationDetector,
DeadVideoTrackDetector,
FrozenVideoTrackDetector,
} from 'webrtc-issue-detector';

const widWithDefaultConstructorArgs = new WebRTCIssueDetector();
Expand All @@ -75,7 +75,7 @@ const widWithCustomConstructorArgs = new WebRTCIssueDetector({
new NetworkMediaSyncIssueDetector(),
new AvailableOutgoingBitrateIssueDetector(),
new UnknownVideoDecoderImplementationDetector(),
new DeadVideoTrackDetector(),
new FrozenVideoTrackDetector(),
],
getStatsInterval: 10_000, // set custom stats parsing interval
onIssues: (payload: IssueDetectorResult) => {
Expand Down
4 changes: 2 additions & 2 deletions src/WebRTCIssueDetector.ts
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ import {
OutboundNetworkIssueDetector,
QualityLimitationsIssueDetector,
UnknownVideoDecoderImplementationDetector,
DeadVideoTrackDetector,
FrozenVideoTrackDetector,
} from './detectors';
import { CompositeRTCStatsParser, RTCStatsParser } from './parser';
import createLogger from './utils/logger';
Expand Down Expand Up @@ -66,7 +66,7 @@ class WebRTCIssueDetector {
new NetworkMediaSyncIssueDetector(),
new AvailableOutgoingBitrateIssueDetector(),
new UnknownVideoDecoderImplementationDetector(),
new DeadVideoTrackDetector(),
new FrozenVideoTrackDetector(),
];

this.networkScoresCalculator = params.networkScoresCalculator ?? new DefaultNetworkScoresCalculator();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,19 +7,19 @@ import {
} from '../types';
import BaseIssueDetector from './BaseIssueDetector';

interface DeadVideoTrackDetectorParams {
interface FrozenVideoTrackDetectorParams {
timeoutMs?: number;
framesDroppedThreshold?: number;
}

class DeadVideoTrackDetector extends BaseIssueDetector {
class FrozenVideoTrackDetector extends BaseIssueDetector {
readonly #lastMarkedAt = new Map<string, number>();

readonly #timeoutMs: number;

readonly #framesDroppedThreshold: number;

constructor(params: DeadVideoTrackDetectorParams = {}) {
constructor(params: FrozenVideoTrackDetectorParams = {}) {
super();
this.#timeoutMs = params.timeoutMs ?? 10_000;
this.#framesDroppedThreshold = params.framesDroppedThreshold ?? 0.5;
Expand Down Expand Up @@ -69,6 +69,7 @@ class DeadVideoTrackDetector extends BaseIssueDetector {
return;
}

// We skip it when ratio is too low because it should be handled by FramesDroppedIssueDetector
if (ratioFramesDropped >= this.#framesDroppedThreshold) {
return;
}
Expand Down Expand Up @@ -132,4 +133,4 @@ class DeadVideoTrackDetector extends BaseIssueDetector {
}
}

export default DeadVideoTrackDetector;
export default FrozenVideoTrackDetector;
2 changes: 1 addition & 1 deletion src/detectors/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -7,4 +7,4 @@ export { default as NetworkMediaSyncIssueDetector } from './NetworkMediaSyncIssu
export { default as OutboundNetworkIssueDetector } from './OutboundNetworkIssueDetector';
export { default as QualityLimitationsIssueDetector } from './QualityLimitationsIssueDetector';
export { default as UnknownVideoDecoderImplementationDetector } from './UnknownVideoDecoderImplementationDetector';
export { default as DeadVideoTrackDetector } from './DeadVideoTrackDetector';
export { default as FrozenVideoTrackDetector } from './FrozenVideoTrackDetector';

0 comments on commit 0a5d950

Please sign in to comment.