Merge pull request #1834 from CastagnaIT/dash_utctiming

[DashTree] Implement UTCTiming for live streams

Author: CastagnaIT

plugin.video.isasamples/menu_data.py

@@ -215,6 +215,14 @@
                     'manifest_url': 'https://livesim2.dashif.org/livesim2/ato_10/testpic_2s/Manifest.mpd'
                 }
             },
+            'BBC LiveTestcard [SegmentTemplate - no timeline]': {
+                SI_FEATURE: 'ADPV,SUBMP4',
+                SI_CODECS: 'avc3,mp4a,ttml',
+                SI_INFO: 'Multi BaseURL with priorities, font download on SupplementalProperty.',
+                SI_CONFIG: {
+                    'manifest_url': 'https://rdmedia.bbc.co.uk/testcard/simulcast/manifests/avc-ctv-stereo-en-sfdt-woff.mpd'
+                }
+            },
         },
         'Dash VOD with DRM': {
             MI_CONFIG: {},
@@ -263,7 +271,8 @@
             },
             'Google angel one': {
                 SI_ENCRYPT: 'DRMWV',
-                SI_INFO: 'Multiple audio and subtitles tracks',
+                SI_FEATURE: 'ADP,SUBEXT,CMP4,CWEBM',
+                SI_INFO: 'Multiple audio/video and subtitles tracks. Use SegmentBase.',
                 SI_CONFIG: {
                     'manifest_url': 'https://storage.googleapis.com/shaka-demo-assets/angel-one-widevine/dash.mpd',
                     'license_type': 'com.widevine.alpha',
@@ -362,14 +371,6 @@
                     'drm': '{"org.w3.clearkey": {"license": {"keyids": {"eb676abbcb345e96bbcf616630f1a3da": "100b6c20940f779a4589152b57d2dacb"}}}}',
                 }
             },
-            'TEST WV': {
-                SI_ENCRYPT: 'DRMWV,DRMPR',
-                SI_INFO: 'Config set to Widevine',
-                SI_CONFIG: {
-                    'manifest_url': 'https://media.axprod.net/TestVectors/v7-MultiDRM-SingleKey/Manifest_1080p.mpd',
-                    'drm': '{"com.widevine.alpha":{"license": {"server_url": "https://drm-widevine-licensing.axtest.net/AcquireLicense","req_data": "eyJ0b2tlbiI6ICJwcmNiNzgyY2Y0NmI0MDM1YmU4Y2Y4ZGMyOTFmNmU0ODQ3MTkyZTViYjk1OGMwMDI5MjJmMTNlNmY1NThhZDM1NTk3ODViYWNmYjZjNjQxMjUyNTk2YTBlNTRlZWFhN2MwNWU4MGFjODI4MDJhMTNlZDk1NmVmMjY1MzIwZTA1NTQyMjA3NjA1MDkyNzk2YjY0NWIyYWMyMjAxMzVmM2MwNzQ2NzZlZjA0YmVjOTcyZTJmZmI3MWIyMGU5M2VjNWY4OGZhNDI3ZDA0ZDViYTU3OTU5ZGZiNGY1OWFkZDhiMGU1N2VmZDZlODBjYTk0ZGFmODZhMDM1OWYxNTY5NzE3MDViNTZmNWE4N2FlODQ4YjE1Y2I5NGY1YTRkNmU1ODA2NmYyYTcxNDk3OTg5ZTEwNWE4YjgzNjE2NzlhNTcyMjQwNmU3YjczMTk2N2JiNzNmZjAzMTBiZWJhNzU3NzA0ZTJlYWI3YmRlZmM2YmU1OGJhMzNjYWEyNzQ3ZDY1NWExNjIzYWRmMTUzMDNiOWI2NWJjZThmYzg0MGY1MzdiMzc5YmI4MzhlNWM5YjRmYzg1NWE3YWFlMzFmZjFlZjJkZTlhODE5N2RhM2YyNTQ1ODBhMDZkYmVlNTk1MDI3MWEzOTVlOGFiNWI5MGM4ZWYxNGY5ZGM2NGViODE0NzM3ZTczYmVkNzc2MTg5YmJmOTJlMzY5NjcyNTVlNzc1YmNhNWU1YmZmY2M1MTkzYjFmOTNmZDNiMGFmODc0NzE0MjE1MDA2MjY1OWNjZjViOWRkYzQ0NzM2MjQwNjlkZTA5ZjkyMjE4YjZiYTY1MGEyZjc4ZDA5MzNmODc1ODhmZjI0YWQwZTVmYWU4MjNlYjNjYzUyMjMwZTIyNWQ1YzliMDU5MzQ0MzkyNzJhNzYyMjE5NzAzY2Q2ZWQ0ZTI5OTRhN2Y4ZmZiMjJhNjI5MGJkYzdlYzQ1ZDU4MTAyNzk0NmU4M2EwMDg2ODI4MjY0NTdlY2YyMTRiNmQ1M2I3MTFmMTYyNzQ1ZDBmYjdjNzMyMTJiMzQxYTAzYjU4ZjQ5NGM0ODkzMTE1N2NmNDFkMzZhYWNiMTNhYmRiOTAwZjgzZGI4ZGJjMzNlMjQ5OWE3ZDhkZGE4YWFmZDg5ZGQ5NjI4Njg4YzFlOGQxYWE0ZTRhMjEyNDdkYmQ5MTE4MDE1ODExNzAwY2I0OTI5NDY2MjBkM2U0NzE0N2NjOTE5ZjNlYmVmY2E3NDk5YmFjNWYzMDM3NDU0NDk3NmI2ZTBkYWVhNThjNzllMmExMWE1YzNmMjdlOWM0ZjY2OWVjOWUzYTcxOWI3NjA4MDZiYzQ0NGE4NjYwZWU2N2U1MDhlMzY4OWEyMGJiNDNmYjdlZGUxNjY2NzFjZjQ0MWVlZGNkMDBhYWViYTFkNjIyYzJkNjJkOGY3YWI3YWZmZGFkNDNiMDkwM2I5NGNkY2NiNTUwMGEzN2E3MGIwNDJhMTg1Y2Q2Y2EwNTRjMWM4NTY0ZTM5YjMxMGVkYmI0ODE1YTRmMjc0NzljYzk3YzI4NjEwYTQyYjkwZjdkMGM5NGZkNDI0ZjkyOTBiZWU1YWIzMmI0ZmVmNTI4NTc5N2Q4ZWYwZDBjNTZlZTIwYjM0YWMyOGQxZjQyMjFlM2NlZjRmZDlmNjk4ZmFkNGU3MmVhMDNmMmJjM2RkNGYxMGEyMTBlZjQ1NDFiOTQ2ZTE4M2YxZDI0ZTZlY2JiOGFjMGZmYWQ0M2QxZTIxZGNlM2ExZWI2NmQ0NjFkMGExMzAyYWM1M2I3ZGM5NDcwMzhlNGY5ZWM1ZWNmNTQzMTMyODY2Nzg1NDI3NzNiYTZjYzUwNmQwODZhZDA1NDZiYWJlYmJjYmRjZWFiZGI2MWE4Mjk3YzU1NWQwZmNkZGYwZTY4ZjE4ZGU0YWZkMTRlMTA0ZjFhODYyMTBkOTc0OGQ4ZTE4YTI5ODBhZmQ1NTdjNzdkMTU1MjUyNThhNDI1MzAyYTgyNzJmMWZiOTFlNDJlNWM1NzUyZDZhMGRjMTU3NDI5ZmEzZGViZTYyNTM1ZmRmMDRkYjI5OGM1MzVlM2QyZmI1NDAwNzc3ZDcwZGIyNWY0OWJkNDg4ZDg0NmNhODY2NzNhNDc0YThhNzIwOThjNWQyNWM2YjM4N2IzNDI0NWMxZDViYjJiN2ZmYTc2MTNlZjFlZDM5Mjg2Zjg5MGFiZDUzNjM5NzcxN2Q0ZGEwZTVhOGVhZWQ2NzkyYjI3NjA0ZDlmYTFhZWY1ZjgwYjA2MGFkNTljZWJlOTIxYzZkYzQxM2Q3YTE5MDQ3MjhkNzlhMDE3OTUzYmQ1MmMwZmYxOWE0M2YxNWNkZjRlMThlMTNhYjE5ZmRlNGQ0NDEwN2U3ZjQ5ZjIwMjI5ZDE4ZTRhNTRlM2Q0ZGJjNzRiZWQyNWM4OWE2NWZiODQzMGZjZWVkZDIyNGQ3ZmFhNzlhNzMxNmY3YWFjNTdjNmVkNjA2NjM3NzY1NWVjOTVlMjA3NzAxYzViYzkzMDVhNzU0MGIzOGQwNjVlZDc2ZDliZjdkZTAyZDFhMGRkYWJjODczNDE5MmNmYTkyMTM5YjJlNDZjMjljODJmMzdkMTM5NTc2ZDAzMTQ2NDMxMmRhN2RlMzQ3NTM3N2NlNTE1ZmEyZGNjYjBlNDY2ZGYwMGI4MDYwMjJiYjYwMDZhZjk2MWUzOWEwODY1YjIzMTI1ZmQ1ZTIwNjUyYjY3OTI4MGI5YWY1M2U4N2RmMWJlZjIxNDcxY2IwMDk0YzJlYmI2OTc4M2M2M2Y1YTlkNTVkYTk5ZjA3ZTlkYWMxMTc2YjMwYjg4OGY0MzM3N2FmNjJmZDVlMjgyNzE3MzlmZDBjN2JlZjQ4NmM3YWFjNjg1MWNmZDBlOTAyYTg5OGNjMGM0OWQ0OWIxNDQ1ZjZhYjNkY2QxYmVlODY3OGM5NTU5OWQ2OTVlZTlmNzkzMmRmOWQ4OTIwMzc1NTUzNDk4MjFiMGNlNWZiZjc5Y2ZhNWNkNGRlNmY3ZTAxZTJlMjZhNGQ2Y2M3MGMzMThjOGUyMjk2NjA5YmE1N2VjNWVlNTA1YTMwNzc1Mzk2YWY1ZDE1ZDA5YjliYTM0MTE5NzBlMjZmMTAwMmM5MzYzMmQ2NGM1ZGYxMzUyZjA0MGQ4Mjc5YTY4ZGUxMDQ5Y2UxNzI3ZGZiYjcxMzI2Y2M1NGM1OWRlNjAxZTYyNzYyZmI1NTA0ZTQzNjMzMjQxN2JkZmZlNmZiZDQ1NTc3ZWRkNWIzMWZhZjcyMzA3MjFlOTg4NTEwYTA2ZDhjOWRjMTc2MTlmNzVkYTQ4MjU3MzU2NGY1NGRiYzM0MGVlYjk2YWVjNjgzOTMwYWZhODI2ZjA3Njc2NzkyMGM4OTQ1MDY4NWU3NjkyODI1NTk3OWUyMDE3ZmJiMGE3YWRjMTNhMjM4YWU2MzQ2NTgyN2Q5NzEzYThhNzY3MDRkNTA3ZmQyZDM5NmRlZDllM2RmODhhOTE0MTg4NWNmNzAxMzZhMmE5MDIyNWM4NGM3MGRiZDc4YzM1ZTliNjhjZGIyMTJkODhlNWUwMjBiNDliYmQ5ZjQ0NDlkMzc1NDY5YTk5YTJjNzJmMDU3ZGE1MTVmNDRkOGNlZmQyMzdjYzZlYTUxMWExMWE0NGE1Y2EyZWQ4ZjEzMmZiOTc5M2E1YjIwNjBmYzcxOGZjOTVhMmM1Y2IwNmJkNzZhNGM5YTg5NWFmZWRjOTQ1MTY0ZTFmYzRmNmQzNTdmZjVlNTU1MzJjMjBkZjYzOGQyNzI2YmVjZGRmOTJjNTc0NzVlYzRjNGIzMDI2OGZhMDk4MjVkMWNlOGIyYjhhMWZmZjkxYjVmYzFkMWFjOTAxMDE3OGU4MGE4YTBhMzJiMDVjZjRkM2RhNTM1YTU4ZDJlZTY1ZDNjZDhjMDgzZTlkZjc3ODdhNDEwMjMyMGMzMWFlYmJiOTNjZTY2ODBlZWM5NGFkODNiZTYwZmE3OWM0ZDRhYWZlYjkyYjJjZWY4YmU3NzUxMTUwOWJkNzEzOGZhY2YxMDlmOTJhZGUxNDM3MDg4NzQzMDRlZmQ4NzcxMTA1NzE1NzcyN2MxZmIyMjMyYjM5Y2Y4NzNkYzU5ODMyNzNmZWMwY2U0ZTg4MDkzZWI5MjgwM2Y2NDg2MzJhNDNjNTFhZTUwZjRkZTM0YmQ0OTY0YTY5NGEzN2IzYzRkNjUzOTA2MzgxYmM5NmNjZGQ1NjZiNzhhOGFhODZiNDA4ZTlkZDgxZmMzNGJkNzVlZWRmMjMzMTlhOGRmNjNmMTU4ODE1NmIwMDJiYjE2MTZhODNkNzU2NjJjZjE0MDc1MjI0OGQyYWVjMjhiN2E2NzBiZDYyM2E1MWI5MTEzZjBmN2I0YThiOTExOGQ2NzFkNmZlNjg2OTJhMmEzOTEzNWM1M2NkNzFjMTk2MDA5NjM0M2JmMjVlYWNkYjIwODJlZjU2YmNkMjAzZTkzOGNkYjg3MTZkZDBhZGM5ODBlZWI1MmMxNTAxODA2NGMxZmY2ZDMyZDMwZDliMjI4OTFiOWNjYTViNjRjNzFhNmI3ZmNlYjkwMTkzM2E3ODUwYyIsICJjaGFsbGVuZ2VfYmFzZTY0IjogIntDSEEtQjY0fSJ9"}}}'
-                }
-            },
         },
     },
     'Manifest HLS': {

src/CompKodiProps.cpp

@@ -411,6 +411,22 @@ void ADP::KODI_PROPS::CCompKodiProps::ParseManifestConfig(const std::string& dat
     {
       m_manifestConfig.liveDelay = jDictVal.GetUint64();
     }
+    else if (configName == "dash_utctiming" && jDictVal.IsObject())
+    {
+      for (auto& jPairUnwrap : jDictVal.GetObject()) // Iterate JSON dict
+      {
+        if (!jPairUnwrap.name.IsString() || !jPairUnwrap.value.IsString())
+        {
+          LOG::LogF(LOGERROR, "The manifest parameter \"dash_utctiming\" contains invalid values");
+          break;
+        }
+        std::pair<std::string, std::string> utcTiming;
+        utcTiming.first = jPairUnwrap.name.GetString();
+        utcTiming.second = jPairUnwrap.value.GetString();
+        m_manifestConfig.dashUTCTiming = utcTiming;
+        break;
+      }
+    }
     else
     {
       LOG::LogF(LOGERROR, "Unsupported \"%s\" config or wrong data type on \"%s\" property",

src/CompKodiProps.h

@@ -70,6 +70,8 @@ struct ManifestConfig
   bool hlsFixDiscontSequence{false};
   // Custom delay from LIVE edge in seconds
   uint64_t liveDelay{0};
+  // Allows to set a custom UTC Timing for DASH live streams (schemeIdUri, value)
+  std::optional<std::pair<std::string, std::string>> dashUTCTiming;
 };
 
 struct DrmCfg

src/codechandler/ttml/TTML.cpp

@@ -215,6 +215,11 @@ void TTML2SRT::ParseTagBody(pugi::xml_node nodeTT)
 void TTML2SRT::ParseTagSpan(pugi::xml_node spanNode, std::string& subText)
 {
   StackStyle(XML::GetAttrib(spanNode, "style"));
+  std::string_view beginTime = XML::GetAttrib(spanNode, "begin");
+  std::string_view endTime = XML::GetAttrib(spanNode, "end");
+  const bool hasTiming = !beginTime.empty() && !endTime.empty();
+  std::string text;
+
   // Parse additional style attributes of node and add them as another style stack
   StackStyle(ParseStyle(spanNode));
 
@@ -224,23 +229,28 @@ void TTML2SRT::ParseTagSpan(pugi::xml_node spanNode, std::string& subText)
     if (spanTextNode.type() == pugi::node_pcdata)
     {
       // It's a text part
-      AppendStyledText(spanTextNode.value(), subText);
+      AppendStyledText(spanTextNode.value(), text);
     }
     else if (spanTextNode.type() == pugi::node_element)
     {
       if (STRING::Compare(spanTextNode.name(), "span"))
       {
-        ParseTagSpan(spanTextNode, subText);
+        ParseTagSpan(spanTextNode, text);
       }
       else if (STRING::Compare(spanTextNode.name(), "br"))
       {
-        subText += "<br/>";
+        text += "<br/>";
       }
     }
   }
 
   UnstackStyle();
   UnstackStyle();
+
+  if (hasTiming)
+    StackSubtitle("child_span", beginTime, endTime, text);
+  else
+    subText += text;
 }
 
 void TTML2SRT::AppendStyledText(std::string_view textPart, std::string& subText)

src/parser/DASHTree.cpp

@@ -97,11 +97,39 @@ std::string DetectCodecFromMimeType(std::string_view mimeType)
   return "";
 }
 
+// \brief Make an HTTP request to get UTC Timing and return the string
+std::string RequestUTCTiming(const std::string& url, CURL::RequestType reqType)
+{
+  CURL::CUrl curl(url, reqType);
+  const int statusCode = curl.Open();
+  if (statusCode == -1 || statusCode >= 400)
+  {
+    LOG::LogF(LOGERROR, "Unable to retrieve UTC timing from url: %s", url.c_str());
+    return {};
+  }
+
+  std::string date;
+  if (reqType == CURL::RequestType::HEAD)
+  {
+    date = curl.GetResponseHeader("date");
+  }
+  else
+  {
+    if (curl.Read(date) != CURL::ReadStatus::IS_EOF)
+    {
+      LOG::LogF(LOGERROR, "Unable to retrieve UTC timing data from url: (url: %s)", url.c_str());
+      return {};
+    }
+  }
+  return date;
+}
+
 } // unnamed namespace
 
 
 adaptive::CDashTree::CDashTree(const CDashTree& left) : AdaptiveTree(left)
 {
+  m_clockOffset = left.m_clockOffset;
 }
 
 void adaptive::CDashTree::Configure(CHOOSER::IRepresentationChooser* reprChooser,
@@ -190,9 +218,26 @@ bool adaptive::CDashTree::ParseManifest(const std::string& data)
   }
 
   // Parse <MPD> <UTCTiming> tags
-  //! @todo: needed implementation
-  if (nodeMPD.child("UTCTiming"))
-    LOG::LogF(LOGWARNING, "The <UTCTiming> tag element is not supported so playback problems may occur.");
+  if (!m_clockOffset.has_value())
+    m_clockOffset = ResolveUTCTiming(nodeMPD);
+
+  // If TSB is not set but availabilityStartTime, use the last one as TSB
+  // since all segments from availabilityStartTime are available
+  if (m_timeShiftBufferDepth == 0 && available_time_ > 0)
+  {
+    const uint64_t now = stream_start_ + *m_clockOffset;
+    m_timeShiftBufferDepth = now - available_time_;
+  }
+
+  // TSB can be very large, limit it to avoid excessive memory consumption
+  uint64_t tsbLimitMs = 14400000; // Default 4 hours
+
+  auto& manifestCfg = CSrvBroker::GetKodiProps().GetManifestConfig();
+  if (manifestCfg.timeShiftBufferLimit.has_value())
+    tsbLimitMs = *manifestCfg.timeShiftBufferLimit * 1000;
+
+  if (m_timeShiftBufferDepth > tsbLimitMs)
+    m_timeShiftBufferDepth = tsbLimitMs;
 
   // Parse <MPD> <BaseURL> tag (just first, multi BaseURL not supported yet)
   std::string mpdUrl = base_url_;
@@ -312,21 +357,6 @@ void adaptive::CDashTree::ParseTagMPDAttribs(pugi::xml_node nodeMPD)
     available_time_ =
         static_cast<uint64_t>(XML::ParseDate(availabilityStartTimeStr.c_str()) * 1000);
 
-  // If TSB is not set but availabilityStartTime, use the last one as TSB
-  // since all segments from availabilityStartTime are available
-  if (m_timeShiftBufferDepth == 0 && available_time_ > 0)
-    m_timeShiftBufferDepth = stream_start_ - available_time_;
-
-  // TSB can be very large, limit it to avoid excessive memory consumption
-  uint64_t tsbLimitMs = 14400000; // Default 4 hours
-
-  auto& manifestCfg = CSrvBroker::GetKodiProps().GetManifestConfig();
-  if (manifestCfg.timeShiftBufferLimit.has_value())
-    tsbLimitMs = *manifestCfg.timeShiftBufferLimit * 1000;
-
-  if (m_timeShiftBufferDepth > tsbLimitMs)
-    m_timeShiftBufferDepth = tsbLimitMs;
-
   std::string suggestedPresentationDelayStr;
   if (XML::QueryAttrib(nodeMPD, "suggestedPresentationDelay", suggestedPresentationDelayStr))
     m_liveDelay = static_cast<uint64_t>(XML::ParseDuration(suggestedPresentationDelayStr));
@@ -1078,7 +1108,8 @@ void adaptive::CDashTree::ParseTagRepresentation(pugi::xml_node nodeRepr,
           periodDurMs = m_mediaPresDuration;
 
         // Generate segments from TSB
-        uint64_t tsbStart = (stream_start_ - available_time_) - m_timeShiftBufferDepth;
+        const uint64_t tsbNow = stream_start_ + *m_clockOffset;
+        uint64_t tsbStart = (tsbNow - available_time_) - m_timeShiftBufferDepth;
         uint64_t tsbEnd = tsbStart + m_timeShiftBufferDepth;
         if (m_timeShiftBufferDepth > 0 && tsbEnd > periodStartMs)
         {
@@ -1095,16 +1126,8 @@ void adaptive::CDashTree::ParseTagRepresentation(pugi::xml_node nodeRepr,
 
           segmentsCount = std::max<size_t>(durationMs / segDurMs, 1);
 
-          if (available_time_ == 0)
-          {
-            time = tsbStart * segTemplate->GetTimescale() / 1000;
-            segNumber = tsbStart / segDurMs;
-          }
-          else
-          {
-            time += tsbStart * segTemplate->GetTimescale() / 1000;
-            segNumber += tsbStart / segDurMs;
-          }
+          segNumber += (tsbStart - periodStartMs) / segDurMs;
+          time += (segNumber - segTemplate->GetStartNumber()) * segTemplate->GetDuration();
         }
         else if (periodDurMs > 0)
         {
@@ -1119,11 +1142,18 @@ void adaptive::CDashTree::ParseTagRepresentation(pugi::xml_node nodeRepr,
         else if (repr->HasSegmentEndNr())
           segNumberEnd = repr->GetSegmentEndNr();
 
+        // Current wall clock, in timescale
+        const uint64_t nowScaled = (UTILS::GetTimestampMs() + *m_clockOffset) * segTimescale / 1000;
+
         for (size_t i = 0; i < segmentsCount; ++i)
         {
           if (segNumber > segNumberEnd)
             break;
 
+          // Make sure to not add segments of the future
+          if (time > nowScaled)
+            break;
+
           CSegment seg;
           seg.startPTS_ = time;
           seg.m_endPts = seg.startPTS_ + segDuration;
@@ -1466,6 +1496,88 @@ uint32_t adaptive::CDashTree::ParseAudioChannelConfig(pugi::xml_node node)
   return channels;
 }
 
+int64_t adaptive::CDashTree::ResolveUTCTiming(pugi::xml_node node)
+{
+  std::vector<std::pair<std::string, std::string>> utcTimings;
+
+  // Custom UTC timing
+  auto& manifestCfg = CSrvBroker::GetKodiProps().GetManifestConfig();
+  if (manifestCfg.dashUTCTiming.has_value())
+    utcTimings.emplace_back(*manifestCfg.dashUTCTiming);
+
+  // Parse <UTCTiming> child tags
+  for (xml_node nodeUTC : node.children("UTCTiming"))
+  {
+    utcTimings.emplace_back(XML::GetAttrib(nodeUTC, "schemeIdUri"), XML::GetAttrib(nodeUTC, "value"));
+  }
+
+  std::optional<int64_t> tsMs;
+
+  // Elements are in order of preference so the first have the highest priority
+  for (auto& [scheme, value] : utcTimings)
+  {
+    if (scheme == "urn:mpeg:dash:utc:http-head:2012" ||
+        scheme == "urn:mpeg:dash:utc:http-head:2014")
+    {
+      const uint64_t ts =
+          UTILS::ConvertDate2822ToTs(RequestUTCTiming(value, CURL::RequestType::HEAD));
+      if (ts == 0)
+      {
+        LOG::LogF(LOGERROR, "UTCTiming conversion failed from scheme \"%s\"", scheme.c_str());
+        continue;
+      }
+      tsMs = static_cast<int64_t>(ts * 1000);
+      break;
+    }
+    else if (scheme == "urn:mpeg:dash:utc:http-xsdate:2014" ||
+             scheme == "urn:mpeg:dash:utc:http-iso:2014" ||
+             scheme == "urn:mpeg:dash:utc:http-xsdate:2012" ||
+             scheme == "urn:mpeg:dash:utc:http-iso:2012")
+    {
+      const double ts = XML::ParseDate(RequestUTCTiming(value, CURL::RequestType::AUTO).c_str(), 0);
+      if (ts == 0)
+      {
+        LOG::LogF(LOGERROR, "UTCTiming conversion failed from scheme \"%s\"", scheme.c_str());
+        continue;
+      }
+      tsMs = static_cast<int64_t>(ts * 1000);
+      break;
+    }
+    else if (scheme == "urn:mpeg:dash:utc:direct:2014" ||
+             scheme == "urn:mpeg:dash:utc:direct:2012")
+    {
+      const double ts = XML::ParseDate(value.c_str(), 0);
+      if (ts == 0)
+      {
+        LOG::LogF(LOGERROR, "A problem occurred in the UTCTiming scheme \"%s\" parsing", scheme.c_str());
+        continue;
+      }
+      tsMs = static_cast<int64_t>(ts * 1000);
+      break;
+    }
+    else if (scheme == "urn:mpeg:dash:utc:http-ntp:2014" ||
+             scheme == "urn:mpeg:dash:utc:ntp:2014" ||
+             scheme == "urn:mpeg:dash:utc:sntp:2014")
+    {
+      LOG::Log(LOGDEBUG, "NTP UTCTiming scheme \"%s\" not supported", scheme.c_str());
+    }
+    else
+      LOG::Log(LOGDEBUG, "UTCTiming scheme \"%s\" not supported", scheme.c_str());
+  }
+
+  int64_t offset{0};
+
+  if (tsMs.has_value())
+  {
+    offset = *tsMs - GetTimestamp();
+    LOG::Log(LOGDEBUG, "UTCTiming clock offset %lli ms", offset);
+  }
+  else if (!utcTimings.empty())
+    LOG::Log(LOGWARNING, "Unable to get UTCTiming, playback problems may occur");
+
+  return offset;
+}
+
 //! @todo: MergeAdpSets its a kind of workaround
 //! its missing a middle interface where store "streams" (or media tracks) data in a form
 //! that is detached from "tree" interface, this would avoid the force
@@ -1774,9 +1886,6 @@ bool adaptive::CDashTree::InsertLiveSegment(PLAYLIST::CPeriod* period,
     return false;
   */
 
-  //! @todo: expired_segments_ should be reworked, see also other parsers
-  repr->expired_segments_++;
-
   const CSegment* segment = repr->Timeline().Get(pos);
 
   if (!segment)
@@ -1786,11 +1895,28 @@ bool adaptive::CDashTree::InsertLiveSegment(PLAYLIST::CPeriod* period,
     return false;
   }
 
+  // Current wall clock, in timescale
+  const uint64_t nowScaled =
+      (UTILS::GetTimestampMs() + *m_clockOffset) * repr->GetSegmentTemplate()->GetTimescale() / 1000;
+
+  const uint64_t segEndPts = segment->m_endPts + repr->GetSegmentTemplate()->GetDuration();
+
+  if (segEndPts >= nowScaled)
+  {
+    // Attempt to add segments beyond the current time are not available segments, if it happens
+    // IsWaitForSegment will be set and playback becomes buffering until the next manifest update
+    LOG::LogF(LOGDEBUG, "Insert live segment skipped! Attempt to add future segments (rep id: %s)",
+              repr->GetId().c_str());
+    return false;
+  }
+
+  //! @todo: expired_segments_ should be reworked, see also other parsers
+  repr->expired_segments_++;
+
   CSegment segCopy = *segment;
-  uint64_t dur = segCopy.m_endPts - segCopy.startPTS_;
-  segCopy.startPTS_ = segCopy.m_endPts;
-  segCopy.m_endPts = segCopy.startPTS_ + dur;
-  segCopy.m_time = segCopy.m_endPts;
+  segCopy.startPTS_ = segment->m_endPts;
+  segCopy.m_endPts = segEndPts;
+  segCopy.m_time = segCopy.startPTS_;
   segCopy.m_number++;
 
   LOG::LogF(LOGDEBUG, "Insert live segment to adptation set \"%s\" (Start PTS: %llu, number: %llu)",