Experiment with more aggressive MSE GC on memory pressure

media/filters/source_buffer_state.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "media/filters/source_buffer_state.h"
 
 #include <set>
 
 #include "base/callback_helpers.h"
 #include "base/command_line.h"
@@ skipping 239 matching lines @@
   for (const auto& it : video_streams_) {
     it.second->Remove(start, end, duration);
   }
 
   for (const auto& it : text_streams_) {
     it.second->Remove(start, end, duration);
   }
 }
 
 bool SourceBufferState::EvictCodedFrames(DecodeTimestamp media_time,
-                                         size_t newDataSize) {
+                                         size_t eviction_size) {
   size_t total_buffered_size = 0;
   for (const auto& it : audio_streams_)
     total_buffered_size += it.second->GetBufferedSize();
   for (const auto& it : video_streams_)
     total_buffered_size += it.second->GetBufferedSize();
   for (const auto& it : text_streams_)
     total_buffered_size += it.second->GetBufferedSize();
 
   DVLOG(3) << __func__ << " media_time=" << media_time.InSecondsF()
-           << " newDataSize=" << newDataSize
+           << " eviction_size=" << eviction_size
            << " total_buffered_size=" << total_buffered_size;
 
   if (total_buffered_size == 0)
     return true;
 
   bool success = true;
   for (const auto& it : audio_streams_) {
     uint64_t curr_size = it.second->GetBufferedSize();
     if (curr_size == 0)
       continue;
-    uint64_t estimated_new_size = newDataSize * curr_size / total_buffered_size;
-    DCHECK_LE(estimated_new_size, SIZE_MAX);
-    success &= it.second->EvictCodedFrames(
-        media_time, static_cast<size_t>(estimated_new_size));
+    uint64_t evict_size = eviction_size * curr_size / total_buffered_size;
+    DCHECK_LE(evict_size, SIZE_MAX);
+    success &= it.second->EvictCodedFrames(media_time,
+                                           static_cast<size_t>(evict_size));
   }
   for (const auto& it : video_streams_) {
     uint64_t curr_size = it.second->GetBufferedSize();
     if (curr_size == 0)
       continue;
-    uint64_t estimated_new_size = newDataSize * curr_size / total_buffered_size;
-    DCHECK_LE(estimated_new_size, SIZE_MAX);
-    success &= it.second->EvictCodedFrames(
-        media_time, static_cast<size_t>(estimated_new_size));
+    uint64_t evict_size = eviction_size * curr_size / total_buffered_size;
+    DCHECK_LE(evict_size, SIZE_MAX);
+    success &= it.second->EvictCodedFrames(media_time,
+                                           static_cast<size_t>(evict_size));
   }
   for (const auto& it : text_streams_) {
     uint64_t curr_size = it.second->GetBufferedSize();
     if (curr_size == 0)
       continue;
-    uint64_t estimated_new_size = newDataSize * curr_size / total_buffered_size;
-    DCHECK_LE(estimated_new_size, SIZE_MAX);
-    success &= it.second->EvictCodedFrames(
-        media_time, static_cast<size_t>(estimated_new_size));
+    uint64_t evict_size = eviction_size * curr_size / total_buffered_size;
+    DCHECK_LE(evict_size, SIZE_MAX);
+    success &= it.second->EvictCodedFrames(media_time,
+                                           static_cast<size_t>(evict_size));
   }
 
   DVLOG(3) << __func__ << " success=" << success;
   return success;
 }
 
+void SourceBufferState::OnMemoryPressure(
+    DecodeTimestamp media_time,
+    base::MemoryPressureListener::MemoryPressureLevel memory_pressure_level) {
+  size_t total_released = 0;
+
+  // Under moderate memory pressure we'll try to release about half of each
+  // stream's memory limit. But for critical memory pressure we'll want to
+  // release as much as possible.
+  size_t mem_pressure_factor = 2;
+  if (memory_pressure_level ==
+      base::MemoryPressureListener::MEMORY_PRESSURE_LEVEL_CRITICAL)
+    mem_pressure_factor = 1;
+
+  // Try to perform garbage collection in video streams first, since that's
+  // where we'll probably get most memory savings.
+  for (const auto& it : video_streams_) {
+    size_t released = 0;
+    it.second->EvictCodedFrames(
+        media_time, it.second->stream_memory_limit() / mem_pressure_factor,
+        &released);
+    total_released += released;
+  }
+  for (const auto& it : audio_streams_) {
+    size_t released = 0;
+    it.second->EvictCodedFrames(
+        media_time, it.second->stream_memory_limit() / mem_pressure_factor,
+        &released);
+    total_released += released;
+  }
+  for (const auto& it : text_streams_) {
+    size_t released = 0;
+    it.second->EvictCodedFrames(
+        media_time, it.second->stream_memory_limit() / mem_pressure_factor,
+        &released);
+    total_released += released;
+  }
+  DVLOG(3) << __func__ << " total_released=" << total_released;
+}
+
 Ranges<TimeDelta> SourceBufferState::GetBufferedRanges(TimeDelta duration,
                                                        bool ended) const {
   RangesList ranges_list;
   for (const auto& it : audio_streams_)
     ranges_list.push_back(it.second->GetBufferedRanges(duration));
 
   for (const auto& it : video_streams_)
     ranges_list.push_back(it.second->GetBufferedRanges(duration));
 
   for (const auto& it : text_streams_)
@@ skipping 569 matching lines @@
 }
 void SourceBufferState::OnSourceInitDone(
     const StreamParser::InitParameters& params) {
   DCHECK_EQ(state_, PENDING_PARSER_INIT);
   state_ = PARSER_INITIALIZED;
   auto_update_timestamp_offset_ = params.auto_update_timestamp_offset;
   base::ResetAndReturn(&init_cb_).Run(params);
 }
 
 }  // namespace media