diff options
| author | Jonatan Rhodin <jonatan.rhodin@mullvad.net> | 2023-11-21 14:33:32 +0100 |
|---|---|---|
| committer | Jonatan Rhodin <jonatan.rhodin@mullvad.net> | 2023-11-22 14:55:05 +0100 |
| commit | c1c2cba7f6b916c94f8304e3d82f343f64ce25c0 (patch) | |
| tree | f9540ca0613718cb8bf1dacaf937b1f08720f8fe /android/lib/ipc/src | |
| parent | 5d67b95e68b1df320a10d3733a57b82661d08c97 (diff) | |
| download | mullvadvpn-c1c2cba7f6b916c94f8304e3d82f343f64ce25c0.tar.xz mullvadvpn-c1c2cba7f6b916c94f8304e3d82f343f64ce25c0.zip | |
Fix account history events being lost because of buffer overflow
Diffstat (limited to 'android/lib/ipc/src')
| -rw-r--r-- | android/lib/ipc/src/main/kotlin/net/mullvad/mullvadvpn/lib/ipc/DispatchingHandler.kt | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/android/lib/ipc/src/main/kotlin/net/mullvad/mullvadvpn/lib/ipc/DispatchingHandler.kt b/android/lib/ipc/src/main/kotlin/net/mullvad/mullvadvpn/lib/ipc/DispatchingHandler.kt index dd73f3c156..efaa1b78f8 100644 --- a/android/lib/ipc/src/main/kotlin/net/mullvad/mullvadvpn/lib/ipc/DispatchingHandler.kt +++ b/android/lib/ipc/src/main/kotlin/net/mullvad/mullvadvpn/lib/ipc/DispatchingHandler.kt @@ -15,7 +15,8 @@ class DispatchingHandler<T : Any>(looper: Looper, private val extractor: (Messag private val handlers = HashMap<KClass<out T>, (T) -> Unit>() private val lock = ReentrantReadWriteLock() - private val _parsedMessages = MutableSharedFlow<T>(extraBufferCapacity = 1) + private val _parsedMessages = + MutableSharedFlow<T>(extraBufferCapacity = MESSAGES_BUFFER_CAPACITY) val parsedMessages = _parsedMessages.asSharedFlow() @Deprecated("Use parsedMessages instead.") @@ -45,4 +46,8 @@ class DispatchingHandler<T : Any>(looper: Looper, private val extractor: (Messag removeCallbacksAndMessages(null) } + + companion object { + private const val MESSAGES_BUFFER_CAPACITY = 10 + } } |