Commit abf78a17 authored by Francois Cartegnie's avatar Francois Cartegnie

demux: adaptative: allow to refresh segments

parent 09c94ed7
...@@ -84,6 +84,9 @@ SegmentChunk * SegmentTracker::getNextChunk(bool switch_allowed) ...@@ -84,6 +84,9 @@ SegmentChunk * SegmentTracker::getNextChunk(bool switch_allowed)
initializing = true; initializing = true;
} }
/* Ensure content is loaded */
rep->runLocalUpdates();
if(!init_sent) if(!init_sent)
{ {
init_sent = true; init_sent = true;
......
...@@ -308,6 +308,11 @@ void SegmentInformation::pruneBySegmentNumber(uint64_t num) ...@@ -308,6 +308,11 @@ void SegmentInformation::pruneBySegmentNumber(uint64_t num)
childs.at(i)->pruneBySegmentNumber(num); childs.at(i)->pruneBySegmentNumber(num);
} }
void SegmentInformation::runLocalUpdates()
{
}
SegmentInformation::SwitchPolicy SegmentInformation::getSwitchPolicy() const SegmentInformation::SwitchPolicy SegmentInformation::getSwitchPolicy() const
{ {
if(switchpolicy == SWITCH_UNKNOWN) if(switchpolicy == SWITCH_UNKNOWN)
......
...@@ -84,6 +84,7 @@ namespace adaptative ...@@ -84,6 +84,7 @@ namespace adaptative
void getDurationsRange(mtime_t *, mtime_t *) const; void getDurationsRange(mtime_t *, mtime_t *) const;
virtual void mergeWith(SegmentInformation *, mtime_t); virtual void mergeWith(SegmentInformation *, mtime_t);
virtual void pruneBySegmentNumber(uint64_t); virtual void pruneBySegmentNumber(uint64_t);
virtual void runLocalUpdates();
protected: protected:
std::size_t getAllSegments(std::vector<ISegment *> &) const; std::size_t getAllSegments(std::vector<ISegment *> &) const;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment