[android] Support configuring maximum number of samples per write to SbPlayer from webapp

cobalt/media/base/sbplayer_pipeline.cc

@@ -134,7 +134,7 @@ SbPlayerPipeline::SbPlayerPipeline(
     const scoped_refptr<base::SequencedTaskRunner>& task_runner,
     const GetDecodeTargetGraphicsContextProviderFunc&
         get_decode_target_graphics_context_provider_func,
-    bool allow_resume_after_suspend, bool allow_batched_sample_write,
+    bool allow_resume_after_suspend, int audio_batched_sample_write,
     bool force_punch_out_by_default,
 #if SB_API_VERSION >= 15
     TimeDelta audio_write_duration_local, TimeDelta audio_write_duration_remote,
@@ -146,7 +146,7 @@ SbPlayerPipeline::SbPlayerPipeline(
       sbplayer_interface_(interface),
       task_runner_(task_runner),
       allow_resume_after_suspend_(allow_resume_after_suspend),
-      allow_batched_sample_write_(allow_batched_sample_write),
+      audio_batched_sample_write_(audio_batched_sample_write),
       window_(window),
       get_decode_target_graphics_context_provider_func_(
           get_decode_target_graphics_context_provider_func),
@@ -1111,8 +1111,10 @@ void SbPlayerPipeline::OnNeedData(DemuxerStream::Type type,
     return;
   }
 
-  int max_buffers =
-      allow_batched_sample_write_ ? max_number_of_buffers_to_write : 1;
+  int max_buffers = audio_batched_sample_write_ > 1
+                        ? std::min(max_number_of_buffers_to_write,
+                                   audio_batched_sample_write_)
+                        : 1;
 
   if (GetReadInProgress(type)) return;
 
@@ -1164,13 +1166,13 @@ void SbPlayerPipeline::OnNeedData(DemuxerStream::Type type,
         audio_read_delayed_ = true;
         return;
       }
-      if (allow_batched_sample_write_ &&
+      if (audio_batched_sample_write_ > 1 &&
           !time_ahead_of_playback.is_negative()) {
         estimated_max_buffers = GetEstimatedMaxBuffers(adjusted_write_duration,
                                                        time_ahead_of_playback,
                                                        false /* is_preroll */);
       }
-    } else if (allow_batched_sample_write_) {
+    } else if (audio_batched_sample_write_ > 1) {
       if (!time_ahead_of_playback_for_preroll.is_negative()) {
         estimated_max_buffers = GetEstimatedMaxBuffers(
             adjusted_write_duration_for_preroll,
@@ -1226,7 +1228,7 @@ int SbPlayerPipeline::GetEstimatedMaxBuffers(TimeDelta write_duration,
   DCHECK_GE(time_ahead_of_playback.InMicroseconds(), 0);
 
   int estimated_max_buffers = 1;
-  if (!allow_batched_sample_write_ ||
+  if (!(audio_batched_sample_write_ > 1) ||
       write_duration <= time_ahead_of_playback) {
     return estimated_max_buffers;
   }

cobalt/media/base/sbplayer_pipeline.h

@@ -63,7 +63,7 @@ class MEDIA_EXPORT SbPlayerPipeline : public Pipeline,
                    const GetDecodeTargetGraphicsContextProviderFunc&
                        get_decode_target_graphics_context_provider_func,
                    bool allow_resume_after_suspend,
-                   bool allow_batched_sample_write,
+                   int audio_batched_sample_write,
                    bool force_punch_out_by_default,
 #if SB_API_VERSION >= 15
                    TimeDelta audio_write_duration_local,
@@ -222,8 +222,11 @@ class MEDIA_EXPORT SbPlayerPipeline : public Pipeline,
   // Whether we should save DecoderBuffers for resume after suspend.
   const bool allow_resume_after_suspend_;
 
-  // Whether we enable batched sample write functionality.
-  const bool allow_batched_sample_write_;
+  // The number of samples per write that is allowed at once.
+  // The minimum number of |audio_batched_sample_write_| and
+  // SbPlayerGetMaximumNumberOfSamplesPerWrite() specifies
+  // the maximum number of samples SbPlayerWriteSamples() can accept.
+  const int audio_batched_sample_write_;
 
   // The default output mode passed to `SbPlayerGetPreferredOutputMode()`.
   SbPlayerOutputMode default_output_mode_ = kSbPlayerOutputModeInvalid;

cobalt/media/media_module.cc

@@ -186,10 +186,9 @@ class CanPlayTypeHandlerStarboard : public CanPlayTypeHandler {
 }  // namespace
 
 bool MediaModule::SetConfiguration(const std::string& name, int32 value) {
-  if (name == "EnableBatchedSampleWrite") {
-    allow_batched_sample_write_ = value;
-    LOG(INFO) << (allow_batched_sample_write_ ? "Enabling" : "Disabling")
-              << " batched sample write.";
+  if (name == "AudioBatchedSampleWrite" && value > 0) {
+    audio_batched_sample_write_ = value;
+    LOG(INFO) << "Set MaximumNumberOfSamplesPerWrite to " << value;
     return true;
   } else if (name == "ForcePunchOutByDefault") {
     force_punch_out_by_default_ = value;
@@ -249,7 +248,7 @@ std::unique_ptr<WebMediaPlayer> MediaModule::CreateWebMediaPlayer(
       base::Bind(&MediaModule::GetSbDecodeTargetGraphicsContextProvider,
                  base::Unretained(this)),
       client, this, options_.allow_resume_after_suspend,
-      allow_batched_sample_write_, force_punch_out_by_default_,
+      audio_batched_sample_write_, force_punch_out_by_default_,
 #if SB_API_VERSION >= 15
       audio_write_duration_local_, audio_write_duration_remote_,
 #endif  // SB_API_VERSION >= 15

cobalt/media/media_module.h

@@ -123,7 +123,7 @@ class MediaModule : public WebMediaPlayerFactory,
   Players players_;
   bool suspended_ = false;
 
-  bool allow_batched_sample_write_ = false;
+  int audio_batched_sample_write_ = 1;
   // When set to `false` (the default value), Cobalt calls
   // `SbPlayerGetPreferredOutputMode()` with `kSbPlayerOutputModeInvalid` when
   // there is no preference on output mode.

cobalt/media/player/web_media_player_impl.cc

@@ -109,7 +109,7 @@ WebMediaPlayerImpl::WebMediaPlayerImpl(
     const Pipeline::GetDecodeTargetGraphicsContextProviderFunc&
         get_decode_target_graphics_context_provider_func,
     WebMediaPlayerClient* client, WebMediaPlayerDelegate* delegate,
-    bool allow_resume_after_suspend, bool allow_batched_sample_write,
+    bool allow_resume_after_suspend, int audio_batched_sample_write,
     bool force_punch_out_by_default,
 #if SB_API_VERSION >= 15
     base::TimeDelta audio_write_duration_local,
@@ -123,7 +123,7 @@ WebMediaPlayerImpl::WebMediaPlayerImpl(
       client_(client),
       delegate_(delegate),
       allow_resume_after_suspend_(allow_resume_after_suspend),
-      allow_batched_sample_write_(allow_batched_sample_write),
+      audio_batched_sample_write_(audio_batched_sample_write),
       force_punch_out_by_default_(force_punch_out_by_default),
       proxy_(new WebMediaPlayerProxy(task_runner_, this)),
       media_log_(media_log),
@@ -143,7 +143,7 @@ WebMediaPlayerImpl::WebMediaPlayerImpl(
   pipeline_ = new SbPlayerPipeline(
       interface, window, pipeline_thread_.task_runner(),
       get_decode_target_graphics_context_provider_func,
-      allow_resume_after_suspend_, allow_batched_sample_write_,
+      allow_resume_after_suspend_, audio_batched_sample_write_,
       force_punch_out_by_default_,
 #if SB_API_VERSION >= 15
       audio_write_duration_local, audio_write_duration_remote,

cobalt/media/player/web_media_player_impl.h

@@ -111,7 +111,7 @@ class WebMediaPlayerImpl : public WebMediaPlayer,
                      WebMediaPlayerClient* client,
                      WebMediaPlayerDelegate* delegate,
                      bool allow_resume_after_suspend,
-                     bool allow_batched_sample_write,
+                     int audio_batched_sample_write,
                      bool force_punch_out_by_default,
 #if SB_API_VERSION >= 15
                      base::TimeDelta audio_write_duration_local,
@@ -304,7 +304,7 @@ class WebMediaPlayerImpl : public WebMediaPlayer,
   WebMediaPlayerClient* const client_;
   WebMediaPlayerDelegate* const delegate_;
   const bool allow_resume_after_suspend_;
-  const bool allow_batched_sample_write_;
+  const int audio_batched_sample_write_;
   const bool force_punch_out_by_default_;
   scoped_refptr<DecodeTargetProvider> decode_target_provider_;
 

starboard/android/shared/BUILD.gn

@@ -380,6 +380,7 @@ static_library("starboard_platform") {
     "player_components_factory.h",
     "player_create.cc",
     "player_destroy.cc",
+    "player_get_maximum_number_of_samples_per_write.cc",
     "player_get_preferred_output_mode.cc",
     "player_set_bounds.cc",
     "player_set_max_video_input_size.cc",
@@ -436,6 +437,7 @@ static_library("starboard_platform") {
   sources -= [
     "//starboard/shared/starboard/player/player_create.cc",
     "//starboard/shared/starboard/player/player_destroy.cc",
+    "//starboard/shared/starboard/player/player_get_maximum_number_of_samples_per_write.cc",
     "//starboard/shared/starboard/player/player_get_preferred_output_mode_prefer_punchout.cc",
     "//starboard/shared/starboard/player/player_set_bounds.cc",
     "//starboard/shared/starboard/player/player_set_playback_rate.cc",

starboard/android/shared/player_get_maximum_number_of_samples_per_write.cc

@@ -0,0 +1,20 @@
+// Copyright 2024 The Cobalt Authors. All Rights Reserved.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#include "starboard/player.h"
+
+int SbPlayerGetMaximumNumberOfSamplesPerWrite(SbPlayer player,
+                                              SbMediaType sample_type) {
+  return 256;
+}