-
Notifications
You must be signed in to change notification settings - Fork 1.1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
KTOR-2036 Fix CIO connection limit #3140
Conversation
ca58c55
to
4156899
Compare
Please check CI |
4156899
to
01c2830
Compare
@rsinukov fixed. The test was broken itself |
return try { | ||
aSocket(selector).tcpNoDelay().tcp().connect(address, configuration) | ||
} catch (cause: Throwable) { | ||
// a failure or cancellation | ||
semaphore.release() | ||
limit.release() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
should you release addressLimit
here too?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
yep, thanks
01c2830
to
0252f21
Compare
@e5l any chance that the fix could be backported to 2.0.x? We are using ktor in a Gradle plugin and cannot update to 2.1.x yet because it needs Kotlin 1.7. |
It should be possible to use this version with old Kotlin. Could you check and file an issue if it doesn't work? |
Fix KTOR-2036