}
}

internal
abstract class AddOpensArgumentProvider : CommandLineArgumentProvider {
    @get:Input
    abstract val jvmVersion: Property<Int>

    @get:Input
    abstract val unitTest: Property<Boolean>

    @get:Input
    abstract val embedded: Property<Boolean>

    override fun asArguments(): Iterable<String> =
        JpmsConfiguration.forDaemonProcesses(jvmVersion.get(), true)
}

import org.gradle.api.reflect.TypeOf
import org.gradle.kotlin.dsl.*


internal
val CtClass.isKotlin: Boolean
    get() = hasAnnotation(Metadata::class.qualifiedName)


internal
val CtMethod.isSynthetic
    get() = methodInfo.getAttribute(SyntheticAttribute.tag) != null


internal
val MemberValue.intValue: Int
    get() {
        var value: Int? = null

class DevServer {
  val handshakeCertificates = TlsUtil.localhost()

  val server =
    MockWebServer().apply {
      useHttps(handshakeCertificates.sslSocketFactory(), false)

      enqueue(
        MockResponse()
          .setResponseCode(HTTP_MOVED_TEMP)
          .setHeader("Location", "https://www.google.com/robots.txt"),
      )
    }

  val clientCertificates =
    HandshakeCertificates

import java.io.IOException
import okhttp3.OkHttpClient
import okhttp3.Request

class ParseResponseWithMoshi {
  private val client = OkHttpClient()
  private val moshi = Moshi.Builder().build()
  private val gistJsonAdapter = moshi.adapter(Gist::class.java)

  fun run() {
    val request =
      Request
        .Builder()
        .url("https://api.github.com/gists/c2a7c39532239ff261be")
        .build()

/** A simple index that of trusted root certificates that have been loaded into memory. */
class BasicTrustRootIndex(
  vararg caCerts: X509Certificate,
) : TrustRootIndex {
  private val subjectToCaCerts: Map<X500Principal, Set<X509Certificate>>

  init {
    val map = mutableMapOf<X500Principal, MutableSet<X509Certificate>>()
    for (caCert in caCerts) {
      map.getOrPut(caCert.subjectX500Principal) { mutableSetOf() }.add(caCert)
    }

import org.junit.jupiter.api.extension.RegisterExtension

class WebSocketWriterTest {
  private val data = Buffer()
  private val random = Random(0)

  /**
   * Check all data as verified inside of the test. We do this in an AfterEachCallback so that
   * exceptions thrown from the test do not cause this check to fail.
   */
  @RegisterExtension
  val noDataLeftBehind =
    AfterEachCallback { context: ExtensionContext ->

        resolutionStrategy.capabilitiesResolution.all {
            selectHighestVersion()
        }
    }
}

fun readCapabilitiesFromJson() {
    val capabilitiesFile = repoRoot().file("gradle/dependency-management/capabilities.json").asFile
    val capabilities: List<CapabilitySpec> = readCapabilities(capabilitiesFile)
    capabilities.forEach {
        it.configure(dependencies.components, configurations)
    }
}

     *
     * @param val The string to be interpolated.
     * @param callback The function to resolve variable values.
     * @return The interpolated string, or null if the input was null.
     */
    @Nullable
    default String interpolate(@Nullable String val, @Nullable UnaryOperator<String> callback) {
        return interpolate(val, callback, false);
    }

    /**

 */
class RealConnection internal constructor(
  val taskRunner: TaskRunner,
  val connectionPool: RealConnectionPool,
  override val route: Route,
  /** The low-level TCP socket. */
  private val rawSocket: JavaNetSocket,
  /**
   * The application layer socket. Either an [SSLSocket] layered over [rawSocket], or [rawSocket]
   * itself if this connection does not use SSL.
   */
  private val javaNetSocket: JavaNetSocket,

}

func (t *Cache[T]) update(ctx context.Context) error {
	val, err := t.updateFn(ctx)
	if err != nil {
		if t.opts.ReturnLastGood && t.val.Load() != nil {
			// Keep last good value, so update
			// does not return an error.
			return nil
		}
		return err
	}

	t.val.Store(&val)
	t.lastUpdateMs.Store(time.Now().UnixMilli())
	return nil