kotlinx-rpc
kotlinx-rpc copied to clipboard
Memory leak
trafficstars
Describe the bug
The RPC services are leaking memory. In the example below the Args and Response objects are never cleared by the GC.
To Reproduce Steps to reproduce the behavior:
Example code:
@Serializable
data class Args(val name: String)
@Serializable
data class Response(val response: String)
interface TestService : RPC {
suspend fun test(args: Args): Response
}
object TestServer {
class TestServiceImpl(override val coroutineContext: CoroutineContext) : TestService {
override suspend fun test(args: Args): Response {
return Response("Hello ${args.name} back")
}
}
@JvmStatic
fun main(args: Array<String>) {
embeddedServer(
Netty,
host = "0.0.0.0",
port = 1337
) {
install(RPC) {
serialization {
json()
}
}
routing {
rpc("/test") {
registerService<TestService> { ctx -> TestServiceImpl(ctx) }
}
}
}.start(true)
}
}
object TestClient {
@JvmStatic
fun main(args: Array<String>) {
runBlocking {
val ktorClient = HttpClient(CIO) {
install(WebSockets)
}
val client = ktorClient.rpc {
url {
host = "0.0.0.0"
port = 1337
encodedPath = "/test"
}
rpcConfig {
serialization {
json()
}
}
}
val service = client.withService<TestService>()
var i = 0
while (true) {
val response = service.test(Args("Name #${i++}"))
println(response)
delay(1)
}
}
}
}
Expected behavior No memory leaks
Additional context
Inspected with VisualVM, even after the GC Args and Response objects stay in the memory and the process eventually throws OutOfMemory
Hey, @ponktacology ! I tried reproducing the leak scenario, but was not able to do so, checked as well with the visual VM. Can you, please, provide a git repo and exact steps to reproduce it?