-
Notifications
You must be signed in to change notification settings - Fork 6
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Use cross-plat IWavePlayer to eliminate loading times for sound playe…
…rs (#34)
- Loading branch information
Showing
27 changed files
with
938 additions
and
107 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,286 @@ | ||
| using NAudio.Wave; | ||
| using OpenTK.Audio.OpenAL; | ||
| using System; | ||
| using System.Threading.Tasks; | ||
|
|
||
| namespace SerialLoops.Gtk | ||
| { | ||
| // Adapted from https://gist.github.com/VisualMelon/d02edcd7c44fadcd6f5745e92c449a90 | ||
| public class ALAudioContext : IDisposable | ||
| { | ||
| public ALDevice Device { get; private set; } | ||
| public ALContext Context { get; private set; } | ||
|
|
||
| public ALAudioContext() | ||
| { | ||
| Init(); | ||
| } | ||
|
|
||
| private unsafe void Init() | ||
| { | ||
| Device = ALC.OpenDevice(null); | ||
| Context = ALC.CreateContext(Device, (int*)null); | ||
| ALC.MakeContextCurrent(Context); | ||
| } | ||
|
|
||
| ~ALAudioContext() | ||
| { | ||
| Dispose(false); | ||
| } | ||
|
|
||
| public void Dispose() | ||
| { | ||
| Dispose(true); | ||
| GC.SuppressFinalize(this); | ||
| } | ||
|
|
||
| protected void Dispose(bool disposing) | ||
| { | ||
| if (Context != ALContext.Null) | ||
| { | ||
| ALC.MakeContextCurrent(ALContext.Null); | ||
| ALC.DestroyContext(Context); | ||
| } | ||
| Context = ALContext.Null; | ||
|
|
||
| if (Device != IntPtr.Zero) | ||
| { | ||
| ALC.CloseDevice(Device); | ||
| } | ||
| Device = ALDevice.Null; | ||
| } | ||
| } | ||
|
|
||
| public class ALWavePlayer : IWavePlayer, IDisposable | ||
| { | ||
| private float _volume; | ||
| public float Volume | ||
| { | ||
| get => _volume; | ||
| set | ||
| { | ||
| _volume = value; | ||
| } | ||
| } | ||
|
|
||
| public PlaybackState PlaybackState { get; private set; } | ||
|
|
||
| public event EventHandler<StoppedEventArgs> PlaybackStopped; | ||
|
|
||
| private ALAudioContext Context { get; } | ||
| public int BufferSize { get; } | ||
|
|
||
| private IWaveProvider WaveProvider; | ||
|
|
||
| private int _source; | ||
| private int _nextBuffer; | ||
| private int _otherBuffer; | ||
|
|
||
| private byte[] _buffer; | ||
| private Accumulator _accumulator; | ||
|
|
||
| private System.Threading.ManualResetEventSlim _signaller; | ||
|
|
||
| private System.Threading.CancellationTokenSource _playerCanceller; | ||
| private Task Player; | ||
|
|
||
| public WaveFormat OutputWaveFormat => WaveProvider.WaveFormat; | ||
|
|
||
| public ALWavePlayer(ALAudioContext context, int bufferSize) | ||
| { | ||
| Context = context; | ||
| BufferSize = bufferSize; | ||
| } | ||
|
|
||
| public unsafe void Init(IWaveProvider waveProvider) | ||
| { | ||
| WaveProvider = waveProvider; | ||
|
|
||
| AL.GenSources(1, ref _source); | ||
| AL.GenBuffers(1, ref _nextBuffer); | ||
| AL.GenBuffers(1, ref _otherBuffer); | ||
|
|
||
| _buffer = new byte[BufferSize]; | ||
| _accumulator = new Accumulator(waveProvider, _buffer); | ||
|
|
||
| _signaller = new System.Threading.ManualResetEventSlim(false); | ||
| PlaybackState = PlaybackState.Paused; | ||
| } | ||
|
|
||
| public void Pause() | ||
| { | ||
| if (PlaybackState == PlaybackState.Stopped) | ||
| throw new InvalidOperationException("Stopped"); | ||
|
|
||
| PlaybackState = PlaybackState.Paused; | ||
| _playerCanceller?.Cancel(); | ||
| _playerCanceller = null; | ||
| AL.SourcePause(_source); | ||
| } | ||
|
|
||
| public void Play() | ||
| { | ||
| if (PlaybackState == PlaybackState.Stopped) | ||
| throw new InvalidOperationException("Stopped"); | ||
|
|
||
| PlaybackState = PlaybackState.Playing; | ||
| if (_playerCanceller == null) | ||
| { | ||
| _playerCanceller = new System.Threading.CancellationTokenSource(); | ||
| Player = PlayLoop(_playerCanceller.Token).ContinueWith(PlayerStopped); | ||
| } | ||
| } | ||
|
|
||
| private void PlayerStopped(Task t) | ||
| { | ||
| PlaybackStopped?.Invoke(this, new StoppedEventArgs(t?.Exception)); | ||
| } | ||
|
|
||
| public void Stop() | ||
| { | ||
| if (PlaybackState == PlaybackState.Stopped) | ||
| { | ||
| throw new InvalidOperationException("Already stopped"); | ||
| } | ||
|
|
||
| PlaybackState = PlaybackState.Stopped; | ||
| if (_playerCanceller != null) | ||
| { | ||
| _playerCanceller?.Cancel(); | ||
| _playerCanceller = null; | ||
| AL.SourceStop(_source); | ||
| } | ||
| else | ||
| { | ||
| PlaybackStopped?.Invoke(this, new StoppedEventArgs()); | ||
| } | ||
| } | ||
|
|
||
| private async Task PlayLoop(System.Threading.CancellationToken ct) | ||
| { | ||
| AL.SourcePlay(_source); | ||
| await Task.Yield(); | ||
|
|
||
| while (true) | ||
| { | ||
| AL.GetSource(_source, ALGetSourcei.BuffersQueued, out int queued); | ||
| AL.GetSource(_source, ALGetSourcei.BuffersProcessed, out int processed); | ||
| AL.GetSource(_source, ALGetSourcei.SourceState, out int state); | ||
|
|
||
| if ((ALSourceState)state != ALSourceState.Playing) | ||
| { | ||
| AL.SourcePlay(_source); | ||
| } | ||
|
|
||
| if (processed == 0 && queued == 2) | ||
| { | ||
| await Task.Delay(1); | ||
| continue; | ||
| } | ||
|
|
||
| if (processed > 0) | ||
| { | ||
| AL.SourceUnqueueBuffers(_source, processed); | ||
| } | ||
|
|
||
| var notFinished = await _accumulator.Accumulate(_buffer, ct); | ||
|
|
||
| if (!notFinished) | ||
| { | ||
| return; | ||
| } | ||
|
|
||
| AL.BufferData(_nextBuffer, TranslateFormat(WaveProvider.WaveFormat), _buffer, WaveProvider.WaveFormat.SampleRate); | ||
| AL.SourceQueueBuffer(_source, _nextBuffer); | ||
| await Task.Delay(10, ct); | ||
|
|
||
| (_nextBuffer, _otherBuffer) = (_otherBuffer, _nextBuffer); | ||
| } | ||
| } | ||
|
|
||
| ~ALWavePlayer() | ||
| { | ||
| Dispose(false); | ||
| } | ||
|
|
||
| public void Dispose() | ||
| { | ||
| Dispose(true); | ||
| GC.SuppressFinalize(this); | ||
| } | ||
|
|
||
| protected void Dispose(bool disposing) | ||
| { | ||
| AL.DeleteSource(_source); | ||
| AL.DeleteBuffer(_nextBuffer); | ||
| AL.DeleteBuffer(_otherBuffer); | ||
| } | ||
|
|
||
| public static ALFormat TranslateFormat(WaveFormat format) | ||
| { | ||
| if (format.Channels == 2) | ||
| { | ||
| if (format.BitsPerSample == 32) | ||
| { | ||
| return ALFormat.StereoFloat32Ext; | ||
| } | ||
| else if (format.BitsPerSample == 16) | ||
| { | ||
| return ALFormat.Stereo16; | ||
| } | ||
| else if (format.BitsPerSample == 8) | ||
| { | ||
| return ALFormat.Stereo8; | ||
| } | ||
| } | ||
| else if (format.Channels == 1) | ||
| { | ||
| if (format.BitsPerSample == 32) | ||
| { | ||
| return ALFormat.MonoFloat32Ext; | ||
| } | ||
| else if (format.BitsPerSample == 16) | ||
| { | ||
| return ALFormat.Mono16; | ||
| } | ||
| else if (format.BitsPerSample == 8) | ||
| { | ||
| return ALFormat.Mono8; | ||
| } | ||
| } | ||
|
|
||
| throw new FormatException("Cannot translate WaveFormat."); | ||
| } | ||
| } | ||
|
|
||
| public class Accumulator | ||
| { | ||
| public Accumulator(IWaveProvider provider, byte[] buffer) | ||
| { | ||
| Provider = provider ?? throw new ArgumentNullException(nameof(provider)); | ||
| } | ||
|
|
||
| public IWaveProvider Provider { get; } | ||
| //private object Locker = new(); | ||
|
|
||
| public async Task<bool> Accumulate(byte[] buffer, System.Threading.CancellationToken ct) | ||
| { | ||
| await Task.Yield(); | ||
|
|
||
| int position = 0; | ||
| while (position < buffer.Length) | ||
| { | ||
| if (ct.IsCancellationRequested) | ||
| throw new TaskCanceledException(); | ||
| var read = Provider.Read(buffer, position, buffer.Length - position); | ||
|
|
||
| if (read == 0) | ||
| return false; | ||
|
|
||
| position += read; | ||
| } | ||
|
|
||
| return true; | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.