Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for Device (0.19 sec)

  1. docs/changelogs/changelog_4x.md

        line application hang after all of the work is done, it may be due to a non-daemon thread like
        this one.
     *  New: Include suppressed exceptions when all routes to a target service fail.
    
    
    ## Version 4.4.1
    
    _2020-03-08_
    
     *  Fix: Don't reuse a connection on redirect if certs match but DNS does not. For better
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

       * When we need a new thread to run tasks, we call [Backend.execute]. A few microseconds later we
       * expect a newly-started thread to call [Runnable.run]. We shouldn't request new threads until
       * the already-requested ones are in service, otherwise we might create more threads than we need.
       *
       * We use [executeCallCount] and [runCallCount] to defend against starting more threads than we
       * need. Both fields are guarded by [lock].
       */
    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)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

          throw AssertionError("Thread ${Thread.currentThread().name} MUST NOT hold lock on $this")
        }
      }
    
      val logger = Logger.getLogger("TaskFaker." + instance++)
    
      /** Though this executor service may hold many threads, they are not executed concurrently. */
      private val tasksExecutor = Executors.newCachedThreadPool(threadFactory("TaskFaker"))
    
      /**
    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/test/java/okhttp3/SocksProxy.kt

          Thread.currentThread().name = threadName
          try {
            while (true) {
              val socket = serverSocket!!.accept()
              connectionCount.incrementAndGet()
              service(socket)
            }
          } catch (e: SocketException) {
            logger.info("$threadName done accepting connections: ${e.message}")
          } catch (e: IOException) {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt

        assertThat(cache.size()).isEqualTo(10)
    
        // Cause the size to grow to 12 should evict 'A'.
        set("c", "c", "c")
        cache.flush()
        assertThat(cache.size()).isEqualTo(8)
        assertAbsent("a")
        assertValue("b", "bb", "bbbb")
        assertValue("c", "c", "c")
    
        // Causing the size to grow to 10 should evict nothing.
        set("d", "d", "d")
        cache.flush()
        assertThat(cache.size()).isEqualTo(10)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 15 14:55:09 GMT 2024
    - 75.8K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

          for (call in runningSyncCalls) {
            call.cancel()
          }
        }
      }
    
      /**
       * Promotes eligible calls from [readyAsyncCalls] to [runningAsyncCalls] and runs them on the
       * executor service. Must not be called with synchronization because executing calls can call
       * into user code.
       *
       * @return true if the dispatcher is currently running calls.
       */
      private fun promoteAndExecute(): Boolean {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 9K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

        override fun alternateService(
          streamId: Int,
          origin: String,
          protocol: ByteString,
          host: String,
          port: Int,
          maxAge: Long,
        ) {
          // TODO: register alternate service.
        }
      }
    
      /** Even, positive numbered streams are pushed streams in HTTP/2. */
      internal fun pushedStream(streamId: Int): Boolean = streamId != 0 && streamId and 1 == 0
    
      internal fun pushRequestLater(
    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)
  8. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

          }
    
          else -> {
            toEvict = null
            toEvictIdleAtNs = -1L
          }
        }
    
        when {
          toEvict != null -> {
            // We've chosen a connection to evict. Confirm it's still okay to be evicted, then close it.
            toEvict.withLock {
              if (toEvict.calls.isNotEmpty()) return 0L // No longer idle.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 16.2K bytes
    - Viewed (0)
Back to top