further improve latency

teamclouday · May 9, 2022 · 3e9210d · 3e9210d
1 parent c5c25de
commit 3e9210d
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 6 deletions.
diff --git a/Android/app/src/main/AndroidManifest.xml b/Android/app/src/main/AndroidManifest.xml
@@ -16,8 +16,7 @@
         android:theme="@style/Theme.Microphone"
         android:name=".DefaultApp">
         <activity
-            android:name=".MainActivity"
-            android:exported="true">
+            android:name=".MainActivity">
             <intent-filter>
                 <action android:name="android.intent.action.MAIN" />
                 <action android:name="android.intent.action.VIEW" />

diff --git a/Android/app/src/main/java/com/example/microphone/audio/AudioBuffer.kt b/Android/app/src/main/java/com/example/microphone/audio/AudioBuffer.kt
@@ -6,7 +6,7 @@ import kotlinx.coroutines.sync.withLock
 class AudioBuffer
 {
     // set buffer size for latency
-    private val BUFFER_SIZE = 5
+    private val BUFFER_SIZE = 2
     // actual buffer of byte arrays (FIFO with queue)
     private val buffer = ArrayDeque<ByteArray>()
     // mutex for coroutines

diff --git a/Android/app/src/main/java/com/example/microphone/service/ForegroundService.kt b/Android/app/src/main/java/com/example/microphone/service/ForegroundService.kt
@@ -177,6 +177,7 @@ class ForegroundService : Service() {
                 while(!states.streamShouldStop.get() && !states.isIPInfoSet.get())
                     delay(WAIT_PERIOD)
             }
+            sharedBuffer.reset()
             showMessage("Starting streaming")
             if(managerStream?.start() == true && managerStream?.isConnected() == true)
             {

diff --git a/Android/app/src/main/java/com/example/microphone/streaming/BluetoothStreamer.kt b/Android/app/src/main/java/com/example/microphone/streaming/BluetoothStreamer.kt
@@ -97,7 +97,7 @@ class BluetoothStreamer(private val ctx : Context) : Streamer {
         try {
             val streamOut = socket!!.outputStream
             streamOut.write(data)
-            streamOut.flush()
+            // streamOut.flush()
         } catch (e : IOException)
         {
             Log.d(TAG, "stream: ${e.message}")

diff --git a/Android/app/src/main/java/com/example/microphone/streaming/WifiStreamer.kt b/Android/app/src/main/java/com/example/microphone/streaming/WifiStreamer.kt
@@ -72,7 +72,7 @@ class WifiStreamer(private val ctx : Context) : Streamer {
         try {
             val streamOut = socket!!.outputStream
             streamOut.write(data)
-            streamOut.flush()
+            // streamOut.flush()
         } catch (e : IOException)
         {
             Log.d(TAG, "${e.message}")

diff --git a/Windows/AndroidMic/Library/Audio/AudioBuffer.cs b/Windows/AndroidMic/Library/Audio/AudioBuffer.cs
@@ -4,7 +4,7 @@ namespace AndroidMic.Audio
 {
     public class AudioBuffer
     {
-        public const int MAX_BUFFER_SIZE = 5;
+        public const int MAX_BUFFER_SIZE = 2;
         private readonly Queue<byte[]> buffer = new Queue<byte[]>();
         private readonly object toLock = new object();