github-mirrors/librespot
1
0
Fork 0
mirror of https://github.com/librespot-org/librespot.git synced 2024-12-18 17:11:53 +00:00
Code Issues Projects Releases Packages Wiki Activity

Simple block of playback thread based on buffer size.

Browse source
This commit is contained in:
Will Stott 2019-03-20 13:23:20 +00:00
parent 49fd48b42a
commit 587aa9c711
2 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
playback/Cargo.toml
View file

@ -20,7 +20,7 @@ portaudio-rs = { version = "0.3.0", optional = true }
libpulse-sys = { version = "0.0.0", optional = true } libpulse-sys = { version = "0.0.0", optional = true }
jack = { version = "0.5.3", optional = true } jack = { version = "0.5.3", optional = true }
libc = { version = "0.2", optional = true } libc = { version = "0.2", optional = true }
rodio = { version = "0.8.1", optional = true, default-features = false } rodio = { git = "https://github.com/tomaka/rodio", optional = true, default-features = false}
[features] [features]
alsa-backend = ["alsa"] alsa-backend = ["alsa"]

10
playback/src/audio_backend/rodio.rs
View file

@ -1,6 +1,6 @@
use super::{Open, Sink}; use super::{Open, Sink};
extern crate rodio; extern crate rodio;
use std::io; use std::{io, thread, time};
use std::process::exit; use std::process::exit;
pub struct RodioSink { pub struct RodioSink {
@ -83,6 +83,14 @@ impl Sink for RodioSink {
fn write(&mut self, data: &[i16]) -> io::Result<()> { fn write(&mut self, data: &[i16]) -> io::Result<()> {
let source = rodio::buffer::SamplesBuffer::new(2, 44100, data); let source = rodio::buffer::SamplesBuffer::new(2, 44100, data);
self.rodio_sink.append(source); self.rodio_sink.append(source);
// Chunk sizes seem to be about 256 to 3000 ish items long.
// Assuming they're on average 1628 then a half second buffer is:
// 44100 elements --> about 27 chunks
while self.rodio_sink.len() > 26 {
// sleep and wait for rodio to drain a bit
thread::sleep(time::Duration::from_millis(10));
}
Ok(()) Ok(())
} }
} }