Skip to content

Commit 65dc448

Browse files
committed
refactor: clear peer ID cache on Core destroy
1 parent d7361d4 commit 65dc448

File tree

2 files changed

+6
-0
lines changed

2 files changed

+6
-0
lines changed

packages/p2p-media-loader-core/src/core.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@ import {
2727
} from "./utils/utils.js";
2828
import { TRACKER_CLIENT_VERSION_PREFIX } from "./utils/peer.js";
2929
import { SegmentStorage } from "./segment-storage/index.js";
30+
import { P2PTrackerClient } from "./p2p/tracker-client.js";
3031

3132
/** Core class for managing media streams loading via P2P. */
3233
export class Core<TStream extends Stream = Stream> {
@@ -432,6 +433,7 @@ export class Core<TStream extends Stream = Stream> {
432433
this.segmentStorage = undefined;
433434
this.manifestResponseUrl = undefined;
434435
this.streamDetails = { isLive: false, activeLevelBitrate: 0 };
436+
P2PTrackerClient.clearPeerIdCache();
435437
}
436438

437439
private async initializeSegmentStorage() {

packages/p2p-media-loader-core/src/p2p/tracker-client.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -162,4 +162,8 @@ export class P2PTrackerClient {
162162
this.logger(`peer closed: ${peer.id}`);
163163
this._peers.delete(peer.id);
164164
};
165+
166+
static clearPeerIdCache() {
167+
P2PTrackerClient.PEER_ID_BY_INFO_HASH.clear();
168+
}
165169
}

0 commit comments

Comments
 (0)