Alsa improvements

src/Beep/Platforms/Linux/AlsaInterop/Alsa.cs

@@ -6,6 +6,9 @@ internal static partial class Alsa
 {
     private const string AlsaLibrary = "libasound";
 
+    internal const int EAGAIN = 11;
+    internal const int EPIPE = 32;
+
     [LibraryImport(AlsaLibrary)]
     internal static partial int snd_pcm_open(ref IntPtr pcm, [MarshalAs(UnmanagedType.LPStr)]  string name, PcmStream stream, int mode);
 
@@ -21,6 +24,9 @@ internal static partial class Alsa
     [LibraryImport(AlsaLibrary)]
     internal static partial int snd_pcm_prepare(IntPtr pcm);
 
+    [LibraryImport(AlsaLibrary)]
+    internal static partial int snd_pcm_wait(IntPtr pcm, int timeout);
+
     [LibraryImport(AlsaLibrary)]
     internal static partial int snd_pcm_close(IntPtr pcm);
 

src/Beep/Platforms/Linux/AlsaPlayer.cs

@@ -167,12 +167,35 @@ private void RunWorker()
                     break;
                 }
 
-                var result = snd_pcm_writei(_pcm, _audioData, (ulong)(audioDataLength / _channelCount));
+                var framesToWrite = audioDataLength / _channelCount;
+                var frameOffset = 0;
 
-                if (result == -32)
+                unsafe
                 {
-                    result = snd_pcm_recover(_pcm, result, 0);
-                    ThrowIfError(result, "Unable to recover from buffer underrun");
+                    fixed (float* audioDataPtr = _audioData)
+                    {
+                        while (framesToWrite > 0)
+                        {
+                            var bufferOffset = audioDataPtr + frameOffset * _channelCount;
+                            var writtenCount = snd_pcm_writei(_pcm, new IntPtr(bufferOffset), (ulong)framesToWrite);
+
+                            switch (writtenCount)
+                            {
+                                case -EPIPE:
+                                    _ = snd_pcm_prepare(_pcm);
+                                    continue;
+
+                                case -EAGAIN:
+                                    _ = snd_pcm_wait(_pcm, 10);
+                                    continue;
+
+                                default:
+                                    frameOffset += writtenCount;
+                                    framesToWrite -= writtenCount;
+                                    break;
+                            }
+                        }
+                    }
                 }
             }
         }