MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

[lsp] refactoring, move tcpClient/tcpConnection near tcpServer so the similar code is closer

Browse Source 
LSP-166

GitOrigin-RevId: 10692c5c5e651c9ce4a8d5cadca3af1e5c228606
This commit is contained in:
Ilya Kirillov
2025-06-18 09:39:04 +00:00
committed by intellij-monorepo-bot
parent 5c11c924ba
commit 5f919d88e1
1 changed files with 31 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
fleet/lsp.protocol/src/main/com/jetbrains/lsp/implementation/tcp.kt
+31 -8
View File
@@ -1,17 +1,11 @@
package com.jetbrains.lsp.implementation
import fleet.util.logging.logger
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.CoroutineStart
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.coroutineScope
import kotlinx.coroutines.launch
import kotlinx.coroutines.runInterruptible
import kotlinx.coroutines.supervisorScope
import kotlinx.coroutines.*
import java.io.InputStream
import java.io.OutputStream
import java.net.ServerSocket
import kotlin.io.use
import java.net.Socket
suspend fun tcpServer(port: Int = 0, server: suspend CoroutineScope.(InputStream, OutputStream) -> Unit) {
ServerSocket(port).use { serverSocket ->
@@ -37,4 +31,33 @@ suspend fun tcpServer(port: Int = 0, server: suspend CoroutineScope.(InputStream
}
}
/**
* VSC opens a **server** socket for LSP to connect to it.
*/
suspend fun tcpClient(port: Int, body: suspend CoroutineScope.(InputStream, OutputStream) -> Unit) {
val socket = runInterruptible(Dispatchers.IO) {
Socket("localhost", port)
}
socket.use {
coroutineScope {
body(socket.getInputStream(), socket.getOutputStream())
}
}
}
suspend fun tcpConnection(clientMode: Boolean, port: Int, body: suspend CoroutineScope.(InputStream, OutputStream) -> Unit) {
when {
clientMode -> {
tcpClient(port, body)
}
else -> {
tcpServer(port, body)
}
}
}
private val LOG = logger<LspClient>()