Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for removeMap (0.08 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

      private fun startNextTask(): SerialTask? {
        taskRunner.assertThreadHoldsLock()
    
        val index = serialTaskQueue.indexOfFirst { it.isReady() }
        if (index == -1) return null
    
        val nextTask = serialTaskQueue.removeAt(index)
        currentTask = nextTask
        contextSwitchCount++
        nextTask.start()
        return nextTask
      }
    
      private interface SerialTask {
        /** Returns true if this task is ready to start. */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/HttpUrl.kt

          for (i in encodedQueryNamesAndValues!!.size - 2 downTo 0 step 2) {
            if (canonicalName == encodedQueryNamesAndValues!![i]) {
              encodedQueryNamesAndValues!!.removeAt(i + 1)
              encodedQueryNamesAndValues!!.removeAt(i)
              if (encodedQueryNamesAndValues!!.isEmpty()) {
                encodedQueryNamesAndValues = null
                return
              }
            }
          }
        }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 09 12:33:05 UTC 2024
    - 63.5K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

            "A connection to ${connection.route().address.url} was leaked. " +
              "Did you forget to close a response body?"
          Platform.get().logCloseableLeak(message, callReference.callStackTrace)
    
          references.removeAt(i)
    
          // If this was the last allocation, the connection is eligible for immediate eviction.
          if (references.isEmpty()) {
            connection.idleAtNs = now - keepAliveDurationNs
            return 0
          }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

        val connection = this.connection!!
        connection.lock.assertHeld()
    
        val calls = connection.calls
        val index = calls.indexOfFirst { it.get() == this@RealCall }
        check(index != -1)
    
        calls.removeAt(index)
        this.connection = null
    
        if (calls.isEmpty()) {
          connection.idleAtNs = System.nanoTime()
          if (connectionPool.connectionBecameIdle(connection)) {
            return connection.socket()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  5. src/cmd/cgo/gcc.go

    			fatalf("cannot load DWARF output from %s: %v", gccTmp(), err)
    		}
    		bo := f.ByteOrder
    		symtab, err := f.Symbols()
    		if err == nil {
    			// Check for use of -fsanitize=hwaddress (issue 53285).
    			removeTag := func(v uint64) uint64 { return v }
    			if goarch == "arm64" {
    				for i := range symtab {
    					if symtab[i].Name == "__hwasan_init" {
    						// -fsanitize=hwaddress on ARM
    						// uses the upper byte of a
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 18 15:07:34 UTC 2024
    - 97.1K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        val events = mutableListOf<Any>()
    
        @Synchronized fun takeEvent(): Any {
          while (events.isEmpty()) {
            wait()
          }
          return events.removeAt(0)
        }
    
        @Synchronized override fun onRequest(
          streamId: Int,
          requestHeaders: List<Header>,
        ): Boolean {
          assertThat(streamId).isEqualTo(2)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
Back to top