servo_media_player/
lib.rs

1/* This Source Code Form is subject to the terms of the Mozilla Public
2 * License, v. 2.0. If a copy of the MPL was not distributed with this
3 * file, You can obtain one at https://mozilla.org/MPL/2.0/. */
4
5use std::ops::Range;
6use std::time::Duration;
7
8extern crate servo_media_streams as streams;
9extern crate servo_media_traits;
10
11pub mod audio;
12pub mod context;
13pub mod metadata;
14pub mod video;
15
16use serde::{Deserialize, Serialize};
17use servo_base::generic_channel::{self, GenericSender};
18use servo_media_traits::MediaInstance;
19use streams::registry::MediaStreamId;
20
21#[derive(Clone, Debug, Deserialize, Serialize)]
22pub enum PlaybackState {
23    Stopped,
24    Buffering,
25    Paused,
26    Playing,
27}
28
29#[derive(Debug, PartialEq)]
30pub enum PlayerError {
31    /// Backend specific error.
32    Backend(String),
33    /// Could not push buffer contents to the player.
34    BufferPushFailed,
35    /// The player cannot consume more data.
36    EnoughData,
37    /// Setting End Of Stream failed.
38    EOSFailed,
39    /// The media stream is not seekable.
40    NonSeekableStream,
41    /// Tried to seek out of range.
42    SeekOutOfRange,
43    /// Setting an audio or video stream failed.
44    /// Possibly because the type of source is not PlayerSource::Stream.
45    SetStreamFailed,
46    // Setting an audio or video track failed.
47    SetTrackFailed,
48}
49
50pub type SeekLockMsg = (bool, GenericSender<()>);
51
52#[derive(Clone, Debug, Deserialize, Serialize)]
53pub struct SeekLock {
54    pub lock_channel: GenericSender<SeekLockMsg>,
55}
56
57impl SeekLock {
58    pub fn unlock(&self, result: bool) {
59        let (ack_sender, ack_recv) =
60            generic_channel::channel::<()>().expect("Could not create IPC channel");
61        self.lock_channel.send((result, ack_sender)).unwrap();
62        ack_recv.recv().unwrap()
63    }
64}
65
66#[derive(Clone, Debug, Deserialize, Serialize)]
67pub enum PlayerEvent {
68    EndOfStream,
69    /// The player has enough data. The client should stop pushing data into.
70    EnoughData,
71    Error(String),
72    VideoFrameUpdated,
73    MetadataUpdated(metadata::Metadata),
74    // The `None` value means the duration is unknown, in which case this is likely a live stream.
75    DurationChanged(Option<Duration>),
76    /// The internal player queue is running out of data. The client should start
77    /// pushing more data.
78    NeedData,
79    PositionChanged(f64),
80    /// The player needs the data to perform a seek to the given offset in bytes.
81    /// The next push_data should get the buffers from the new offset.
82    /// The player will be blocked until the user unlocks it through
83    /// the given SeekLock instance.
84    /// This event is only received for seekable stream types.
85    SeekData(u64, SeekLock),
86    /// The player has performed a seek to the given time offset in seconds.
87    SeekDone(f64),
88    StateChanged(PlaybackState),
89}
90
91#[derive(Clone, Copy, Debug, Deserialize, PartialEq, Serialize)]
92pub enum StreamType {
93    /// No seeking is supported in the stream, such as a live stream.
94    Stream,
95    /// The stream is seekable.
96    Seekable,
97}
98
99pub trait Player: Send + MediaInstance {
100    fn play(&self) -> Result<(), PlayerError>;
101    fn pause(&self) -> Result<(), PlayerError>;
102    fn paused(&self) -> bool;
103    fn can_resume(&self) -> bool;
104    fn stop(&self) -> Result<(), PlayerError>;
105    fn seek(&self, time: f64) -> Result<(), PlayerError>;
106    fn seekable(&self) -> Vec<Range<f64>>;
107    fn set_mute(&self, muted: bool) -> Result<(), PlayerError>;
108    fn muted(&self) -> bool;
109    fn set_volume(&self, volume: f64) -> Result<(), PlayerError>;
110    fn volume(&self) -> f64;
111    fn set_input_size(&self, size: u64) -> Result<(), PlayerError>;
112    fn set_seekable(&self, seekable: bool) -> Result<(), PlayerError>;
113    fn set_playback_rate(&self, playback_rate: f64) -> Result<(), PlayerError>;
114    fn playback_rate(&self) -> f64;
115    fn push_data(&self, data: Vec<u8>) -> Result<(), PlayerError>;
116    fn end_of_stream(&self) -> Result<(), PlayerError>;
117    /// Get the list of time ranges in seconds that have been buffered.
118    fn buffered(&self) -> Vec<Range<f64>>;
119    /// Set the stream to be played by the player.
120    /// Only a single stream of the same type (audio or video) can be set.
121    /// Subsequent calls with a stream of the same type will override the previously
122    /// set stream.
123    /// This method requires the player to be constructed with StreamType::Stream.
124    /// It is important to give the correct value of `only_stream` indicating
125    /// that the audio or video stream being set is the only one expected.
126    /// Subsequent calls to `set_stream` after the `only_stream` flag has been
127    /// set to true will fail.
128    fn set_stream(&self, stream: &MediaStreamId, only_stream: bool) -> Result<(), PlayerError>;
129    /// If player's rendering draws using GL textures
130    fn render_use_gl(&self) -> bool;
131    fn set_audio_track(&self, stream_index: i32, enabled: bool) -> Result<(), PlayerError>;
132    fn set_video_track(&self, stream_index: i32, enabled: bool) -> Result<(), PlayerError>;
133}
servo_media_player/lib.rs

servo_media_player/
lib.rs
