From e00d020c7606c77072e4083edd7b9679c23692d2 Mon Sep 17 00:00:00 2001 From: Marco van Dijk Date: Tue, 26 Dec 2023 13:49:03 +0100 Subject: [PATCH] Store ID in cache --- client/src/proto/livepeer.proto | 13 +++++++++++++ master/src/routes/hodler.js | 2 ++ 2 files changed, 15 insertions(+) diff --git a/client/src/proto/livepeer.proto b/client/src/proto/livepeer.proto index 8a1c9df..e3df8be 100644 --- a/client/src/proto/livepeer.proto +++ b/client/src/proto/livepeer.proto @@ -7,6 +7,7 @@ service Orchestrator { // Called by the broadcaster to request transcoder info from an orchestrator. rpc GetOrchestrator(OrchestratorRequest) returns (OrchestratorInfo); + rpc EndTranscodingSession(EndTranscodingSessionRequest) returns (EndTranscodingSessionResponse); rpc Ping(PingPong) returns (PingPong); } @@ -23,6 +24,14 @@ message PingPong { } +// sent by Broadcaster to Orchestrator to terminate the transcoding session and free resources (used for verification sessions) +message EndTranscodingSessionRequest { + // Data for transcoding authentication + AuthToken auth_token = 1; +} + +message EndTranscodingSessionResponse { +} // This request is sent by the broadcaster in `GetTranscoder` to request // information on which transcoder to use. @@ -221,6 +230,9 @@ message SegData { // Transcoding parameters specific to this segment SegParameters segment_parameters = 37; + // Force HW Session Reinit + bool ForceSessionReinit = 38; + // [EXPERIMENTAL] // Detector profiles to use repeated DetectorProfile detector_profiles = 36; @@ -292,6 +304,7 @@ message VideoProfile { CHROMA_444 = 2; } ChromaSubsampling chromaFormat = 27; + uint32 quality = 28; } // Individual transcoded segment data. diff --git a/master/src/routes/hodler.js b/master/src/routes/hodler.js index 1f5dbb0..0817cf0 100644 --- a/master/src/routes/hodler.js +++ b/master/src/routes/hodler.js @@ -217,12 +217,14 @@ const onOrchUpdate = async function (id, obj, tag, region, livepeer_regions) { if (!newObj) { newObj = { name: ensDomain, + id: id.toLowerCase(), regionalStats: {}, instances: {}, leaderboardResults: { lastTime: now }, }; } else { newObj.name = ensDomain; + newObj.id = id.toLowerCase() } // Find region entry or init it let newRegion = newObj.regionalStats[tag];