MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-03-22 15:19:59 +07:00
Code Issues Packages Projects Releases Wiki Activity

[build scripts] JPS Caches: retry file presense checks on a remote server

Browse Source 
(cherry picked from commit 6c6e42fb23d2d341469be71200309aaac2a1c418)

IJ-CR-158277

GitOrigin-RevId: d47f81cd44e6b4ca8cf6e49abd0fdacb5f9bfb68
This commit is contained in:
Vladislav Rassokhin
2025-03-24 22:07:49 +01:00
committed by intellij-monorepo-bot
parent 06f7c37aec
commit 040ea10937
1 changed files with 21 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
platform/build-scripts/src/org/jetbrains/intellij/build/impl/compilation/PortableCompilationCacheUploader.kt
View File

@@ -1,18 +1,17 @@
// Copyright 2000-2024 JetBrains s.r.o. and contributors. Use of this source code is governed by the Apache 2.0 license.
// Copyright 2000-2025 JetBrains s.r.o. and contributors. Use of this source code is governed by the Apache 2.0 license.
@file:OptIn(ExperimentalPathApi::class)
package org.jetbrains.intellij.build.impl.compilation
import com.google.gson.stream.JsonReader
import io.netty.handler.codec.http.HttpResponseStatus
import io.netty.handler.codec.http.HttpStatusClass
import io.opentelemetry.api.common.AttributeKey
import io.opentelemetry.api.common.Attributes
import io.opentelemetry.api.trace.Span
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.launch
import kotlinx.coroutines.withContext
import org.jetbrains.intellij.build.BuildMessages
import org.jetbrains.intellij.build.CompilationContext
import org.jetbrains.intellij.build.forEachConcurrent
import org.jetbrains.intellij.build.*
import org.jetbrains.intellij.build.http2Client.Http2ClientConnection
import org.jetbrains.intellij.build.http2Client.ZstdCompressContextPool
import org.jetbrains.intellij.build.http2Client.upload
@@ -233,16 +232,24 @@ internal suspend fun checkExists(
urlPath: String,
logIfExists: Boolean = false,
): Boolean {
val status = connection.head(urlPath)
if (status == HttpResponseStatus.OK) {
// already exists
if (logIfExists) {
Span.current().addEvent("File $urlPath already exists on server, nothing to upload")
return retryWithExponentialBackOff {
when (val status = connection.head(urlPath)) {
HttpResponseStatus.OK -> {
// already exists
if (logIfExists) {
Span.current().addEvent("File $urlPath already exists on server, nothing to upload")
}
true
}
HttpResponseStatus.NOT_FOUND -> false
else -> {
Span.current().addEvent("unexpected response status for HEAD request", Attributes.of(AttributeKey.stringKey("status"), status.toString()))
val message = "unexpected response status for HEAD request: $status"
if (status.codeClass() == HttpStatusClass.SERVER_ERROR || status.code() == 420 || status.code() == 429)
throw IllegalStateException(message)
else
throw NoMoreRetriesException(message)
}
}
return true
}
else if (status != HttpResponseStatus.NOT_FOUND) {
Span.current().addEvent("unexpected response status for HEAD request", Attributes.of(AttributeKey.stringKey("status"), status.toString()))
}
return false
}