blob: 6a343f4849076f7c731b198ffee740fc10ee479d [file] [log] [blame]
// Copyright 2018 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.
#ifndef MEDIA_GPU_TEST_VIDEO_PLAYER_VIDEO_PLAYER_H_
#define MEDIA_GPU_TEST_VIDEO_PLAYER_VIDEO_PLAYER_H_
#include <limits.h>
#include <memory>
#include <utility>
#include <vector>
#include "base/callback.h"
#include "base/macros.h"
#include "base/sequence_checker.h"
#include "base/synchronization/condition_variable.h"
#include "base/synchronization/lock.h"
#include "base/thread_annotations.h"
#include "media/gpu/test/video_frame_helpers.h"
#include "media/gpu/test/video_player/frame_renderer.h"
namespace gpu {
class GpuMemoryBufferFactory;
}
namespace media {
namespace test {
class FrameRenderer;
class Video;
class VideoDecoderClient;
struct VideoDecoderClientConfig;
// Default timeout used when waiting for events.
constexpr base::TimeDelta kDefaultEventWaitTimeout = base::Seconds(30);
enum class VideoPlayerState : size_t {
kUninitialized = 0,
kIdle,
kDecoding,
kDestroyed,
};
enum class VideoPlayerEvent : size_t {
kInitialized,
kFrameDecoded,
kFlushing,
kFlushDone,
kResetting,
kResetDone,
kConfigInfo, // A config info was encountered in an H.264/HEVC video stream.
kNumEvents,
};
// The video player provides a framework to build video decode accelerator tests
// upon. It provides methods to manipulate video playback, and wait for specific
// events to occur.
class VideoPlayer {
public:
using EventCallback = base::RepeatingCallback<bool(VideoPlayerEvent)>;
VideoPlayer(const VideoPlayer&) = delete;
VideoPlayer& operator=(const VideoPlayer&) = delete;
~VideoPlayer();
// Create an instance of the video player. The |gpu_memory_buffer_factory|,
// |frame_renderer| and |frame_processors| will not be owned by the video
// player. The caller should guarantee they outlive the video player.
static std::unique_ptr<VideoPlayer> Create(
const VideoDecoderClientConfig& config,
gpu::GpuMemoryBufferFactory* gpu_memory_buffer_factory,
std::unique_ptr<FrameRenderer> frame_renderer,
std::vector<std::unique_ptr<VideoFrameProcessor>> frame_processors = {});
// Wait until all frame processors have finished processing. Returns whether
// processing was successful.
bool WaitForFrameProcessors();
// Wait until the renderer has finished rendering all queued frames.
void WaitForRenderer();
// Set the maximum time we will wait for an event to finish.
void SetEventWaitTimeout(base::TimeDelta timeout);
// Initialize the video player for the specified |video|. This function can be
// called multiple times and needs to be called before Play(). The |video|
// will not be owned by the video player, the caller should guarantee it
// outlives the video player.
bool Initialize(const Video* video);
// Play the video asynchronously.
void Play();
// Play the video asynchronously. Automatically pause decoding when the
// specified |event| occurred |event_count| times.
void PlayUntil(VideoPlayerEvent event, size_t event_count = 1);
// Reset the decoder to the beginning of the video stream.
void Reset();
// Flush the decoder.
void Flush();
// Get current media time.
base::TimeDelta GetCurrentTime() const;
// Get the current frame number.
size_t GetCurrentFrame() const;
// Get the current state of the video player.
VideoPlayerState GetState() const;
// Get the frame renderer associated with the video player.
FrameRenderer* GetFrameRenderer() const;
// Wait for an event to occur the specified number of times. All events that
// occurred since last calling this function will be taken into account. All
// events with different types will be consumed. Will return false if the
// specified timeout is exceeded while waiting for the events.
bool WaitForEvent(VideoPlayerEvent event, size_t times = 1);
// Helper function to wait for a FlushDone event.
bool WaitForFlushDone();
// Helper function to wait for a ResetDone event.
bool WaitForResetDone();
// Helper function to wait for the specified number of FrameDecoded events.
bool WaitForFrameDecoded(size_t times);
// Get the number of times the specified event occurred.
size_t GetEventCount(VideoPlayerEvent event) const;
// Helper function to get the number of ResetDone events thrown.
size_t GetResetDoneCount() const;
// Helper function to get the number of FlushDone events thrown.
size_t GetFlushDoneCount() const;
// Helper function to get the number of FrameDecoded events thrown.
size_t GetFrameDecodedCount() const;
private:
VideoPlayer();
bool CreateDecoderClient(
const VideoDecoderClientConfig& config,
gpu::GpuMemoryBufferFactory* gpu_memory_buffer_factory,
std::unique_ptr<FrameRenderer> frame_renderer,
std::vector<std::unique_ptr<VideoFrameProcessor>> frame_processors);
void Destroy();
// Notify the video player an event has occurred (e.g. frame decoded). Returns
// whether the decoder client should continue decoding frames.
bool NotifyEvent(VideoPlayerEvent event);
const Video* video_ = nullptr;
VideoPlayerState video_player_state_ = VideoPlayerState::kUninitialized;
std::unique_ptr<VideoDecoderClient> decoder_client_;
// The timeout used when waiting for events.
base::TimeDelta event_timeout_ = kDefaultEventWaitTimeout;
mutable base::Lock event_lock_;
base::ConditionVariable event_cv_;
std::vector<VideoPlayerEvent> video_player_events_ GUARDED_BY(event_lock_);
size_t video_player_event_counts_[static_cast<size_t>(
VideoPlayerEvent::kNumEvents)] GUARDED_BY(event_lock_);
// The next event ID to start at, when waiting for events.
size_t event_id_ GUARDED_BY(event_lock_);
// Automatically pause decoding once the video player has seen the specified
// number of events occur.
std::pair<VideoPlayerEvent, size_t> play_until_{
VideoPlayerEvent::kNumEvents, std::numeric_limits<size_t>::max()};
SEQUENCE_CHECKER(sequence_checker_);
};
} // namespace test
} // namespace media
#endif // MEDIA_GPU_TEST_VIDEO_PLAYER_VIDEO_PLAYER_H_