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

[starter][event bus] Retry on the same port

Browse Source 
GitOrigin-RevId: 0537784e4cd9cb25bc5718c63bb3744b14cfb746
This commit is contained in:
Maxim.Kolmakov
2024-07-12 14:45:12 +00:00
committed by intellij-monorepo-bot
parent 75f75c5b6b
commit 758638cabb
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/performanceTesting/event-bus/src/com/intellij/tools/ide/starter/bus/shared/client/LocalEventBusServerClient.kt
+8 -5
View File
@@ -32,13 +32,12 @@ class LocalEventBusServerClient(val server: LocalEventBusServer) : EventBusServe
return sendRequest("GET", endpoint, requestBody)
}
private fun sendRequest(method: String, endpoint: String, requestBody: String?): String {
private fun sendRequest(method: String, endpoint: String, requestBody: String?, retriesOnTheSamePort: Int = 0): String {
val url = URL("http://localhost:${server.port}/$endpoint")
val connection = url.openConnection() as HttpURLConnection
return try {
connection.requestMethod = method
connection.connectTimeout = 3000 // 3 seconds
connection.readTimeout = 10000 // 10 seconds
connection.connectTimeout = 1000 // 1 seconds
requestBody?.also { body ->
connection.doOutput = true
connection.setRequestProperty("Content-Type", "application/json")
@@ -58,8 +57,12 @@ class LocalEventBusServerClient(val server: LocalEventBusServer) : EventBusServe
}
}
catch (e: ConnectException) {
if (!server.updatePort()) throw e
sendRequest(method, endpoint, requestBody)
if (retriesOnTheSamePort < 3) {
sendRequest(method, endpoint, requestBody, retriesOnTheSamePort + 1)
} else {
if (!server.updatePort()) throw e
sendRequest(method, endpoint, requestBody, 0)
}
}
finally {
connection.disconnect()