Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for runOnce (0.05 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

       */
      fun schedule(
        name: String,
        delayNanos: Long = 0L,
        block: () -> Long,
      ) {
        schedule(
          object : Task(name) {
            override fun runOnce(): Long = block()
          },
          delayNanos,
        )
      }
    
      /**
       * Executes [block] once on a task runner thread.
       *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

      private val cleanupTask =
        object : Task("$okHttpName ConnectionPool connection closer") {
          override fun runOnce(): Long = closeConnections(System.nanoTime())
        }
    
      private fun AddressState.scheduleOpener() {
        queue.schedule(
          object : Task("$okHttpName ConnectionPool connection opener") {
            override fun runOnce(): Long = openConnections(this@scheduleOpener)
          },
        )
      }
    
      /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

            try {
              while (true) {
                currentThread.name = task.name
                val delayNanos =
                  logger.logElapsed(task, task.queue!!) {
                    task.runOnce()
                  }
    
                // A task ran successfully. Update the execution state and take the next task.
                task = withLock {
                  afterRun(task, delayNanos, true)
                  awaitTaskToRun()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      )
    
      internal class Close(
        val code: Int,
        val reason: ByteString?,
        val cancelAfterCloseMillis: Long,
      )
    
      private inner class WriterTask : Task("$name writer") {
        override fun runOnce(): Long {
          try {
            if (writeOneFrame()) return 0L
          } catch (e: IOException) {
            failWebSocket(e = e, isWriter = true)
          }
          return -1L
        }
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

       */
      private var nextSequenceNumber: Long = 0
    
      private val cleanupQueue = taskRunner.newQueue()
      private val cleanupTask =
        object : Task("$okHttpName Cache") {
          override fun runOnce(): Long {
            synchronized(this@DiskLruCache) {
              if (!initialized || closed) {
                return -1L // Nothing to do.
              }
    
              try {
                trimToSize()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.32.md

    - Removed support for the kubelet `--runonce` mode.
      If you specify the kubelet command line flag `--runonce`, this is an error.
      Setting `runOnce` in a kubelet configuration file is also an error, and specifying any
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Aug 13 14:49:49 UTC 2025
    - 412.3K bytes
    - Viewed (0)
Back to top