Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for Tasks (0.12 sec)

  1. samples/tlssurvey/build.gradle.kts

      implementation("com.squareup.retrofit2:converter-moshi:2.11.0")
      implementation(libs.squareup.moshi)
      implementation(libs.squareup.moshi.kotlin)
    
      ksp("com.squareup.moshi:moshi-kotlin-codegen:1.15.1")
    }
    
    tasks.compileJava {
      options.isWarnings = false
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 08 02:48:17 GMT 2024
    - 617 bytes
    - Viewed (0)
  2. build.gradle.kts

    import com.vanniktech.maven.publish.SonatypeHost
    import java.net.URI
    import kotlinx.validation.ApiValidationExtension
    import org.gradle.api.tasks.testing.logging.TestExceptionFormat
    import org.jetbrains.dokka.gradle.DokkaTaskPartial
    import org.jetbrains.kotlin.gradle.dsl.kotlinExtension
    import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
    import ru.vyarus.gradle.plugin.animalsniffer.AnimalSnifferExtension
    
    buildscript {
      dependencies {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 18 01:32:42 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

        BeforeOtherTasks,
    
        /** Resumes after the already-enqueued tasks. */
        AfterEnqueuedTasks,
    
        /** Resumes after all other tasks, including tasks enqueued while yielding. */
        AfterOtherTasks,
      }
    
      /** Returns the task that was started, or null if there were no tasks to start. */
      private fun startNextTask(): SerialTask? {
        taskRunner.assertThreadHoldsLock()
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 12.6K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

        val name = lock.withLock { nextQueueName++ }
        return TaskQueue(this, "Q$name")
      }
    
      /**
       * Returns a snapshot of queues that currently have tasks scheduled. The task runner does not
       * necessarily track queues that have no tasks scheduled.
       */
      fun activeQueues(): List<TaskQueue> {
        lock.withLock {
          return busyQueues + readyQueues
        }
      }
    
      fun cancelAll() {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  5. container-tests/build.gradle.kts

    plugins {
      kotlin("jvm")
    }
    
    val platform = System.getProperty("okhttp.platform", "jdk9")
    val testJavaVersion = System.getProperty("test.java.version", "21").toInt()
    
    tasks.withType<Test> {
      useJUnitPlatform()
      onlyIf("By default not in CI") {
        System.getenv("CI") == null
          || (project.hasProperty("containerTests") && project.property("containerTests").toString().toBoolean())
      }
    
      jvmArgs(
        "-Dokhttp.platform=$platform",
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Mar 17 14:46:34 GMT 2024
    - 1.1K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

         * Since we can't ACK settings on the current reader thread (the reader thread can't write) we
         * execute all peer settings logic on the writer thread. This relies on the fact that the
         * writer task queue won't reorder tasks; otherwise settings could be applied in the opposite
         * order than received.
         */
        fun applyAndAckSettings(
          clearPrevious: Boolean,
          settings: Settings,
        ) {
          var delta: Long
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 32.6K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

      private val taskFaker = TaskFaker()
      private val taskRunner = taskFaker.taskRunner
    
      /**
       * Note that we don't use the same [TaskFaker] for this factory. That way off-topic tasks like
       * connection pool maintenance tasks don't add noise to route planning tests.
       */
      private val routePlanner = FakeRoutePlanner(taskFaker = taskFaker)
      private val finder = FastFallbackExchangeFinder(routePlanner, taskRunner)
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt

          "FINE: Q10000 scheduled after 100 µs: task one",
          "FINE: Q10000 scheduled after 200 µs: task two",
        )
      }
    
      /**
       * We don't track the active task in scheduled tasks. This behavior might be a mistake, but it's
       * cumbersome to implement properly because the active task might be a cancel.
       */
      @Test fun scheduledTasksDoesNotIncludeRunningTask() {
        val task =
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 23K bytes
    - Viewed (0)
Back to top