Changelog 1.6 version

1.6.3

released 26th August 2021

Client

Auth Feature: token refresh works only on main thread in Kotlin/Native

https://youtrack.jetbrains.com/issue/KTOR-3055

Ktor version:

Ktor client 1.6.2, default iOS engine

Description:

Auth feature uses global constants during token refresh process which are not marked with @ThreadLocal annotation. This makes it impossible to perform refresh from non-main thread in Kotlin/Native targets.

Stacktrace:

Caused by: kotlin.native.IncorrectDereferenceException: Trying to access top level value not marked as @ThreadLocal or @SharedImmutable from non-main thread
    at 0   shared                              0x000000010774e04f kfun:kotlin.Throwable#<init>(kotlin.String?){} + 95 (/Users/teamcity2/buildAgent/work/7c4fade2802b7783/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/Throwable.kt:23:37)
    at 1   shared                              0x000000010774697d kfun:kotlin.Exception#<init>(kotlin.String?){} + 93 (/Users/teamcity2/buildAgent/work/7c4fade2802b7783/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/Exceptions.kt:23:44)
    at 2   shared                              0x0000000107746bed kfun:kotlin.RuntimeException#<init>(kotlin.String?){} + 93 (/Users/teamcity2/buildAgent/work/7c4fade2802b7783/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/Exceptions.kt:34:44)
    at 3   shared                              0x000000010777bd3d kfun:kotlin.native.IncorrectDereferenceException#<init>(kotlin.String){} + 93 (/Users/teamcity2/buildAgent/work/7c4fade2802b7783/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/native/Runtime.kt:30:36)
    at 4   shared                              0x000000010779fd43 ThrowIncorrectDereferenceException + 131 (/Users/teamcity2/buildAgent/work/7c4fade2802b7783/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/native/internal/RuntimeUtils.kt:104:11)
    at 5   shared                              0x0000000107938b5e CheckGlobalsAccessible + 30
    at 6   shared                              0x0000000107cea6a5 kfun:io.ktor.http.auth.<get-TOKEN68_EXTRA>#internal + 21 (/Users/evgenygusev/ktor/ktor-http/common/src/io/ktor/http/auth/HttpAuthHeader.kt:16:9)
    at 7   shared                              0x0000000107cf0169 kfun:io.ktor.http.auth.isToken68#internal + 281 (/Users/evgenygusev/ktor/ktor-http/common/src/io/ktor/http/auth/HttpAuthHeader.kt:372:106)
    at 8   shared                              0x0000000107cebba1 kfun:io.ktor.http.auth.matchToken68#internal + 353 (/Users/evgenygusev/ktor/ktor-http/common/src/io/ktor/http/auth/HttpAuthHeader.kt:128:61)
    at 9   shared                              0x0000000107ceaaca kfun:io.ktor.http.auth#parseAuthorizationHeader(kotlin.String){}io.ktor.http.auth.HttpAuthHeader? + 874 (/Users/evgenygusev/ktor/ktor-http/common/src/io/ktor/http/auth/HttpAuthHeader.kt:51:19)
    at 10  shared                              0x0000000107d78161 kfun:io.ktor.client.features.auth.Auth.Feature.$install$lambda-1COROUTINE$1.invokeSuspend#internal + 3425 (/Users/evgenygusev/ktor/ktor-client/ktor-client-features/ktor-client-auth/common/src/io/ktor/client/features/auth/Auth.kt:51:38)

Bearer Token is Not Initialized after Clean

InvalidMutabilityException when using withContext and SavedHttpCall

https://youtrack.jetbrains.com/issue/KTOR-2033

Calling HttpResponse.readText is throwing this exception. I'm using Dispatchers.Main only. I'm not explicitly trying to save any HTTP calls, just making one-time calls.

I've tried both Ktor 1.5.1 and 1.5.0 Coroutines 1.4.2-native-mt Kotlin 1.4.20

Caused by: kotlin.native.concurrent.InvalidMutabilityException: mutation attempt of frozen io.ktor.client.call.SavedHttpCall@3f8be38
    at 0   jgosdk                              0x00000001109e102f kfun:kotlin.Throwable#<init>(kotlin.String?){} + 95 (/Users/teamcity1/teamcity_work/f01984a9f5203417/runtime/src/main/kotlin/kotlin/Throwable.kt:23:37)
    at 1   jgosdk                              0x00000001109d982d kfun:kotlin.Exception#<init>(kotlin.String?){} + 93 (/Users/teamcity1/teamcity_work/f01984a9f5203417/runtime/src/main/kotlin/kotlin/Exceptions.kt:23:44)
    at 2   jgosdk                              0x00000001109d9a9d kfun:kotlin.RuntimeException#<init>(kotlin.String?){} + 93 (/Users/teamcity1/teamcity_work/f01984a9f5203417/runtime/src/main/kotlin/kotlin/Exceptions.kt:34:44)
    at 3   jgosdk                              0x0000000110a1276d kfun:kotlin.native.concurrent.InvalidMutabilityException#<init>(kotlin.String){} + 93 (/Users/teamcity1/teamcity_work/f01984a9f5203417/runtime/src/main/kotlin/kotlin/native/concurrent/Freezing.kt:22:60)
    at 4   jgosdk                              0x0000000110a13f4f ThrowInvalidMutabilityException + 431 (/Users/teamcity1/teamcity_work/f01984a9f5203417/runtime/src/main/kotlin/kotlin/native/concurrent/Internal.kt:92:11)
    at 5   jgosdk                              0x0000000110b18e00 MutationCheck + 128
    at 6   jgosdk                              0x0000000110da9e38 kfun:io.ktor.client.call.SavedHttpCall.<set-responseContent>#internal + 104 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-client/ktor-client-core/common/src/io/ktor/client/call/SavedCall.kt:23:13)
    at 7   jgosdk                              0x0000000110daa4e4 kfun:io.ktor.client.call.SavedHttpCall.$getResponseContentCOROUTINE$7#invokeSuspend(kotlin.Result<kotlin.Any?>){}kotlin.Any? + 1412 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-client/ktor-client-core/common/src/io/ktor/client/call/SavedCall.kt:30:13)
    at 8   jgosdk                              0x0000000110daa676 kfun:io.ktor.client.call.SavedHttpCall#getResponseContent(){}io.ktor.utils.io.ByteReadChannel + 246 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-client/ktor-client-core/common/src/io/ktor/client/call/SavedCall.kt:28:22)
    at 9   jgosdk                              0x0000000110da78eb kfun:io.ktor.client.call.HttpClientCall.$receiveCOROUTINE$5#invokeSuspend(kotlin.Result<kotlin.Any?>){}kotlin.Any? + 2379 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-client/ktor-client-core/common/src/io/ktor/client/call/HttpClientCall.kt:82:72)
    at 10  jgosdk                              0x0000000110da85c2 kfun:io.ktor.client.call.HttpClientCall#receive(io.ktor.client.call.TypeInfo){}kotlin.Any + 322 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-client/ktor-client-core/common/src/io/ktor/client/call/HttpClientCall.kt:75:20)
    at 11  jgosdk                              0x0000000110dec056 kfun:io.ktor.client.statement.$readTextCOROUTINE$97#invokeSuspend(kotlin.Result<kotlin.Any?>){}kotlin.Any? + 1942 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-client/ktor-client-core/common/src/io/ktor/client/statement/HttpStatement.kt:170:45)
    at 12  jgosdk                              0x0000000110dec4c2 kfun:io.ktor.client.statement#readText@io.ktor.client.statement.HttpResponse(io.ktor.utils.io.charsets.Charset?){}kotlin.String + 322 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-client/ktor-client-core/common/src/io/ktor/client/statement/HttpStatement.kt:168:16)
    at 13  jgosdk                              0x0000000110dec67f kfun:io.ktor.client.statement#readText$default@io.ktor.client.statement.HttpResponse(io.ktor.utils.io.charsets.Charset?;kotlin.Int){}kotlin.String + 303 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-client/ktor-client-core/common/src/io/ktor/client/statement/HttpStatement.kt:168:16)

Core

Server: TLSConfigBuilder.addKeyStore: store.getCertificateChain could return null

Docs

Deploy WAR on Tomcat

Generator

FUS report mixes up feature id and feature version

Marketing

Add prominent warning on Ktor EAP page about artifacts not being permanently available

Plugin

Reuse Package Search to add dependencies for Ktor Features in Plugin

The wizard missing the Pebble plugin

Wizard: Creating a project without sample code creates `Application.configureRouting` without `routing`

The 'Create Run Configuration automatically' option name is cropped

Server

SessionTrackerById - doesn't remove invalid session id

ktor does not support semicolon query parameter in Netty Engine

HOCON config not resolved in ServletApplicationEngine

Other

Release 1.6.3

1.6.2

released 29th July 2021

Client

kotlin.native.concurrent.InvalidMutabilityException: mutation attempt of frozen <object>@72c18

https://youtrack.jetbrains.com/issue/KTOR-2883

I am trying to upload an image as multiform data using KMM

For android, it's working fine, and able to upload it. But in iOS, I can upload only text data not byteArray.

This is how I created HTTP client

expect fun httpClient(config: HttpClientConfig<*>.() -> Unit = {}): HttpClient

actual fun httpClient(config: HttpClientConfig<*>.() -> Unit) = HttpClient(Ios) {
    config(this)
    engine {
        configureRequest {
            setAllowsCellularAccess(true)
       }
    }
}


@ThreadLocal
val jsonSerializer = kotlinx.serialization.json.Json {
    ignoreUnknownKeys = true
    prettyPrint = true
    isLenient = true
    useAlternativeNames = false
}

internal class KtorClient {
private val nativeClient = httpClient {
       install(Logging) {
           level = LogLevel.HEADERS
           logger = kTorLogger
       }
       install(JsonFeature) {
           serializer = KotlinxSerializer(json = jsonSerializer)
       }
       install(HttpTimeout) {
           requestTimeoutMillis = 15000L
           connectTimeoutMillis = 15000L
           socketTimeoutMillis = 15000L
       }
       install(Auth) {
           bearer {
               loadTokens { BearerTokens(accessToken = "", refreshToken = "") }
               refreshTokens { response: HttpResponse ->
                   BearerTokens(accessToken = "", refreshToken = "")
               }
           }
       }
   }.also {
       initLogger()
   }
   fun getNativeClient(): HttpClient {
        return nativeClient
    }
}


class ApiImpl constructor(private val httpClient: HttpClient = KtorClient().getNativeClient()) :
    Api {
    override suspend fun testFileUpload(
            data: NewTicket, fileData: FileData
        ): HttpResponse {
            val jsonData = Json.encodeToString(data)
            val formPartTicket = FormPart(
                key = "data",
                value = jsonData,
                headers = Headers.build {
                    append(
                        HttpHeaders.ContentType,
                        "multipart/form-data;"
                    )//"application/json;charset=utf-8"
                    append(HttpHeaders.ContentDisposition, "form-data;name=data")
                })

            val formPartAttachment = FormPart(key = "attachments",
                value = fileData.data,
                headers = Headers.build {
                    append(HttpHeaders.ContentType, "image/png")
                    append(
                        HttpHeaders.ContentDisposition,
                        "filename=${fileData.fileName}"
                    )
                })

            val response: HttpResponse = httpClient.submitFormWithBinaryData(
                url = KtorClient.baseUrl + createTicket,
                formData = formData {
                    append(formPartTicket)
                    //after adding byteArray, this gets crashed. Without below apped, all works fine
                    append(formPartAttachment)
                }
            )
            return response
        }
    }
@Serializable
data class FileData(val fileName: String?, val data: ByteArray?)

On iOS side, for testing purpose I am converting local image to byteArray

let newTicket = NewTicket(customerId: "12345",subject: subject, description: description, cfTag: cfTag, subTag: subTag)
let url = Bundle.main.url(forResource: "image", withExtension: "png")
let iosPlat =  IOSPlat()
//get byteArray from data
let bytesA = try! iosPlat.toByteArray(nsData: Data.init(contentsOf: url!))
let fileData = FileData("image.png",bytesA)

//Make api call like 
api.testFileUpload(newTicket,fileData) {(response,erro) in 
  print(response)
}

@ThreadLocal
object IOSPlat {

    var autoFileData = AtomicReference(FileData(null,null).freeze())

    fun isFreezed() {
        Napier.d("isFreezed ${autoFileData.value.isFrozen}")
    }
    fun setNewFileData(fileName: String?, data: ByteArray?) {
        val fileData = FileData(fileName, data.freeze()).freeze()
        autoFileData.value = fileData
    }

    fun getFileData(): FileData {
        return autoFileData.value
    }
    fun toByteArray(nsData: NSData): ByteArray {
        val data: CPointer<ByteVar> = nsData.bytes!!.reinterpret()
        val arr = ByteArray(nsData.length.toInt()) { index -> data[index] }
        return arr
    }
}

Exception -> I haven't added throw to a function to get iOS crash

Exception doesn't match @Throws-specified class list and thus isn't propagated from Kotlin to Objective-C/Swift as NSError.
It is considered unexpected and unhandled instead. Program will be terminated.
Uncaught Kotlin exception: kotlin.native.concurrent.InvalidMutabilityException: mutation attempt of frozen <object>@72c18
    at 0   sharedfaq                           0x000000010d40076f kfun:kotlin.Throwable#<init>(kotlin.String?){} + 95 (/Users/teamcity3/buildAgent/work/290aee0e088a1666/runtime/src/main/kotlin/kotlin/Throwable.kt:23:37)
    at 1   sharedfaq                           0x000000010d3f8f9d kfun:kotlin.Exception#<init>(kotlin.String?){} + 93 (/Users/teamcity3/buildAgent/work/290aee0e088a1666/runtime/src/main/kotlin/kotlin/Exceptions.kt:23:44)
    at 2   sharedfaq                           0x000000010d3f920d kfun:kotlin.RuntimeException#<init>(kotlin.String?){} + 93 (/Users/teamcity3/buildAgent/work/290aee0e088a1666/runtime/src/main/kotlin/kotlin/Exceptions.kt:34:44)
    at 3   sharedfaq                           0x000000010d430d8d kfun:kotlin.native.concurrent.InvalidMutabilityException#<init>(kotlin.String){} + 93 (/Users/teamcity3/buildAgent/work/290aee0e088a1666/runtime/src/main/kotlin/kotlin/native/concurrent/Freezing.kt:22:60)
    at 4   sharedfaq                           0x000000010d43258f ThrowInvalidMutabilityException + 431 (/Users/teamcity3/buildAgent/work/290aee0e088a1666/runtime/src/main/kotlin/kotlin/native/concurrent/Internal.kt:93:11)
    at 5   sharedfaq                           0x000000010d59baf0 MutationCheck + 128
    at 6   sharedfaq                           0x000000010d7862b8 kfun:io.ktor.utils.io.pool.SingleInstancePool.<set-instance>#internal + 104 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-io/common/src/io/ktor/utils/io/pool/Pool.kt:59:13)
    at 7   sharedfaq                           0x000000010d786880 kfun:io.ktor.utils.io.pool.SingleInstancePool#recycle(1:0){} + 496 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-io/common/src/io/ktor/utils/io/pool/Pool.kt:94:9)
    at 8   sharedfaq                           0x000000010d774e8f kfun:io.ktor.utils.io.core.internal.ChunkBuffer#release(io.ktor.utils.io.pool.ObjectPool<io.ktor.utils.io.core.internal.ChunkBuffer>){} + 607 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-io/common/src/io/ktor/utils/io/core/internal/ChunkBuffer.kt:69:27)
    at 9   sharedfaq                           0x000000010d7303c8 kfun:io.ktor.utils.io.core.AbstractInput.ensureNext#internal + 776 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-io/common/src/io/ktor/utils/io/core/AbstractInput.kt:717:17)
    at 10  sharedfaq                           0x000000010d72eea5 kfun:io.ktor.utils.io.core.AbstractInput#ensureNext(io.ktor.utils.io.core.internal.ChunkBuffer){}io.ktor.utils.io.core.internal.ChunkBuffer? + 341 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-io/common/src/io/ktor/utils/io/core/AbstractInput.kt:637:67)
    at 11  sharedfaq                           0x000000010d72ecda kfun:io.ktor.utils.io.core.AbstractInput#ensureNextHead(io.ktor.utils.io.core.internal.ChunkBuffer){}io.ktor.utils.io.core.internal.ChunkBuffer? + 202 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-io/common/src/io/ktor/utils/io/core/AbstractInput.kt:634:69)
    at 12  sharedfaq                           0x000000010d78080a kfun:io.ktor.utils.io.core.internal#prepareReadNextHead__at__io.ktor.utils.io.core.Input(io.ktor.utils.io.core.internal.ChunkBuffer){}io.ktor.utils.io.core.internal.ChunkBuffer? + 394 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-io/common/src/io/ktor/utils/io/core/internal/Unsafe.kt:128:16)
    at 13  sharedfaq                           0x000000010d75deac kfun:io.ktor.utils.io.core#readFully__at__io.ktor.utils.io.core.Input(kotlin.ByteArray;kotlin.Int;kotlin.Int){} + 892 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-io/common/src/io/ktor/utils/io/core/InputArrays.kt:8:13)
    at 14  sharedfaq                           0x000000010d77178d kfun:io.ktor.utils.io.core#readBytes__at__io.ktor.utils.io.core.ByteReadPacket(kotlin.Int){}kotlin.ByteArray + 333 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-io/common/src/io/ktor/utils/io/core/Strings.kt:174:35)
    at 15  sharedfaq                           0x000000010d771a12 kfun:io.ktor.utils.io.core#readBytes$default__at__io.ktor.utils.io.core.ByteReadPacket(kotlin.Int;kotlin.Int){}kotlin.ByteArray + 450 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-io/common/src/io/ktor/utils/io/core/Strings.kt:171:8)
    at 16  sharedfaq                           0x000000010d9c5e13 kfun:io.ktor.client.engine.ios.$toNSDataCOROUTINE$4#invokeSuspend(kotlin.Result<kotlin.Any?>){}kotlin.Any? + 2275 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-client/ktor-client-ios/darwin/src/io/ktor/client/engine/ios/IosUtils.kt:21:31)
    at 17  sharedfaq                           0x000000010d423c10 kfun:kotlin.coroutines.native.internal.BaseContinuationImpl#resumeWith(kotlin.Result<kotlin.Any?>){} + 800 (/Users/teamcity3/buildAgent/work/290aee0e088a1666/runtime/src/main/kotlin/kotlin/coroutines/ContinuationImpl.kt:30:39)
    at 18  sharedfaq                           0x000000010d6b82d0 kfun:kotlinx.coroutines.DispatchedTask#run(){} + 2880 (/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/common/src/internal/DispatchedTask.kt:106:71)
    at 19  sharedfaq                           0x000000010d63dfb1 kfun:kotlinx.coroutines.EventLoop#processUnconfinedEvent(){}kotlin.Boolean + 561 (/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/common/src/EventLoop.common.kt:70:18)
    at 20  sharedfaq                           0x000000010d6b6de5 kfun:kotlinx.coroutines.internal#resumeCancellableWith__at__kotlin.coroutines.Continuation<0:0>(kotlin.Result<0:0>;kotlin.Function1<kotlin.Throwable,kotlin.Unit>?){0§<kotlin.Any?>} + 2245 (/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/common/src/internal/DispatchedContinuation.kt:294:2)
    at 21  sharedfaq                           0x000000010d6c4d9f kfun:kotlinx.coroutines.intrinsics#startCoroutineCancellable__at__kotlin.coroutines.SuspendFunction1<0:0,0:1>(0:0;kotlin.coroutines.Continuation<0:1>;kotlin.Function1<kotlin.Throwable,kotlin.Unit>?){0§<kotlin.Any?>;1§<kotlin.Any?>} + 671 (/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/common/src/intrinsics/Cancellable.kt:30:74)
    at 22  sharedfaq                           0x000000010d629ff4 kfun:kotlinx.coroutines#startCoroutineImpl(kotlinx.coroutines.CoroutineStart;0:1;kotlin.coroutines.Continuation<0:0>;kotlin.Function1<kotlin.Throwable,kotlin.Unit>?;kotlin.coroutines.SuspendFunction1<0:1,0:0>){0§<kotlin.Any?>;1§<kotlin.Any?>} + 628 (/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/common/src/Builders.common.kt:192:37)
    at 23  sharedfaq                           0x000000010d6dddc6 kfun:kotlinx.coroutines.startCoroutine#internal + 1222 (/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/native/src/Builders.kt:140:5)
    at 24  sharedfaq                           0x000000010d6dd8a1 kfun:kotlinx.coroutines#startAbstractCoroutine(kotlinx.coroutines.CoroutineStart;0:1;kotlinx.coroutines.AbstractCoroutine<0:0>;kotlin.coroutines.SuspendFunction1<0:1,0:0>){0§<kotlin.Any?>;1§<kotlin.Any?>} + 417 (/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/native/src/Builders.kt:111:5)
    at 25  sharedfaq                           0x000000010d624f02 kfun:kotlinx.coroutines.AbstractCoroutine#start(kotlinx.coroutines.CoroutineStart;0:0;kotlin.coroutines.SuspendFunction1<0:0,1:0>){0§<kotlin.Any?>} + 162 (/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/common/src/AbstractCoroutine.kt:130:9)
    at 26  sharedfaq                           0x000000010d628cca kfun:kotlinx.coroutines#async__at__kotlinx.coroutines.CoroutineScope(kotlin.coroutines.CoroutineContext;kotlinx.coroutines.CoroutineStart;kotlin.coroutines.SuspendFunction1<kotlinx.coroutines.CoroutineScope,0:0>){0§<kotlin.Any?>}kotlinx.coroutines.Deferred<0:0> + 666 (/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/common/src/Builders.common.kt:91:15)
    at 27  sharedfaq                           0x000000010d629079 kfun:kotlinx.coroutines#async$default__at__kotlinx.coroutines.CoroutineScope(kotlin.coroutines.CoroutineContext?;kotlinx.coroutines.CoroutineStart?;kotlin.coroutines.SuspendFunction1<kotlinx.coroutines.CoroutineScope,0:0>;kotlin.Int){0§<kotlin.Any?>}kotlinx.coroutines.Deferred<0:0> + 697 (/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/common/src/Builders.common.kt:82:8)
    at 28  sharedfaq                           0x000000010d8a4474 kfun:io.ktor.client.engine.HttpClientEngine.$executeWithinCallContextCOROUTINE$11.invokeSuspend#internal + 1732 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-client/ktor-client-core/common/src/io/ktor/client/engine/HttpClientEngine.kt:80:16)
    at 29  sharedfaq                           0x000000010d8a499f kfun:io.ktor.client.engine.HttpClientEngine.executeWithinCallContext#internal + 383 (/Users/administrator/Documents/agent/work/8d547b974a7be21f/ktor-client/ktor-client-core/common/src/io/ktor/client/engine/HttpClientEngine.kt:75:21)
CoreSimulator 732.17 - Device: iPhone 11 Pro Max (AA752351-AABC-4A64-9690-95698DE9A1F6) - Runtime: iOS 14.0 (18A372) - DeviceType: iPhone 11 Pro Max

CIO WebSockets client incorrectly sends Sec-WebSocket-Extensions header even if empty

https://youtrack.jetbrains.com/issue/KTOR-2388

I have observed that the CIO WebSockets client is sending out a Sec-WebSocket-Extensions header in the initial handshake even if no extension has been specified. This is causing issues with RFC 6455 compliant servers as (if my understanding is correct) the spec mandates that at least one extension be provided if the header exists (otherwise fail).

https://tools.ietf.org/html/rfc6455#section-9.1 https://tools.ietf.org/html/rfc2616#section-2.1 (ABNF notes)

I am not familiar enough with the Ktor code to submit a PR with a fix, but as a workaround a simple plugin can be used to strip the header from the request before sending it to the server:

import io.ktor.client.*
import io.ktor.client.features.*
import io.ktor.client.request.*
import io.ktor.http.*
import io.ktor.util.*

/**
 * Intercept outgoing HTTP requests to strip the `Sec-WebSocket-Extensions` header if it is empty.
 *
 * This feature should be installed after the `WebSockets` feature has been installed.
 */
internal class StripBlankSWSEHeader {
    private fun stripHeader(context: HttpRequestBuilder) {
        if (HttpHeaders.SecWebSocketExtensions in context.headers
                && context.headers[HttpHeaders.SecWebSocketExtensions]?.isBlank() == true) {
            context.headers.remove(HttpHeaders.SecWebSocketExtensions)
        }
    }

    class EmptyConfig

    internal companion object Feature : HttpClientFeature<EmptyConfig, StripBlankSWSEHeader> {
        override val key: AttributeKey<StripBlankSWSEHeader> = AttributeKey("StripEmptyWSExtensionHeader")

        override fun prepare(block: EmptyConfig.() -> Unit): StripBlankSWSEHeader {
            return StripBlankSWSEHeader()
        }

        override fun install(feature: StripBlankSWSEHeader, scope: HttpClient) {
            scope.requestPipeline.intercept(HttpRequestPipeline.Render) {
                feature.stripHeader(context)

                proceed()
            }
        }
    }
}

In the client configuration the StripBlankSWSEHeader feature must be registered AFTER the WebSockets feature:

install(WebSockets)
install(StripBlankSWSEHeader) // must be registered AFTER WebSockets feature

NPE in ApacheRequestProducer when "http://" is requested

Core

ByteReadChannel.readUTF8Line() indefinitely returns empty lines when `\r` is not followed by `\n`

Docs

parseUrlEncodedParameters Documentation

OAuth authentication documentation is confusing because of incomplete code example

Fix 404 errors in ktor docs

Prometeus version is missing in Ktor docs

Incorrect Structured Markup (LD+JSON) on Ktor docs

Confusing/incorrect JWT auth documentation

CookieConfiguration should default to secure configuration and require user opt-out

Docs section about testing with cookies is outdated

HTTP/2 documentation outdated

Plugin

Ktor plugin raises StackOverflowError when opening some files

Quick action on a Application.module(...) to generate tests for a given module with all the endpoints

Server

Embedded Netty Server with watch paths is crashing in API level 22 when calling stopping server

NoSuchMethodError: No virtual method getParameterCount on Android API 25 and lower

https://youtrack.jetbrains.com/issue/KTOR-2924

To reproduce run an Android application on Android API level 25 with the following code:

embeddedServer(Netty, port = 3333, watchPaths = emptyList()) {
    routing {
        get("/") {
            call.respondText { "ewq" }
        }
    }
}.start()

E/AndroidRuntime: FATAL EXCEPTION: main
    Process: com.example.ktor_android, PID: 6703
    java.lang.NoSuchMethodError: No virtual method getParameterCount()I in class Ljava/lang/reflect/Constructor; or its super classes (declaration of 'java.lang.reflect.Constructor' appears in /system/framework/core-oj.jar)
        at io.ktor.server.engine.internal.CallableUtilsKt.executeModuleFunction(CallableUtils.kt:43)
        at io.ktor.server.engine.ApplicationEngineEnvironmentReloading$launchModuleByName$1.invoke(ApplicationEngineEnvironmentReloading.kt:317)
        at io.ktor.server.engine.ApplicationEngineEnvironmentReloading$launchModuleByName$1.invoke(ApplicationEngineEnvironmentReloading.kt:316)
        at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.avoidingDoubleStartupFor(ApplicationEngineEnvironmentReloading.kt:341)
        at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.launchModuleByName(ApplicationEngineEnvironmentReloading.kt:316)
        at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.access$launchModuleByName(ApplicationEngineEnvironmentReloading.kt:30)
        at io.ktor.server.engine.ApplicationEngineEnvironmentReloading$instantiateAndConfigureApplication$1.invoke(ApplicationEngineEnvironmentReloading.kt:304)
        at io.ktor.server.engine.ApplicationEngineEnvironmentReloading$instantiateAndConfigureApplication$1.invoke(ApplicationEngineEnvironmentReloading.kt:295)
        at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.avoidingDoubleStartup(ApplicationEngineEnvironmentReloading.kt:323)
        at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.instantiateAndConfigureApplication(ApplicationEngineEnvironmentReloading.kt:295)
        at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.createApplication(ApplicationEngineEnvironmentReloading.kt:136)
        at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.start(ApplicationEngineEnvironmentReloading.kt:268)
        at io.ktor.server.netty.NettyApplicationEngine.start(NettyApplicationEngine.kt:174)
        at io.ktor.server.netty.NettyApplicationEngine.start(NettyApplicationEngine.kt:29)
        at io.ktor.server.engine.ApplicationEngine$DefaultImpls.start$default(ApplicationEngine.kt:56)
        at com.example.ktor_android.MainActivity.onCreate(MainActivity.kt:99)
        at android.app.Activity.performCreate(Activity.java:6679)
        at android.app.Instrumentation.callActivityOnCreate(Instrumentation.java:1118)
        at android.app.ActivityThread.performLaunchActivity(ActivityThread.java:2618)
        at android.app.ActivityThread.handleLaunchActivity(ActivityThread.java:2726)
        at android.app.ActivityThread.-wrap12(ActivityThread.java)
        at android.app.ActivityThread$H.handleMessage(ActivityThread.java:1477)
        at android.os.Handler.dispatchMessage(Handler.java:102)
        at android.os.Looper.loop(Looper.java:154)
        at android.app.ActivityThread.main(ActivityThread.java:6119)
        at java.lang.reflect.Method.invoke(Native Method)
        at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:886)
        at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:776)

The code above works as expected with Ktor 1.6.0.

X-Forwarded-Port Parse Exception when it contains comma separated list of ports

"ApplicationEngineEnvironment was not started" when accessing application before server is started

Other

Release 1.6.2

Update serialization version to 1.2.2

Update vulnerable versions from sonatype report

1.6.1

released 30th June 2021

Client

crypto is undefined in IE11

java.nio.charset.IllegalCharsetNameException: %s

Postpone (and don't cache) name resolution in cio client

refresh token gets stuck

https://youtrack.jetbrains.com/issue/KTOR-2797

I'm trying to setup the new Bearer Auth functionality(Auth | Ktor) but i'm pretty much stuck.

For what i understand the loadTokens function is to add some initial values, while refreshTokens is to handle the actual refresh. So i've setup my multiplatform project this way:

install(Auth) {
                bearer {

                    loadTokens {
                        sessionStorage.getAuthorizationTokenData()?.let {
                            // it will use this tokens to authenticate calls
                            BearerTokens(
                                accessToken = it.authorizationToken,
                                refreshToken = it.refreshToken
                            )
                        }
                    }

                    refreshTokens { unauthorizedResponse: HttpResponse ->

                        // on new 401 we will need to refresh the token
                        sessionStorage.getAuthorizationTokenData()?.let {
                            // use stored refresh token to get new token
                            val data = getAuthUseCases().refreshToken(
                                RefreshTokenRequestValue(
                                    clientId = platform.clientId,
                                    refreshToken = it.refreshToken
                                )
                            )

                            // save new tokens
                            sessionStorage.setAuthorizationTokenData(
                                AuthToken(
                                    authorizationToken = data.token,
                                    refreshToken = data.refreshToken
                                )
                            )
                            return@refreshTokens BearerTokens(
                                accessToken = data.token,
                                refreshToken = data.refreshToken
                            )
                        }
                    }
                }

the actual refresh is done by using the ktor client itself so it is something along these lines

suspend fun refreshToken(
        clientId: String,
        refreshToken: String
    ): PostRefreshTokenResponse = ktorClient.post(
        request = ApiRequest(
            baseUrl = "http://example.com",
            relativeUrl = "/auth/refresh",
            body = PostRefreshTokenRequest(
                clientId = clientId,
                refreshToken = refreshToken
            )
        )
    )

The authentication part is working ok, the refresh block is called, but whenever the token expires and i get another 401 the actual refresh is stuck, the function `refreshToken` is invoked, but never actually executed.

When trying to actually return only a BearerTokens object it runs ok (but of course without a refreshed token) .

Core

ApplicationEngineEnvironmentBuilder.module { … } is executed twice on Exception

The '-ea' flag works differently when running a server using Application.module and embeddedServer

Docs

Full example for configuring response validation is missing

Link back to site from Docs

Update ktor 1.5.0 docs. Deprecated "challenge" function for form auth in docs.

Auth Feature Code Snippet: form authentication the doesn't work

https://youtrack.jetbrains.com/issue/KTOR-821

This issue was imported from GitHub issue: https://github.com/ktorio/ktor/issues/211

I've the below code, route "/" and "/bye" are working fine, but route "login" given blank page once!!

package blog

import kotlinx.html.*
import kotlinx.html.stream.*    // for createHTML
import org.jetbrains.ktor.application.*
import org.jetbrains.ktor.auth.*
import org.jetbrains.ktor.features.*
import org.jetbrains.ktor.http.*
import org.jetbrains.ktor.response.*
import org.jetbrains.ktor.routing.*

import org.jetbrains.ktor.request.*   // for request.uri

import org.jetbrains.ktor.html.*
import org.jetbrains.ktor.pipeline.*

import org.jetbrains.ktor.host.*   // for embededServer
import org.jetbrains.ktor.netty.*  // for Netty

fun main(args: Array<String>) {
    embeddedServer(Netty, 8080, watchPaths = listOf("BlogAppKt"), module = Application::module).start()
}

fun Application.module() {
    install(DefaultHeaders)
    install(CallLogging)

    intercept(ApplicationCallPipeline.Call) { 
        if (call.request.uri == "/hi")
            call.respondText("Test String")
    }

    install(Routing) {
        get("/") {
            call.respondText("""Hello, world!<br><a href="/bye">Say bye?</a>""", ContentType.Text.Html)
        }
        get("/bye") {
            call.respondText("""Good bye! <br><a href="/login">Login?</a> """, ContentType.Text.Html)
        }
        route("/login") {
            authentication {
                formAuthentication { up: UserPasswordCredential ->
                    when {
                        up.password == "ppp" -> UserIdPrincipal(up.name)
                        else -> null
                    }
                }
            }
         
            handle {
                val principal = call.authentication.principal<UserIdPrincipal>()
                if (principal != null) {
                    call.respondText("Hello, ${principal.name}")
                } else {
                        val html = createHTML().html {
                        body {
                            form(action = "/login", encType = FormEncType.applicationXWwwFormUrlEncoded, method = FormMethod.post) {
                                p {
                                    +"user:"
                                    textInput(name = "user") {
                                        value = principal?.name ?: ""
                                    }
                                }

                                p {
                                    +"password:"
                                    passwordInput(name = "pass")
                                }

                                p {
                                    submitInput() { value = "Login" }
                                }
                            }
                        }
                    }
                    call.respondText(html, ContentType.Text.Html)
                }
            }
        }
    }
}

Review documentation for the onUpload/onDownload client callbacks

Generator

Add start.ktor.io to allowed hosts of the generator backend

Selecting custom package name in Ktor wizard still results in example.com import in ApplicationTest.kt

Infrastructure

Add watchosX64 as an architecture

Unbound public symbol for public io.ktor.network.sockets/SocketTimeoutException when iosArm64 framework

https://youtrack.jetbrains.com/issue/KTOR-2276

When declaring a dependency on Ktor io.ktor:ktor-network and io.ktor:ktor-client-ios, this leads to a compiler error on iosArm64. Tested using kotlin 1.4.31 and ktor 1.5.2

I created a minimal reproducer here: https://github.com/PaulWoitaschek/KtorSocketBug

To reproduce it, run ./gradlew linkDebugFrameworkIosArm64

> Task :linkDebugFrameworkIosArm64 FAILED
e: Compilation failed: Unbound symbols not allowed

Unbound public symbol for public io.ktor.network.sockets/SocketTimeoutException.<init>|-4324620762574333298[0] public io.ktor.network.sockets/SocketTimeoutException.<init>|-4324620762574333298[0]

 * Source files: 
 * Compiler version info: Konan: 1.4.31 / Kotlin: 1.4.31
 * Output kind: FRAMEWORK

e: java.lang.AssertionError: Unbound symbols not allowed

Unbound public symbol for public io.ktor.network.sockets/SocketTimeoutException.<init>|-4324620762574333298[0] public io.ktor.network.sockets/SocketTimeoutException.<init>|-4324620762574333298[0]
        at org.jetbrains.kotlin.ir.util.SymbolTableKt.noUnboundLeft(SymbolTable.kt:1119)
        at org.jetbrains.kotlin.psi2ir.Psi2IrTranslator.generateModuleFragment(Psi2IrTranslator.kt:89)
        at org.jetbrains.kotlin.backend.konan.PsiToIrKt.psiToIr(PsiToIr.kt:160)
        at org.jetbrains.kotlin.backend.konan.ToplevelPhasesKt$psiToIrPhase$1.invoke(ToplevelPhases.kt:135)
        at org.jetbrains.kotlin.backend.konan.ToplevelPhasesKt$psiToIrPhase$1.invoke(ToplevelPhases.kt)
        at org.jetbrains.kotlin.backend.common.phaser.PhaseBuildersKt$namedOpUnitPhase$1.invoke(PhaseBuilders.kt:97)
        at org.jetbrains.kotlin.backend.common.phaser.PhaseBuildersKt$namedOpUnitPhase$1.invoke(PhaseBuilders.kt:95)
        at org.jetbrains.kotlin.backend.common.phaser.NamedCompilerPhase.invoke(CompilerPhase.kt:94)
        at org.jetbrains.kotlin.backend.common.phaser.CompositePhase.invoke(PhaseBuilders.kt:30)
        at org.jetbrains.kotlin.backend.common.phaser.NamedCompilerPhase.invoke(CompilerPhase.kt:94)
        at org.jetbrains.kotlin.backend.common.phaser.CompilerPhaseKt.invokeToplevel(CompilerPhase.kt:41)
        at org.jetbrains.kotlin.backend.konan.KonanDriverKt.runTopLevelPhases(KonanDriver.kt:29)
        at org.jetbrains.kotlin.cli.bc.K2Native.doExecute(K2Native.kt:78)
        at org.jetbrains.kotlin.cli.bc.K2Native.doExecute(K2Native.kt:35)
        at org.jetbrains.kotlin.cli.common.CLICompiler.execImpl(CLICompiler.kt:88)
        at org.jetbrains.kotlin.cli.common.CLICompiler.execImpl(CLICompiler.kt:44)
        at org.jetbrains.kotlin.cli.common.CLITool.exec(CLITool.kt:98)
        at org.jetbrains.kotlin.cli.common.CLITool.exec(CLITool.kt:76)
        at org.jetbrains.kotlin.cli.common.CLITool.exec(CLITool.kt:45)
        at org.jetbrains.kotlin.cli.common.CLITool$Companion.doMainNoExit(CLITool.kt:227)
        at org.jetbrains.kotlin.cli.bc.K2Native$Companion$mainNoExitWithGradleRenderer$1.invoke(K2Native.kt:286)
        at org.jetbrains.kotlin.cli.bc.K2Native$Companion$mainNoExitWithGradleRenderer$1.invoke(K2Native.kt:270)
        at org.jetbrains.kotlin.util.UtilKt.profileIf(Util.kt:27)
        at org.jetbrains.kotlin.util.UtilKt.profile(Util.kt:21)
        at org.jetbrains.kotlin.cli.bc.K2Native$Companion.mainNoExitWithGradleRenderer(K2Native.kt:285)
        at org.jetbrains.kotlin.cli.bc.K2NativeKt.mainNoExitWithGradleRenderer(K2Native.kt:485)
        at org.jetbrains.kotlin.cli.utilities.MainKt$daemonMain$1.invoke(main.kt:43)
        at org.jetbrains.kotlin.cli.utilities.MainKt$daemonMain$1.invoke(main.kt)
        at org.jetbrains.kotlin.cli.utilities.MainKt.mainImpl(main.kt:17)
        at org.jetbrains.kotlin.cli.utilities.MainKt.daemonMain(main.kt:43)
        at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:64)
        at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.base/java.lang.reflect.Method.invoke(Method.java:564)
        at org.jetbrains.kotlin.compilerRunner.KotlinToolRunner.runInProcess(KotlinToolRunner.kt:124)
        at org.jetbrains.kotlin.compilerRunner.KotlinToolRunner.run(KotlinToolRunner.kt:73)
        at org.jetbrains.kotlin.gradle.tasks.AbstractKotlinNativeCompile.compile(KotlinNativeTasks.kt:334)
        at org.jetbrains.kotlin.gradle.tasks.KotlinNativeLink.compile(KotlinNativeTasks.kt:657)
        at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:64)
        at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.base/java.lang.reflect.Method.invoke(Method.java:564)
        at org.gradle.internal.reflect.JavaMethod.invoke(JavaMethod.java:104)
        at org.gradle.api.internal.project.taskfactory.StandardTaskAction.doExecute(StandardTaskAction.java:58)
        at org.gradle.api.internal.project.taskfactory.StandardTaskAction.execute(StandardTaskAction.java:51)
        at org.gradle.api.internal.project.taskfactory.StandardTaskAction.execute(StandardTaskAction.java:29)
        at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter$2.run(ExecuteActionsTaskExecuter.java:494)
        at org.gradle.internal.operations.DefaultBuildOperationRunner$1.execute(DefaultBuildOperationRunner.java:29)
        at org.gradle.internal.operations.DefaultBuildOperationRunner$1.execute(DefaultBuildOperationRunner.java:26)
        at org.gradle.internal.operations.DefaultBuildOperationRunner$3.execute(DefaultBuildOperationRunner.java:75)
        at org.gradle.internal.operations.DefaultBuildOperationRunner$3.execute(DefaultBuildOperationRunner.java:68)
        at org.gradle.internal.operations.DefaultBuildOperationRunner.execute(DefaultBuildOperationRunner.java:153)
        at org.gradle.internal.operations.DefaultBuildOperationRunner.execute(DefaultBuildOperationRunner.java:68)
        at org.gradle.internal.operations.DefaultBuildOperationRunner.run(DefaultBuildOperationRunner.java:56)
        at org.gradle.internal.operations.DefaultBuildOperationExecutor.lambda$run$1(DefaultBuildOperationExecutor.java:71)
        at org.gradle.internal.operations.UnmanagedBuildOperationWrapper.runWithUnmanagedSupport(UnmanagedBuildOperationWrapper.java:45)
        at org.gradle.internal.operations.DefaultBuildOperationExecutor.run(DefaultBuildOperationExecutor.java:71)
        at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter.executeAction(ExecuteActionsTaskExecuter.java:479)
        at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter.executeActions(ExecuteActionsTaskExecuter.java:462)
        at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter.access$400(ExecuteActionsTaskExecuter.java:105)
        at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter$TaskExecution.executeWithPreviousOutputFiles(ExecuteActionsTaskExecuter.java:273)
        at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter$TaskExecution.execute(ExecuteActionsTaskExecuter.java:251)
        at org.gradle.internal.execution.steps.ExecuteStep.lambda$executeOperation$1(ExecuteStep.java:66)
        at java.base/java.util.Optional.orElseGet(Optional.java:362)
        at org.gradle.internal.execution.steps.ExecuteStep.executeOperation(ExecuteStep.java:66)
        at org.gradle.internal.execution.steps.ExecuteStep.access$000(ExecuteStep.java:34)
        at org.gradle.internal.execution.steps.ExecuteStep$1.call(ExecuteStep.java:47)
        at org.gradle.internal.execution.steps.ExecuteStep$1.call(ExecuteStep.java:44)
        at org.gradle.internal.operations.DefaultBuildOperationRunner$CallableBuildOperationWorker.execute(DefaultBuildOperationRunner.java:200)
        at org.gradle.internal.operations.DefaultBuildOperationRunner$CallableBuildOperationWorker.execute(DefaultBuildOperationRunner.java:195)
        at org.gradle.internal.operations.DefaultBuildOperationRunner$3.execute(DefaultBuildOperationRunner.java:75)
        at org.gradle.internal.operations.DefaultBuildOperationRunner$3.execute(DefaultBuildOperationRunner.java:68)
        at org.gradle.internal.operations.DefaultBuildOperationRunner.execute(DefaultBuildOperationRunner.java:153)
        at org.gradle.internal.operations.DefaultBuildOperationRunner.execute(DefaultBuildOperationRunner.java:68)
        at org.gradle.internal.operations.DefaultBuildOperationRunner.call(DefaultBuildOperationRunner.java:62)
        at org.gradle.internal.operations.DefaultBuildOperationExecutor.lambda$call$2(DefaultBuildOperationExecutor.java:76)
        at org.gradle.internal.operations.UnmanagedBuildOperationWrapper.callWithUnmanagedSupport(UnmanagedBuildOperationWrapper.java:54)
        at org.gradle.internal.operations.DefaultBuildOperationExecutor.call(DefaultBuildOperationExecutor.java:76)
        at org.gradle.internal.execution.steps.ExecuteStep.execute(ExecuteStep.java:44)
        at org.gradle.internal.execution.steps.ExecuteStep.execute(ExecuteStep.java:34)
        at org.gradle.internal.execution.steps.RemovePreviousOutputsStep.execute(RemovePreviousOutputsStep.java:72)
        at org.gradle.internal.execution.steps.RemovePreviousOutputsStep.execute(RemovePreviousOutputsStep.java:42)
        at org.gradle.internal.execution.steps.ResolveInputChangesStep.execute(ResolveInputChangesStep.java:53)
        at org.gradle.internal.execution.steps.ResolveInputChangesStep.execute(ResolveInputChangesStep.java:39)
        at org.gradle.internal.execution.steps.CancelExecutionStep.execute(CancelExecutionStep.java:44)
        at org.gradle.internal.execution.steps.TimeoutStep.executeWithoutTimeout(TimeoutStep.java:77)
        at org.gradle.internal.execution.steps.TimeoutStep.execute(TimeoutStep.java:58)
        at org.gradle.internal.execution.steps.CreateOutputsStep.execute(CreateOutputsStep.java:54)
        at org.gradle.internal.execution.steps.CreateOutputsStep.execute(CreateOutputsStep.java:32)
        at org.gradle.internal.execution.steps.CaptureStateAfterExecutionStep.execute(CaptureStateAfterExecutionStep.java:57)
        at org.gradle.internal.execution.steps.CaptureStateAfterExecutionStep.execute(CaptureStateAfterExecutionStep.java:38)
        at org.gradle.internal.execution.steps.BroadcastChangingOutputsStep.execute(BroadcastChangingOutputsStep.java:63)
        at org.gradle.internal.execution.steps.BroadcastChangingOutputsStep.execute(BroadcastChangingOutputsStep.java:30)
        at org.gradle.internal.execution.steps.BuildCacheStep.executeWithoutCache(BuildCacheStep.java:176)
        at org.gradle.internal.execution.steps.BuildCacheStep.execute(BuildCacheStep.java:76)
        at org.gradle.internal.execution.steps.BuildCacheStep.execute(BuildCacheStep.java:47)
        at org.gradle.internal.execution.steps.StoreExecutionStateStep.execute(StoreExecutionStateStep.java:43)
        at org.gradle.internal.execution.steps.StoreExecutionStateStep.execute(StoreExecutionStateStep.java:32)
        at org.gradle.internal.execution.steps.RecordOutputsStep.execute(RecordOutputsStep.java:39)
        at org.gradle.internal.execution.steps.RecordOutputsStep.execute(RecordOutputsStep.java:25)
        at org.gradle.internal.execution.steps.SkipUpToDateStep.executeBecause(SkipUpToDateStep.java:102)
        at org.gradle.internal.execution.steps.SkipUpToDateStep.lambda$execute$0(SkipUpToDateStep.java:95)
        at java.base/java.util.Optional.map(Optional.java:258)
        at org.gradle.internal.execution.steps.SkipUpToDateStep.execute(SkipUpToDateStep.java:55)
        at org.gradle.internal.execution.steps.SkipUpToDateStep.execute(SkipUpToDateStep.java:39)
        at org.gradle.internal.execution.steps.ResolveChangesStep.execute(ResolveChangesStep.java:83)
        at org.gradle.internal.execution.steps.ResolveChangesStep.execute(ResolveChangesStep.java:44)
        at org.gradle.internal.execution.steps.legacy.MarkSnapshottingInputsFinishedStep.execute(MarkSnapshottingInputsFinishedStep.java:37)
        at org.gradle.internal.execution.steps.legacy.MarkSnapshottingInputsFinishedStep.execute(MarkSnapshottingInputsFinishedStep.java:27)
        at org.gradle.internal.execution.steps.ResolveCachingStateStep.execute(ResolveCachingStateStep.java:96)
        at org.gradle.internal.execution.steps.ResolveCachingStateStep.execute(ResolveCachingStateStep.java:52)
        at org.gradle.internal.execution.steps.CaptureStateBeforeExecutionStep.execute(CaptureStateBeforeExecutionStep.java:83)
        at org.gradle.internal.execution.steps.CaptureStateBeforeExecutionStep.execute(CaptureStateBeforeExecutionStep.java:54)
        at org.gradle.internal.execution.steps.ValidateStep.execute(ValidateStep.java:74)
        at org.gradle.internal.execution.steps.SkipEmptyWorkStep.lambda$execute$2(SkipEmptyWorkStep.java:88)
        at java.base/java.util.Optional.orElseGet(Optional.java:362)
        at org.gradle.internal.execution.steps.SkipEmptyWorkStep.execute(SkipEmptyWorkStep.java:88)
        at org.gradle.internal.execution.steps.SkipEmptyWorkStep.execute(SkipEmptyWorkStep.java:34)
        at org.gradle.internal.execution.steps.legacy.MarkSnapshottingInputsStartedStep.execute(MarkSnapshottingInputsStartedStep.java:38)
        at org.gradle.internal.execution.steps.LoadExecutionStateStep.execute(LoadExecutionStateStep.java:46)
        at org.gradle.internal.execution.steps.LoadExecutionStateStep.execute(LoadExecutionStateStep.java:34)
        at org.gradle.internal.execution.steps.AssignWorkspaceStep.lambda$execute$0(AssignWorkspaceStep.java:43)
        at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter$TaskExecution$3.withWorkspace(ExecuteActionsTaskExecuter.java:286)
        at org.gradle.internal.execution.steps.AssignWorkspaceStep.execute(AssignWorkspaceStep.java:43)
        at org.gradle.internal.execution.steps.AssignWorkspaceStep.execute(AssignWorkspaceStep.java:33)
        at org.gradle.internal.execution.steps.IdentityCacheStep.execute(IdentityCacheStep.java:40)
        at org.gradle.internal.execution.steps.IdentityCacheStep.execute(IdentityCacheStep.java:30)
        at org.gradle.internal.execution.steps.IdentifyStep.execute(IdentifyStep.java:54)
        at org.gradle.internal.execution.steps.IdentifyStep.execute(IdentifyStep.java:40)
        at org.gradle.internal.execution.impl.DefaultExecutionEngine.execute(DefaultExecutionEngine.java:41)
        at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter.lambda$executeIfValid$1(ExecuteActionsTaskExecuter.java:183)
        at java.base/java.util.Optional.orElseGet(Optional.java:362)
        at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter.executeIfValid(ExecuteActionsTaskExecuter.java:183)
        at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter.execute(ExecuteActionsTaskExecuter.java:173)
        at org.gradle.api.internal.tasks.execution.CleanupStaleOutputsExecuter.execute(CleanupStaleOutputsExecuter.java:109)
        at org.gradle.api.internal.tasks.execution.FinalizePropertiesTaskExecuter.execute(FinalizePropertiesTaskExecuter.java:46)
        at org.gradle.api.internal.tasks.execution.ResolveTaskExecutionModeExecuter.execute(ResolveTaskExecutionModeExecuter.java:62)
        at org.gradle.api.internal.tasks.execution.SkipTaskWithNoActionsExecuter.execute(SkipTaskWithNoActionsExecuter.java:57)
        at org.gradle.api.internal.tasks.execution.SkipOnlyIfTaskExecuter.execute(SkipOnlyIfTaskExecuter.java:56)
        at org.gradle.api.internal.tasks.execution.CatchExceptionTaskExecuter.execute(CatchExceptionTaskExecuter.java:36)
        at org.gradle.api.internal.tasks.execution.EventFiringTaskExecuter$1.executeTask(EventFiringTaskExecuter.java:77)
        at org.gradle.api.internal.tasks.execution.EventFiringTaskExecuter$1.call(EventFiringTaskExecuter.java:55)
        at org.gradle.api.internal.tasks.execution.EventFiringTaskExecuter$1.call(EventFiringTaskExecuter.java:52)
        at org.gradle.internal.operations.DefaultBuildOperationRunner$CallableBuildOperationWorker.execute(DefaultBuildOperationRunner.java:200)
        at org.gradle.internal.operations.DefaultBuildOperationRunner$CallableBuildOperationWorker.execute(DefaultBuildOperationRunner.java:195)
        at org.gradle.internal.operations.DefaultBuildOperationRunner$3.execute(DefaultBuildOperationRunner.java:75)
        at org.gradle.internal.operations.DefaultBuildOperationRunner$3.execute(DefaultBuildOperationRunner.java:68)
        at org.gradle.internal.operations.DefaultBuildOperationRunner.execute(DefaultBuildOperationRunner.java:153)
        at org.gradle.internal.operations.DefaultBuildOperationRunner.execute(DefaultBuildOperationRunner.java:68)
        at org.gradle.internal.operations.DefaultBuildOperationRunner.call(DefaultBuildOperationRunner.java:62)
        at org.gradle.internal.operations.DefaultBuildOperationExecutor.lambda$call$2(DefaultBuildOperationExecutor.java:76)
        at org.gradle.internal.operations.UnmanagedBuildOperationWrapper.callWithUnmanagedSupport(UnmanagedBuildOperationWrapper.java:54)
        at org.gradle.internal.operations.DefaultBuildOperationExecutor.call(DefaultBuildOperationExecutor.java:76)
        at org.gradle.api.internal.tasks.execution.EventFiringTaskExecuter.execute(EventFiringTaskExecuter.java:52)
        at org.gradle.execution.plan.LocalTaskNodeExecutor.execute(LocalTaskNodeExecutor.java:41)
        at org.gradle.execution.taskgraph.DefaultTaskExecutionGraph$InvokeNodeExecutorsAction.execute(DefaultTaskExecutionGraph.java:411)
        at org.gradle.execution.taskgraph.DefaultTaskExecutionGraph$InvokeNodeExecutorsAction.execute(DefaultTaskExecutionGraph.java:398)
        at org.gradle.execution.taskgraph.DefaultTaskExecutionGraph$BuildOperationAwareExecutionAction.execute(DefaultTaskExecutionGraph.java:391)
        at org.gradle.execution.taskgraph.DefaultTaskExecutionGraph$BuildOperationAwareExecutionAction.execute(DefaultTaskExecutionGraph.java:377)
        at org.gradle.execution.plan.DefaultPlanExecutor$ExecutorWorker.lambda$run$0(DefaultPlanExecutor.java:127)
        at org.gradle.execution.plan.DefaultPlanExecutor$ExecutorWorker.execute(DefaultPlanExecutor.java:191)
        at org.gradle.execution.plan.DefaultPlanExecutor$ExecutorWorker.executeNextNode(DefaultPlanExecutor.java:182)
        at org.gradle.execution.plan.DefaultPlanExecutor$ExecutorWorker.run(DefaultPlanExecutor.java:124)
        at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:64)
        at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:48)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:630)
        at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:56)
        at java.base/java.lang.Thread.run(Thread.java:832)


FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':linkDebugFrameworkIosArm64'.
> Compilation finished with errors

* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.

* Get more help at https://help.gradle.org

BUILD FAILED in 11s
2 actionable tasks: 2 executed

Plugin

Endpoints View: Endpoints no longer populate in KTOR project

Lots of Run Configurations Created for Ktor Project with the Similar Names

KtorTestIntentionImpl doesn't have description

Import `kotlin.test` is not resolved in generated project

Unable to run new Ktor project

Research shared indexes for Ktor

Generated project with specific security and session features selected fails to compile / run

Wizard: Misleading comment in Static Feature

Server

Support X-Forwarded-Port header in XForwardedHeaderSupport plugin

configureBootstrap hook overwritten by Ktor settings

StatusPages doesn't catch FreeMarker exceptions

Adding application startup and hot-reloading time log

Unhandled get freezes with `CIO` server

JWK Public Key of type "EC"

Enabled-by-default development mode breaks reflection by overriding classloader

Test Infrastructure

ktor-server-test-host depends on kotlin-test-junit and junit

Other

Release 1.6.1

Publish Ktor to NPM

Improve diagnostics for exceptions inherited from IOException

developmentMode is on by default in tests

Update CONTRIBUTING.md

Double host header

Use kotlin.reflect.jvm.javaType instead of the type token pattern in io.ktor.util.reflect.typeInfo

1.6.0

released 28th May 2021

Client

When the main thread executes runBlocking, using the iOS engine will cause a deadlock

'%3D' inside query of redirect target location will be replaced to '='

https://youtrack.jetbrains.com/issue/KTOR-2057

When the server returns 302 with the URL has '%3D' (inside query part), the Ktor replaces '%3D' with '=' so some server returns invalid content (in this case, 403).

Test code:

import io.ktor.client.*
import io.ktor.client.features.*
import io.ktor.client.request.*
import io.ktor.client.statement.*
import kotlinx.coroutines.runBlocking

fun main(): Unit = runBlocking {
    val url = "https://dl.bintray.com/anatawa12/maven/com/anatawa12/forge/ForgeGradle/1.2-1.0.0/ForgeGradle-1.2-1.0.0-javadoc.jar"

    // also in CIO
    //val factory = io.ktor.client.engine.cio.CIO
    val factory = io.ktor.client.engine.apache.Apache
    val clientNoFollow = HttpClient(io.ktor.client.engine.cio.CIO) {
        followRedirects = false
        expectSuccess = false
    }
    val response = clientNoFollow.get<HttpResponse>(url)
    println("status: " + response.status)
    println("location:  " + response.headers["Location"])
    println("location has %3D: " + response.headers["Location"]!!.contains("%3D"))
    check(response.headers["Location"]!!.contains("%3D"))

    val clientWithFollow = HttpClient(io.ktor.client.engine.cio.CIO)
    try {
        val got = clientWithFollow.get<ByteArray>(url)
    } catch (e: ResponseException) {
        println("error: " + e)
        println("error url: " + e.response.request.url)
        println("error url has %3D: " + e.response.request.url.toString().contains("%3D"))
    }
}

Log:

status: 302 
location:  https://d29vzk4ow07wi7.cloudfront.net/d133d0ab57f0e1a996fa1367eb3e5c7ebbd1860a5d505a69791d7746457acb0a?response-content-disposition=attachment%3Bfilename%3D%22ForgeGradle-1.2-1.0.0-javadoc.jar%22&Policy=eyJTdGF0ZW1lbnQiOiBbeyJSZXNvdXJjZSI6Imh0dHAqOi8vZDI5dnprNG93MDd3aTcuY2xvdWRmcm9udC5uZXQvZDEzM2QwYWI1N2YwZTFhOTk2ZmExMzY3ZWIzZTVjN2ViYmQxODYwYTVkNTA1YTY5NzkxZDc3NDY0NTdhY2IwYT9yZXNwb25zZS1jb250ZW50LWRpc3Bvc2l0aW9uPWF0dGFjaG1lbnQlM0JmaWxlbmFtZSUzRCUyMkZvcmdlR3JhZGxlLTEuMi0xLjAuMC1qYXZhZG9jLmphciUyMiIsIkNvbmRpdGlvbiI6eyJEYXRlTGVzc1RoYW4iOnsiQVdTOkVwb2NoVGltZSI6MTYxMjkzNzUyOX0sIklwQWRkcmVzcyI6eyJBV1M6U291cmNlSXAiOiIwLjAuMC4wLzAifX19XX0_&Signature=ch~WD7z9cBluu3KWX2pIsmCd7pfVQ~WnM2QEg6wLuDPFi5pr2e4DnHApdAX9A92dxJW68WYllbKB1pNRkJ6RjtW~3eip545DnUcSBYGT1vfiaxNzp80QYsg~EUo~l4eHFYVoywXXPNgEPRXPIZ2vHGv7H7aeGJ5fbhzyunSmdstRnfUpfKLL5XmsDjpvVY4RYy1NSHHG70BU3y6UP1nqdu1hEdzBhRFKwZ~0uj8~2S4OF6Daaj71jkRWF49TQS~aNpvrkaAZojUilWEwppXZNcCekXu7Bt95oJDESsNQf0bu0gDw5eNtAfy2ZzN~a~lXVTV3ORy3kVanNwiVJzcf~g__&Key-Pair-Id=APKAIFKFWOMXM2UMTSFA
location has %3D: true
error: io.ktor.client.features.ClientRequestException: Client request(https://d29vzk4ow07wi7.cloudfront.net/d133d0ab57f0e1a996fa1367eb3e5c7ebbd1860a5d505a69791d7746457acb0a?response-content-disposition=attachment%3Bfilename=%22ForgeGradle-1.2-1.0.0-javadoc.jar%22&Policy=eyJTdGF0ZW1lbnQiOiBbeyJSZXNvdXJjZSI6Imh0dHAqOi8vZDI5dnprNG93MDd3aTcuY2xvdWRmcm9udC5uZXQvZDEzM2QwYWI1N2YwZTFhOTk2ZmExMzY3ZWIzZTVjN2ViYmQxODYwYTVkNTA1YTY5NzkxZDc3NDY0NTdhY2IwYT9yZXNwb25zZS1jb250ZW50LWRpc3Bvc2l0aW9uPWF0dGFjaG1lbnQlM0JmaWxlbmFtZSUzRCUyMkZvcmdlR3JhZGxlLTEuMi0xLjAuMC1qYXZhZG9jLmphciUyMiIsIkNvbmRpdGlvbiI6eyJEYXRlTGVzc1RoYW4iOnsiQVdTOkVwb2NoVGltZSI6MTYxMjkzNzUzMH0sIklwQWRkcmVzcyI6eyJBV1M6U291cmNlSXAiOiIwLjAuMC4wLzAifX19XX0_&Signature=XwmQYLdJSkb~0fNr36ebj1vzn1KXmufRtaP9Mj9y9thRAtpAbyImJU-31VhtEhV56ijN2-tBtT5m0rNPSq-f6AEvngoEZURUUpE-vGVb1UFwiGnVnTuDKQJUvao3gZTj-fq9kRCLosJGYJiVbLG3GTXQKYoxL9fQh2ttwS3eFKAyFylcjyvsmSkEAekomfjB8OhUpgc~B6CE0Vg6aOm3ZBaKNAtfX4~cccnFrz4PB836WD68y8qX9jN5IQMCAiDy0881chyPIjGM7c30aycANw5c8StHSRy~gWo5WL7TGpq19X5q2pK-sT8Vq0I3AJJZ95XW9N3GWj0WR7IKqOQTAg__&Key-Pair-Id=APKAIFKFWOMXM2UMTSFA) invalid: 403 Forbidden. Text: "<?xml version="1.0" encoding="UTF-8"?><Error><Code>AccessDenied</Code><Message>Access denied</Message></Error>"
error url: https://d29vzk4ow07wi7.cloudfront.net/d133d0ab57f0e1a996fa1367eb3e5c7ebbd1860a5d505a69791d7746457acb0a?response-content-disposition=attachment%3Bfilename=%22ForgeGradle-1.2-1.0.0-javadoc.jar%22&Policy=eyJTdGF0ZW1lbnQiOiBbeyJSZXNvdXJjZSI6Imh0dHAqOi8vZDI5dnprNG93MDd3aTcuY2xvdWRmcm9udC5uZXQvZDEzM2QwYWI1N2YwZTFhOTk2ZmExMzY3ZWIzZTVjN2ViYmQxODYwYTVkNTA1YTY5NzkxZDc3NDY0NTdhY2IwYT9yZXNwb25zZS1jb250ZW50LWRpc3Bvc2l0aW9uPWF0dGFjaG1lbnQlM0JmaWxlbmFtZSUzRCUyMkZvcmdlR3JhZGxlLTEuMi0xLjAuMC1qYXZhZG9jLmphciUyMiIsIkNvbmRpdGlvbiI6eyJEYXRlTGVzc1RoYW4iOnsiQVdTOkVwb2NoVGltZSI6MTYxMjkzNzUzMH0sIklwQWRkcmVzcyI6eyJBV1M6U291cmNlSXAiOiIwLjAuMC4wLzAifX19XX0_&Signature=XwmQYLdJSkb~0fNr36ebj1vzn1KXmufRtaP9Mj9y9thRAtpAbyImJU-31VhtEhV56ijN2-tBtT5m0rNPSq-f6AEvngoEZURUUpE-vGVb1UFwiGnVnTuDKQJUvao3gZTj-fq9kRCLosJGYJiVbLG3GTXQKYoxL9fQh2ttwS3eFKAyFylcjyvsmSkEAekomfjB8OhUpgc~B6CE0Vg6aOm3ZBaKNAtfX4~cccnFrz4PB836WD68y8qX9jN5IQMCAiDy0881chyPIjGM7c30aycANw5c8StHSRy~gWo5WL7TGpq19X5q2pK-sT8Vq0I3AJJZ95XW9N3GWj0WR7IKqOQTAg__&Key-Pair-Id=APKAIFKFWOMXM2UMTSFA
error url has %3D: false

HTTP-client auth with Bearer token

Ktor fails to deliver response with error: failed with exception: kotlinx.coroutines.JobCancellationException: Parent job is Completed;

Apache HTTP Client does not send Content-Length header if body is empty content

Sporadic OkHttp errors after upgrading to ktor 1.3.1

https://youtrack.jetbrains.com/issue/KTOR-449

This issue was imported from GitHub issue: https://github.com/ktorio/ktor/issues/1708

Ktor Version and Engine Used (client or server and name)

implementation("io.ktor:ktor-client-core-jvm:1.3.1")
implementation("io.ktor:ktor-client-core:1.3.1")
implementation("io.ktor:ktor-client-jackson:1.3.1")
implementation("io.ktor:ktor-client-logging-jvm:1.3.1")
implementation("io.ktor:ktor-client-okhttp:1.3.1")
implementation("io.ktor:ktor-jackson:1.3.1")
implementation("io.ktor:ktor-metrics-micrometer:1.3.1")
implementation("io.ktor:ktor-metrics:1.3.1")
implementation("io.ktor:ktor-server-host-common:1.3.1")
implementation("io.ktor:ktor-server-netty:1.3.1")

Describe the bug

We've started seeing sporadic OkHttp exceptions in our tests when we upgraded from 1.3.0 to 1.3.1. Upon downgrading back to 1.3.0 (with no other changes) the tests were fine again.

The exception is:

java.io.EOFException: \n not found: limit=0 content=…
	at o.RealBufferedSource.readUtf8LineStrict(RealBufferedSource.java:240)
	at o.i.h.Http1ExchangeCodec.readHeaderLine(Http1ExchangeCodec.java:242)
	at o.i.h.Http1ExchangeCodec.readResponseHeaders(Http1ExchangeCodec.java:213)
	... 20 common frames omitted
Wrapped by: java.io.IOException: unexpected end of stream on http://called-service/...
	at o.i.h.Http1ExchangeCodec.readResponseHeaders(Http1ExchangeCodec.java:236)
	at o.i.c.Exchange.readResponseHeaders(Exchange.java:115)
	at o.i.h.CallServerInterceptor.intercept(CallServerInterceptor.java:94)
	at o.i.h.RealInterceptorChain.proceed(RealInterceptorChain.java:142)
	at o.i.c.ConnectInterceptor.intercept(ConnectInterceptor.java:43)
	at o.i.h.RealInterceptorChain.proceed(RealInterceptorChain.java:142)
	at o.i.h.RealInterceptorChain.proceed(RealInterceptorChain.java:117)
	at o.i.c.CacheInterceptor.intercept(CacheInterceptor.java:94)
	at o.i.h.RealInterceptorChain.proceed(RealInterceptorChain.java:142)
	at o.i.h.RealInterceptorChain.proceed(RealInterceptorChain.java:117)
	at o.i.h.BridgeInterceptor.intercept(BridgeInterceptor.java:93)
	at o.i.h.RealInterceptorChain.proceed(RealInterceptorChain.java:142)
	at o.i.h.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:88)
	at o.i.h.RealInterceptorChain.proceed(RealInterceptorChain.java:142)
	at o.i.h.RealInterceptorChain.proceed(RealInterceptorChain.java:117)
	at okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:221)
	at o.RealCall$AsyncCall.execute(RealCall.java:172)
	at o.i.NamedRunnable.run(NamedRunnable.java:32)
	at j.u.c.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at j.u.c.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.lang.Thread.run(Thread.java:834)

It looks like the HTTP client receives an EOF while reading the response headers from calling http://called-service/... I don't think the culprit is the remote web server though, because this server is called from other services and it's only the one with ktor 1.3.1 that throws these errors. And this one is also fine with ktor 1.3.0.

This issue has already been raised before in the OkHttp repository, for example here.

From what I can see, both ktor 1.3.0 and 1.3.1 both depend on com.squareup.okhttp3:okhttp:3.14.2, so maybe this is due to a change in the way ktor uses OkHttp?

To Reproduce

Not easy to reproduce, unfortunately, because the error only occurs in a small percentage of requests (~5%). I'm hoping someone else observes this issue and can come up with a reproducible test.

Client upload/download progress observer/handler/interceptor

CIO: TLSConfigBuilder JVM allow null as password

Occasional "Channel has been cancelled" errors when using OkHttp

https://youtrack.jetbrains.com/issue/KTOR-1054

I haven't been able to repro this.
Ktor 1.4.0 OkHttp 4.8.0 Okio 2.7.0

java.util.concurrent.CancellationException: Channel has been cancelled
    at io.ktor.utils.io.ByteBufferChannel.cancel(ByteBufferChannel.kt:152)
    at io.ktor.utils.io.ByteReadChannelKt.cancel(ByteReadChannel.kt:225)
    at io.ktor.utils.io.jvm.javaio.InputAdapter.close(Blocking.kt:66)
    at okio.InputStreamSource.close(JvmOkio.kt:108)
    at kotlin.io.CloseableKt.closeFinally(Closeable.kt:60)
    at io.ktor.client.engine.okhttp.StreamRequestBody.writeTo(StreamRequestBody.kt:20)
    at okhttp3.internal.http.CallServerInterceptor.intercept(CallServerInterceptor.kt:59)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.kt:34)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.kt:95)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.kt:83)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.kt:76)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.connection.RealCall.getResponseWithInterceptorChain$okhttp(RealCall.kt:201)
    at okhttp3.internal.connection.RealCall$AsyncCall.run(RealCall.kt:517)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1167)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:641)
    at java.lang.Thread.run(Thread.java:923)
java.util.concurrent.CancellationException: Channel has been cancelled
    at java.lang.reflect.Constructor.newInstance0(Constructor.java)
    at java.lang.reflect.Constructor.newInstance(Constructor.java:343)
    at io.ktor.utils.io.ExceptionUtilsJvmKt$createConstructor$$inlined$safeCtor$3.invoke(ExceptionUtilsJvm.kt:105)
    at io.ktor.utils.io.ExceptionUtilsJvmKt$createConstructor$$inlined$safeCtor$3.invoke
    at io.ktor.utils.io.ExceptionUtilsJvmKt.tryCopyException(ExceptionUtilsJvm.kt:65)
    at io.ktor.utils.io.ByteBufferChannelKt.rethrowClosed(ByteBufferChannel.kt:2594)
    at io.ktor.utils.io.ByteBufferChannelKt.access$rethrowClosed(ByteBufferChannel.kt:1)
    at io.ktor.utils.io.ByteBufferChannel.setupStateForRead(ByteBufferChannel.kt:268)
    at io.ktor.utils.io.ByteBufferChannel.access$setupStateForRead(ByteBufferChannel.kt:23)
    at io.ktor.utils.io.ByteBufferChannel.readAsMuchAsPossible(ByteBufferChannel.kt:2667)
    at io.ktor.utils.io.ByteBufferChannel.readAvailable$suspendImpl(ByteBufferChannel.kt:605)
    at io.ktor.utils.io.ByteBufferChannel.readAvailable
    at io.ktor.utils.io.jvm.javaio.InputAdapter$loop$1.loop(Blocking.kt:33)
    at io.ktor.utils.io.jvm.javaio.InputAdapter$loop$1$loop$1.invokeSuspend
    at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
    at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:56)
    at io.ktor.utils.io.jvm.javaio.UnsafeBlockingTrampoline.dispatch(Blocking.kt:284)
    at kotlinx.coroutines.DispatchedContinuation.resumeWith(DispatchedContinuation.kt:184)
    at io.ktor.utils.io.jvm.javaio.BlockingAdapter.submitAndAwait(Blocking.kt:221)
    at io.ktor.utils.io.jvm.javaio.BlockingAdapter.submitAndAwait(Blocking.kt:194)
    at io.ktor.utils.io.jvm.javaio.InputAdapter.read(Blocking.kt:60)
    at okio.InputStreamSource.read(JvmOkio.kt:90)
    at okio.RealBufferedSink.writeAll(RealBufferedSink.kt:180)
    at io.ktor.client.engine.okhttp.StreamRequestBody.writeTo(StreamRequestBody.kt:21)
    at okhttp3.internal.http.CallServerInterceptor.intercept(CallServerInterceptor.kt:59)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.kt:34)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.kt:95)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.kt:83)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.kt:76)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.connection.RealCall.getResponseWithInterceptorChain$okhttp(RealCall.kt:201)
    at okhttp3.internal.connection.RealCall$AsyncCall.run(RealCall.kt:517)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1167)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:641)
    at java.lang.Thread.run(Thread.java:923)

Core

UDPSocketTest.testBroadcastSuccessful[jvm] is failing

How to track leaked buffers in ktor-io?

Expose TrailingSlashRouteSelector

Docs

Wrong Tabs Name in Code Blocks

Document usage of Bearer token in Http Client

Duplicate server `Features` Section on the Documentation Website

Duplicate entry "Features" in Server docs

Infrastructure

Update Dokka: Dokka tasks fails with old dokka version and Gradle 7

Migrate to Dokka 1.4.0

Plugin

IDE plugin: SOE through KtorUrlReferenceContributor$Companion.getParentUrlPaths

https://youtrack.jetbrains.com/issue/KTOR-2576

User feedback:

After installing Intellij IDEA 2021.1 (on Linux Mint 20.1 with all updates installed) I was having a lot of problems working in a simple Ktor/Gradle project, newly created. I could build in gradle and run the application but in the IDE the editor was showing errors where there were none. Go to definition and other code navigation features weren't working. I got an error saying "Kotlin not enabled" but the plugin was installed and enabled. Eventually the IDE would lock up completely and I'd have to kill the process manually.

I tried uninstalling and reinstalling, removing all folders in places like .local where files were stored before reinstalling. I tried installing using JB toolbox and then removing that as well and installing from a .tar.gz file.

Finally I just removed it all and installed 2020.3, and it's working, but doesn't have some of the new features like Code With Me that I wanted to try.

IDEA 2021.1.1 Preview Build #IU-211.7142.13 Kotlin (211-1.4.32-release-IJ7142.3) Ktor version: 1.5.3

2021-04-22 09:09:59,895 [  34465]  ERROR - mpl.search.PsiSearchHelperImpl - IntelliJ IDEA 2021.1.1 Preview  Build #IU-211.7142.13 
2021-04-22 09:09:59,895 [  34465]  ERROR - mpl.search.PsiSearchHelperImpl - JDK: 11.0.10; VM: Dynamic Code Evolution 64-Bit Server VM; Vendor: JetBrains s.r.o. 
2021-04-22 09:09:59,895 [  34465]  ERROR - mpl.search.PsiSearchHelperImpl - OS: Linux 
2021-04-22 09:09:59,895 [  34465]  ERROR - mpl.search.PsiSearchHelperImpl - Plugin to blame: Ktor version: 1.5.3 
2021-04-22 09:09:59,895 [  34465]  ERROR - mpl.search.PsiSearchHelperImpl - Last Action: About 
2021-04-22 09:09:59,895 [  34465]  ERROR - aemon.impl.PassExecutorService - null 
java.lang.StackOverflowError
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.openapi.progress.util.ProgressWrapper.setText(ProgressWrapper.java:105)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.processGlobalRequests(PsiSearchHelperImpl.java:837)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.processGlobalRequestsOptimized(PsiSearchHelperImpl.java:830)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.processRequests(PsiSearchHelperImpl.java:755)
	at com.intellij.psi.search.SearchRequestQuery.processResults(SearchRequestQuery.java:24)
	at com.intellij.util.AbstractQuery.doProcessResults(AbstractQuery.java:91)
	at com.intellij.util.AbstractQuery.delegateProcessResults(AbstractQuery.java:108)
	at com.intellij.util.MergeQuery.processResults(MergeQuery.java:22)
	at com.intellij.util.AbstractQuery.doProcessResults(AbstractQuery.java:91)
	at com.intellij.util.AbstractQuery.delegateProcessResults(AbstractQuery.java:108)
	at com.intellij.util.UniqueResultsQuery.processResults(UniqueResultsQuery.java:39)
	at com.intellij.util.AbstractQuery.doProcessResults(AbstractQuery.java:91)
	at com.intellij.util.AbstractQuery.forEach(AbstractQuery.java:83)
	at com.intellij.util.AbstractQuery.findAll(AbstractQuery.java:28)
	at com.intellij.util.Query.iterator(Query.java:129)
	at com.intellij.util.AbstractQuery.iterator(AbstractQuery.java:39)
	at io.ktor.ide.KtorUrlReferenceContributor$Companion.getParentUrlPaths(KtorUrlReferenceContributor.kt:370)
	at io.ktor.ide.KtorUrlReferenceContributor$Companion.getParentUrlPaths$default(KtorUrlReferenceContributor.kt:120)
	at io.ktor.ide.KtorUrlReferenceContributor$Companion.getParentUrlPaths(KtorUrlReferenceContributor.kt:191)
	at io.ktor.ide.KtorUrlReferenceContributor$Companion.getParentUrlPaths$default(KtorUrlReferenceContributor.kt:120)
	at io.ktor.ide.KtorUrlReferenceContributor$Companion.calculateUrlPathContext(KtorUrlReferenceContributor.kt:85)
	at io.ktor.ide.KtorUrlReferenceContributor$registerServerReferenceProvider$1$injector$1.invoke(KtorUrlReferenceContributor.kt:232)
	at io.ktor.ide.KtorUrlReferenceContributor$registerServerReferenceProvider$1$injector$1.invoke(KtorUrlReferenceContributor.kt:22)
	at com.intellij.microservices.url.references.UrlPathReferenceInjector$buildReferences$1.rootContext(UrlPathReferenceInjector.kt:128)
	at com.intellij.microservices.url.references.UrlPathReferenceInjector$buildReferences$1.forPsiElement(UrlPathReferenceInjector.kt:136)
	at io.ktor.ide.KtorUrlReferenceContributor$registerServerReferenceProvider$1.invoke(KtorUrlReferenceContributor.kt:238)
	at io.ktor.ide.KtorUrlReferenceContributor$registerServerReferenceProvider$1.invoke(KtorUrlReferenceContributor.kt:22)
	at com.intellij.psi.UastReferenceRegistrar$uastReferenceProvider$1.getReferencesByElement(UastReferenceRegistrar.kt:54)
	at com.intellij.psi.UastReferenceProviderAdapter$getReferencesByElement$1.invoke(UastReferenceProviderAdapter.kt:13)
	at com.intellij.psi.UastReferenceProviderAdapter$getReferencesByElement$1.invoke(UastReferenceProviderAdapter.kt:8)
	at com.intellij.openapi.progress.impl.CancellationCheck.withCancellationCheck(CancellationCheck.kt:59)
	at com.intellij.openapi.progress.impl.CancellationCheck$Companion.runWithCancellationCheck(CancellationCheck.kt:105)
	at com.intellij.psi.UastReferenceProviderAdapter.getReferencesByElement(UastReferenceProviderAdapter.kt:13)
	at com.intellij.psi.impl.source.resolve.reference.ReferenceProvidersRegistryImpl.getReferences(ReferenceProvidersRegistryImpl.java:201)
	at com.intellij.psi.impl.source.resolve.reference.ReferenceProvidersRegistryImpl.mapNotEmptyReferencesFromProviders(ReferenceProvidersRegistryImpl.java:164)
	at com.intellij.psi.impl.source.resolve.reference.ReferenceProvidersRegistryImpl.doGetReferencesFromProviders(ReferenceProvidersRegistryImpl.java:143)
	at com.intellij.psi.impl.source.resolve.reference.ReferenceProvidersRegistry.getReferencesFromProviders(ReferenceProvidersRegistry.java:43)
	at com.intellij.psi.PsiReferenceServiceImpl.doGetReferences(PsiReferenceServiceImpl.java:34)
	at com.intellij.psi.PsiReferenceServiceImpl.getReferences(PsiReferenceServiceImpl.java:26)
	at com.intellij.psi.search.SingleTargetRequestResultProcessor.processTextOccurrence(SingleTargetRequestResultProcessor.java:32)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl$5.lambda$execute$0(PsiSearchHelperImpl.java:942)
	at com.intellij.psi.impl.search.LowLevelSearchUtil.processTreeUp(LowLevelSearchUtil.java:88)
	at com.intellij.psi.impl.search.LowLevelSearchUtil.lambda$processElementsAtOffsets$0(LowLevelSearchUtil.java:179)
	at com.intellij.psi.impl.search.LowLevelSearchUtil.processOffsets(LowLevelSearchUtil.java:205)
	at com.intellij.psi.impl.search.LowLevelSearchUtil.processElementsAtOffsets(LowLevelSearchUtil.java:178)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl$5.execute(PsiSearchHelperImpl.java:938)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl$2.processInReadAction(PsiSearchHelperImpl.java:272)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl$2.processInReadAction(PsiSearchHelperImpl.java:263)
	at com.intellij.openapi.application.ReadActionProcessor.lambda$process$0(ReadActionProcessor.java:25)
	at com.intellij.openapi.application.impl.ApplicationImpl.runReadAction(ApplicationImpl.java:844)
	at com.intellij.openapi.application.ReadAction.compute(ReadAction.java:61)
	at com.intellij.openapi.application.ReadActionProcessor.process(ReadActionProcessor.java:25)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.lambda$processCandidates$17(PsiSearchHelperImpl.java:899)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.lambda$processVirtualFile$10(PsiSearchHelperImpl.java:535)
	at com.intellij.openapi.application.impl.ApplicationImpl.tryRunReadAction(ApplicationImpl.java:1091)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.processVirtualFile(PsiSearchHelperImpl.java:515)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.lambda$processPsiFileRoots$7(PsiSearchHelperImpl.java:392)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.lambda$processFilesConcurrentlyDespiteWriteActions$8(PsiSearchHelperImpl.java:465)
	at com.intellij.openapi.application.impl.ReadMostlyRWLock.executeByImpatientReader(ReadMostlyRWLock.java:167)
	at com.intellij.openapi.application.impl.ApplicationImpl.executeByImpatientReader(ApplicationImpl.java:178)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.lambda$processFilesConcurrentlyDespiteWriteActions$9(PsiSearchHelperImpl.java:464)
	at com.intellij.concurrency.JobLauncherImpl.lambda$processImmediatelyIfTooFew$2(JobLauncherImpl.java:142)
	at com.intellij.openapi.progress.impl.CoreProgressManager.registerIndicatorAndRun(CoreProgressManager.java:688)
	at com.intellij.openapi.progress.impl.CoreProgressManager.executeProcessUnderProgress(CoreProgressManager.java:634)
	at com.intellij.openapi.progress.impl.ProgressManagerImpl.executeProcessUnderProgress(ProgressManagerImpl.java:64)
	at com.intellij.concurrency.JobLauncherImpl.lambda$processImmediatelyIfTooFew$3(JobLauncherImpl.java:138)
	at com.intellij.openapi.application.impl.ApplicationImpl.runReadAction(ApplicationImpl.java:814)
	at com.intellij.concurrency.JobLauncherImpl.processImmediatelyIfTooFew(JobLauncherImpl.java:149)
	at com.intellij.concurrency.JobLauncherImpl.invokeConcurrentlyUnderProgress(JobLauncherImpl.java:45)
	at com.intellij.concurrency.JobLauncher.invokeConcurrentlyUnderProgress(JobLauncher.java:49)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.processFilesConcurrentlyDespiteWriteActions(PsiSearchHelperImpl.java:481)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.processPsiFileRoots(PsiSearchHelperImpl.java:389)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.processCandidates(PsiSearchHelperImpl.java:894)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.processGlobalRequests(PsiSearchHelperImpl.java:864)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.processGlobalRequestsOptimized(PsiSearchHelperImpl.java:830)
	at com.intellij.psi.impl.search.PsiSearchHelperImpl.processRequests(PsiSearchHelperImpl.java:755)
	at com.intellij.psi.search.SearchRequestQuery.processResults(SearchRequestQuery.java:24)
	at com.intellij.util.AbstractQuery.doProcessResults(AbstractQuery.java:91)
	at com.intellij.util.AbstractQuery.delegateProcessResults(AbstractQuery.java:108)
	at com.intellij.util.MergeQuery.processResults(MergeQuery.java:22)
	at com.intellij.util.AbstractQuery.doProcessResults(AbstractQuery.java:91)
	at com.intellij.util.AbstractQuery.delegateProcessResults(AbstractQuery.java:108)
	at com.intellij.util.UniqueResultsQuery.processResults(UniqueResultsQuery.java:39)
	at com.intellij.util.AbstractQuery.doProcessResults(AbstractQuery.java:91)
	at com.intellij.util.AbstractQuery.forEach(AbstractQuery.java:83)
	at com.intellij.util.AbstractQuery.findAll(AbstractQuery.java:28)
	at com.intellij.util.Query.iterator(Query.java:129)
	at com.intellij.util.AbstractQuery.iterator(AbstractQuery.java:39)
	at io.ktor.ide.KtorUrlReferenceContributor$Companion.getParentUrlPaths(KtorUrlReferenceContributor.kt:370)
	at io.ktor.ide.KtorUrlReferenceContributor$Companion.getParentUrlPaths$default(KtorUrlReferenceContributor.kt:120)
	at io.ktor.ide.KtorUrlReferenceContributor$Companion.getParentUrlPaths(KtorUrlReferenceContributor.kt:191)
	at io.ktor.ide.KtorUrlReferenceContributor$Companion.getParentUrlPaths$default(KtorUrlReferenceContributor.kt:120)
	at io.ktor.ide.KtorUrlReferenceContributor$Companion.calculateUrlPathContext(KtorUrlReferenceContributor.kt:85)
	at io.ktor.ide.KtorUrlReferenceContributor$registerServerReferenceProvider$1$injector$1.invoke(KtorUrlReferenceContributor.kt:232)
	at io.ktor.ide.KtorUrlReferenceContributor$registerServerReferenceProvider$1$injector$1.invoke(KtorUrlReferenceContributor.kt:22)
	at com.intellij.microservices.url.references.UrlPathReferenceInjector$buildReferences$1.rootContext(UrlPathReferenceInjector.kt:128)
	at com.intellij.microservices.url.references.UrlPathReferenceInjector$buildReferences$1.forPsiElement(UrlPathReferenceInjector.kt:136)
	at io.ktor.ide.KtorUrlReferenceContributor$registerServerReferenceProvider$1.invoke(KtorUrlReferenceContributor.kt:238)
	at io.ktor.ide.KtorUrlReferenceContributor$registerServerReferenceProvider$1.invoke(KtorUrlReferenceContributor.kt:22)
	at com.intellij.psi.UastReferenceRegistrar$uastReferenceProvider$1.getReferencesByElement(UastReferenceRegistrar.kt:54)
[...]

Override flag to auto-suggest imports for Ktor modules

Add EP to Kotlin/Idea to prioritise a list of Ktor imports in case of ambiguity if the flag is enabled

Creating Ktor run configuration for module progress doesn't stop

Testing in IDE: Action to generate tests for given Ktor routes

Server

Netty: server freezes after start error

Occasionally empty response using Netty + Jackson

https://youtrack.jetbrains.com/issue/KTOR-1973

Ktor 1.5.0 When you use netty + jackson content negotiation, couple of times in 10k requests you will have 200 with empty response. manual jackson mapping, or string response work properly. Also on jetty works properly(but you can see socket timeout instead of empty response)

gradle:

plugins {
    id 'org.jetbrains.kotlin.jvm' version '1.4.21'
}

group 'org.example'
version '1.0-SNAPSHOT'

repositories {
    mavenCentral()
}

dependencies {
    implementation "org.jetbrains.kotlin:kotlin-stdlib"
    implementation("com.squareup.okhttp3:okhttp:4.9.0")
    implementation("io.ktor:ktor-server-netty:1.5.0")
    implementation("io.ktor:ktor-jackson:1.5.0")
}

server

import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
import io.ktor.application.call
import io.ktor.application.install
import io.ktor.features.ContentNegotiation
import io.ktor.http.ContentType
import io.ktor.jackson.JacksonConverter
import io.ktor.response.respond
import io.ktor.routing.get
import io.ktor.routing.routing
import io.ktor.server.engine.embeddedServer
import io.ktor.server.netty.Netty
import kotlinx.coroutines.delay
import java.util.UUID
import java.util.UUID.randomUUID

fun main() {
    embeddedServer(Netty, 8081) {
        install(ContentNegotiation) {
            register(ContentType.Application.Json, JacksonConverter(objectmapper = jacksonObjectMapper()))
        }
        routing {
            get("/json") {
                delay(10)
                call.respond(Response(randomUUID()))
            }
        }
    }.start(wait = true)
}

data class Response(
    val id: UUID
)

client

import kotlinx.coroutines.Dispatchers.IO
import kotlinx.coroutines.async
import kotlinx.coroutines.isActive
import kotlinx.coroutines.runBlocking
import kotlinx.coroutines.supervisorScope
import kotlinx.coroutines.withContext
import okhttp3.OkHttpClient
import okhttp3.Request
import java.util.concurrent.atomic.AtomicLong

val counter: AtomicLong = AtomicLong()

val request: Request = Request.Builder()
    .url("http://localhost:8081/json")
    .build()

fun main(): Unit = runBlocking {
    val clients = (1..10).map { it to OkHttpClient() }

    withContext(IO) {
        supervisorScope {
            clients.map { (idx, client) ->
                async {
                    while (isActive) {
                        val r = runCatching {
                            client.newCall(request).execute()
                        }
                        if ((r.getOrNull()?.body?.string() ?: "").isBlank()) {
                            println("$idx: I'm blank on ${counter.get()} try ${r.getOrNull()}")
                        }
                        if (counter.incrementAndGet() % 10000L == 0L) {
                            println("$idx: OK on ${counter.get()} try")
                        }
                    }
                }
            }
        }
    }
}

Example of log:

7: I'm blank on 8299 try Response{protocol=http/1.1, code=200, message=OK, url=http://localhost:8081/json}
2: OK on 10000 try
5: I'm blank on 10620 try Response{protocol=http/1.1, code=200, message=OK, url=http://localhost:8081/json}
6: I'm blank on 16593 try Response{protocol=http/1.1, code=200, message=OK, url=http://localhost:8081/json}
10: OK on 20000 try
8: I'm blank on 21634 try Response{protocol=http/1.1, code=200, message=OK, url=http://localhost:8081/json}
1: I'm blank on 22057 try Response{protocol=http/1.1, code=200, message=OK, url=http://localhost:8081/json}
7: I'm blank on 22574 try Response{protocol=http/1.1, code=200, message=OK, url=http://localhost:8081/json}
9: I'm blank on 27737 try Response{protocol=http/1.1, code=200, message=OK, url=http://localhost:8081/json}
5: I'm blank on 27759 try Response{protocol=http/1.1, code=200, message=OK, url=http://localhost:8081/json}
10: OK on 30000 try
...

call.respond() will not check or apply ContentNegotiation for some types

route("{...}") stopped matching root

Routing: Add PutTyped and PatchTyped Overload

Support for Compression Extensions for WebSocket (RFC 7692)

https://youtrack.jetbrains.com/issue/KTOR-688

This issue was imported from GitHub issue: https://github.com/ktorio/ktor/issues/907

Origin Problem

It would be very useful if ktor-websockets gained support for Compression Extensions for WebSocket, as defined in RFC 7692. The WebSocket Subprotocol "ocpp2.0" (Open Charge Point Protocol version 2.0) requires this feature to be implemented at the server-side, specifically using the DEFLATE algorithm, which is included as the "permessage-deflate" extension in section 7 of the aforementioned RFC.

I guess there's probably a way to manually implement the handling of DEFLATE (de)compression according to this extension in application code on top of Ktor, but it would be much nicer if Ktor would gain integrated and transparent support for this extension in its WebSocket functionality, so this would work out of the box without requiring any application-specific programming.

Thank you in advance for considering this feature.

Proposed solution

We make the API for implementation and usage of the WebSocket extensions:

Using WebSocket extensions

Installation

To install and configure the extensions we provide 2 methods: extensions and install which can be used in the following way:

install(WebSockets) {
    extensions { /* WebSocketExtensionConfig.() -> Unit */
        install(MyWebSocketExtension) { /* MyWebSocketExtensionConfig.() -> Unit */
        /* Optional extension configuration. */ 
        }
    }
}

The extensions are used in order of installation. This way looks familiar to existing features installation API and works for client and server in the same way.

Check if an extension is in use

All installed extensions go through the negotiation process and only negotiated extensions are used for the request. We introduce WebSocketSession.extensions: : List<WebSocketExtension<*>> property with list of all extensions used by for the current session.

There are 2 methods to check if the extension is in use: WebSocketSession.extension and WebSocketSession.extensionOrNull:

webSocket("/echo") {
    val myExtension = extension(MyWebSocketException) // will throw if `MyWebSocketException` is not negotiated
    // or
    val myExtension = extensionOrNull(MyWebSocketException) ?: close() // will close the session if `MyWebSocketException` is not negotiated
}

This API is similar to the Ktor feature discovery with the feature(...) method.

Implementing new extension

There are 2 interfaces for implementing new extension: WebSocketExtension<ConfigType: Any> and WebSocketExtensionFactory<ConfigType : Any, ExtensionType : WebSocketExtension<ConfigType>>. The new extension can be made by implementing all of them. The single implementation is working for client and server as well.

Here is the example of how the simple frame logging extension can be implemented:

class FrameLoggerExtension(val logger: Logger) : WebSocketExtension<FrameLogger.Config> {

The feature has 2 groups of fields and methods. The first group is for extension negotiation:

    /** List of protocols will be send in client request for negotiation **/
    override val protocols: List<WebSocketExtensionHeader> = emptyList()
   
    /** 
      * This method will be called for the server and will process `requestedProtocols` from a client.
      * In the result it will return a list of extensions that the server agrees to use.
      */
    override fun serverNegotiation(requestedProtocols: List<WebSocketExtensionHeader>): List<WebSocketExtensionHeader> {
        logger.log("Server negotiation")
        return emptyList()
    }

    /**
      * This method will be called on the client with a list of protocols, produced by `serverNegotiation`. It will decide if these extensions should be used. 
      */ 
    override fun clientNegotiation(negotiatedProtocols: List<WebSocketExtensionHeader>): Boolean {
        logger.log("Client negotiation")
        return true
    }

The second group is the place for actual frame processing. Methods will take the frame and produce a new processed frame if necessary:

    override fun processOutgoingFrame(frame: Frame): Frame {
        logger.log("Process outgoing frame: $frame")
        return frame
    }

    override fun processIncomingFrame(frame: Frame): Frame {
        logger.log("Process incoming frame: $frame")
        return frame
    }

There are also some implementation details: the feature has Config and reference to the origin `factory.

    class Config {
        lateinit var logger: Logger
    }

    /**
    * Factory which can create current extension instance. 
    */
    override val factory: WebSocketExtensionFactory<Config, FrameLogger> = FrameLoggerExtension

The factory is usually implemented in companion object(similar to regular features):

    companion object : WebSocketExtensionFactory<Config, FrameLogger> {
        /* Key to discover installed extension instance */
        override val key: AttributeKey<FrameLogger> = AttributeKey("frame-logger")

        /** Occupied rsv bits.
         * If the extension occupies a bit, it can't be used in other installed extensions. We use that bits to prevent feature conflicts(prevent installing multiple compression features). If you implementing a feature using some RFC, rsv occupied bits should be referenced there.
         */
        override val rsv1: Boolean = true

       /** Create feture instance. Will be called for each WebSocket session **/
        override fun install(config: Config.() -> Unit): FrameLogger {
            return FrameLogger(Config().apply(config).logger)
        }
    }
}

Status

This API is implemented in the ws-extensions branch. It marked with @ExperimentalWebSocketExtensionsApiannotation with the level error until we agree on the final design.

Other

Update Kotlin and Serialization Versions

Deprecate TestApplicationCall.requestHandled

aSocket().bind() sometimes throws Already bound SocketException

https://youtrack.jetbrains.com/issue/KTOR-638

This issue was imported from GitHub issue: https://github.com/ktorio/ktor/issues/1049

Ktor Version

1.1.3

Ktor Engine Used

Netty, Socket

JVM Version, Operating System and Relevant Context

openjdk version "10.0.2" 2018-07-17, Ubuntu 18.04.2 LTS

Feedback

It's hard to reproduce, the problem appears and disappears without observable reasons. I have a server starting two Netty instances and one UDP socket

fun Application.main() {
    embeddedServer(Netty, port = 18080) {
        routing {
            get("/") {
                call.respondText("Hello World from what is supposed to be WWW server!", ContentType.Text.Plain)
            }
        }
    }.start()
    embeddedServer(Netty, port = 18090) {
        routing {
            get("/") {
                call.respondText("Hello World from what is supposed to be RESt server!", ContentType.Text.Plain)
            }
        }
    }.start()
    runBlocking {
        org.looksworking.ha.controller.Application.logger.info("Starting UDP")
        val server = aSocket(ActorSelectorManager(Dispatchers.IO))
            .udp()
            .bind(InetSocketAddress("0.0.0.0", 18070))
        while (true) {
            println(server.incoming.receive().packet.readText())
        }
    }
}

Console output:

...
Starting UDP
Exception in thread "main" java.lang.reflect.InvocationTargetException
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:564)
	at kotlin.reflect.jvm.internal.calls.CallerImpl$Method.callMethod(CallerImpl.kt:97)
	at kotlin.reflect.jvm.internal.calls.CallerImpl$Method$Static.call(CallerImpl.kt:106)
	at kotlin.reflect.jvm.internal.KCallableImpl.call(KCallableImpl.kt:106)
	at kotlin.reflect.jvm.internal.KCallableImpl.callDefaultMethod$kotlin_reflect_api(KCallableImpl.kt:152)
	at kotlin.reflect.jvm.internal.KCallableImpl.callBy(KCallableImpl.kt:110)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.callFunctionWithInjection(ApplicationEngineEnvironmentReloading.kt:349)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.executeModuleFunction(ApplicationEngineEnvironmentReloading.kt:299)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.instantiateAndConfigureApplication(ApplicationEngineEnvironmentReloading.kt:275)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.createApplication(ApplicationEngineEnvironmentReloading.kt:127)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.start(ApplicationEngineEnvironmentReloading.kt:247)
	at io.ktor.server.netty.NettyApplicationEngine.start(NettyApplicationEngine.kt:106)
	at io.ktor.server.netty.NettyApplicationEngine.start(NettyApplicationEngine.kt:18)
	at io.ktor.server.engine.ApplicationEngine$DefaultImpls.start$default(ApplicationEngine.kt:52)
	at io.ktor.server.netty.EngineMain.main(EngineMain.kt:17)
Caused by: java.net.SocketException: Already bound
	at java.base/sun.nio.ch.Net.translateToSocketException(Net.java:136)
	at java.base/sun.nio.ch.DatagramSocketAdaptor.bind(DatagramSocketAdaptor.java:93)
	at io.ktor.network.sockets.UDPSocketBuilder.bind(Builders.kt:150)
	at io.ktor.network.sockets.UDPSocketBuilder.bind$default(Builders.kt:141)
	at org.looksworking.ha.controller.AppKt$main$3.invokeSuspend(App.kt:44)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:32)
	at kotlinx.coroutines.DispatchedTask.run(Dispatched.kt:233)
	at kotlinx.coroutines.EventLoopImplBase.processNextEvent(EventLoop.kt:116)
	at kotlinx.coroutines.BlockingCoroutine.joinBlocking(Builders.kt:76)
	at kotlinx.coroutines.BuildersKt__BuildersKt.runBlocking(Builders.kt:53)
	at kotlinx.coroutines.BuildersKt.runBlocking(Unknown Source)
	at kotlinx.coroutines.BuildersKt__BuildersKt.runBlocking$default(Builders.kt:35)
	at kotlinx.coroutines.BuildersKt.runBlocking$default(Unknown Source)
	at org.looksworking.ha.controller.AppKt.main(App.kt:38)
	... 18 more
Caused by: java.nio.channels.AlreadyBoundException
	at java.base/sun.nio.ch.DatagramChannelImpl.bind(DatagramChannelImpl.java:669)
	at java.base/sun.nio.ch.DatagramSocketAdaptor.bind(DatagramSocketAdaptor.java:91)
	... 30 more

I checked many times - no other instance is running, no ports are busy. At the same time, tcp ports are successfully taken, while this problem with udp socket sometimes persists even after reboot. And then just goes away without any changes. Is it possible that like in most upvoted answer here, ktor sometimes creates an already bound socket?