Android: влияние сотовой сети на размер буфера чтения сокетов Wi-Fi соединений

Я исследую проблему, при которой передача данных по Wi-Fi между моим приложением для Android и GoPro несовместима в различных условиях мобильной сети. Сначала я заметил, что GoPro Quik (официальное приложение GoPro) мог эффективно передавать данные даже в сетях 2G, в то время как моё приложение не могло. После некоторого изучения их исходного кода я понял, что Quik переопределяет read_buffer_size в OkHttp. Как только я внес такую же корректировку в своём приложении, оно стало хорошо передавать данные в 2G, что улучшило производительность в этих случаях. Однако это решение не было идеальным. Иногда передача данных замедлялась даже на 4G, и я заметил, что GoPro Quik также испытывал медленные скорости передачи в этих случаях. Интересно, что скорости значительно увеличивались, как только мобильное соединение отключалось, что может указывать на то, что между мобильной и Wi-Fi сетями существует взаимодействие, которое влияет на производительность. Я ищу способы логирования размеров буферов, чтобы продолжить исследование, и рассматриваю, как Android или основной ядро Linux могут влиять на эти поведения.

Буду признателен за любые предложения или теории о том, как именно качество мобильной сети может оказать влияние.

Вот мой код для создания клиента OkHttp с пользовательской фабрикой сокетов, которая переопределяет read_buffer_size:

class CustomBufferSocketFactory(
    private val sendBufferSizeBytes: Int,
    private val receiveBufferSizeBytes: Int,
    private val tcpNoDelayEnabled: Boolean = false,
    private val socketFactory: SocketFactory = SocketFactory.getDefault()
) : SocketFactory() {

    override fun createSocket(): Socket {
        return configureSocket(socketFactory.createSocket())
    }

    override fun createSocket(host: String, port: Int): Socket {
        return configureSocket(socketFactory.createSocket(host, port))
    }

    override fun createSocket(host: String, port: Int, localHost: InetAddress, localPort: Int): Socket {
        return configureSocket(socketFactory.createSocket(host, port, localHost, localPort))
    }

    override fun createSocket(address: InetAddress, port: Int): Socket {
        return configureSocket(socketFactory.createSocket(address, port))
    }

    override fun createSocket(address: InetAddress, port: Int, localAddress: InetAddress, localPort: Int): Socket {
        return configureSocket(socketFactory.createSocket(address, port, localAddress, localPort))
    }

    private fun configureSocket(socket: Socket): Socket {
        socket.sendBufferSize = sendBufferSizeBytes
        socket.receiveBufferSize = receiveBufferSizeBytes
        socket.tcpNoDelay = tcpNoDelayEnabled
        return socket
    }
}

suspend fun connectToLocalNetwork(
    context: Context,
    ssid: String,
    password: String
): OkHttpClient? {
    return withTimeoutOrNull(15000L) { // Таймаут через 15 секунд
        suspendCancellableCoroutine { continuation ->
            var isResumed = false

            val connectivityManager = context.getSystemService(Context.CONNECTIVITY_SERVICE) as ConnectivityManager

            // Используйте WifiNetworkSpecifier для создания запроса на желаемую Wi-Fi сеть
            val wifiSpecifier = WifiNetworkSpecifier.Builder()
                .setSsid(ssid)
                .setWpa2Passphrase(password)
                .build()

            // Создание запроса на сеть
            val networkRequest = NetworkRequest.Builder()
                .addTransportType(NetworkCapabilities.TRANSPORT_WIFI)
                .removeTransportType(NetworkCapabilities.TRANSPORT_CELLULAR)
                .removeCapability(NetworkCapabilities.NET_CAPABILITY_INTERNET)
                .removeCapability(NetworkCapabilities.NET_CAPABILITY_TRUSTED)
                .removeCapability(NetworkCapabilities.NET_CAPABILITY_VALIDATED)
                .setNetworkSpecifier(wifiSpecifier)
                .build()

            // Определите обратный вызов сети
            val networkCallback = object : ConnectivityManager.NetworkCallback() {
                override fun onAvailable(network: Network) {
                    if (!isResumed && !continuation.isCancelled) {
                        isResumed = true

                        // Привязка сетевого трафика вашего приложения к конкретной сети
                        connectivityManager.bindProcessToNetwork(network)

                        Logger.getLogger(OkHttpClient::class.java.name).setLevel(Level.FINE)

                        // Используйте OkHttpClientFactory для загрузки больших файлов
                        val client =
                            OkHttpClient.Builder()
                                .connectTimeout(60, TimeUnit.SECONDS)
                                .readTimeout(60, TimeUnit.SECONDS)
                                .writeTimeout(60, TimeUnit.SECONDS)
                                .socketFactory(CustomBufferSocketFactory(
                                    524288, 524288, true, network.socketFactory))
                                .build()

                        continuation.resume(client)
                    }
                }

                override fun onUnavailable() {
                    if (!isResumed && !continuation.isCancelled) {
                        isResumed = true
                        continuation.resume(null)
                    }
                }

                override fun onLost(network: Network) {
                    if (!isResumed && !continuation.isCancelled) {
                        isResumed = true
                        continuation.resume(null)
                    }
                }
            }

            connectivityManager.requestNetwork(networkRequest, networkCallback)
        }
    }
}