Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 14 for observers (0.08 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

         *   to decrease request latency, but these connections will occasionally time out.
         *
         * * **Unreachable proxy servers.** A [ProxySelector] can be used to
         *   attempt multiple proxy servers in sequence, eventually falling back to a direct
         *   connection.
         *
         * Set this to false to avoid retrying requests when doing so is destructive. In this case the
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 51.4K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

          )
        peer.sendFrame().headers(true, 2, expectedResponseHeaders)
        peer.sendFrame().data(true, 3, data(0), 0)
        peer.play()
        val observer = RecordingPushObserver()
    
        // Play it back.
        val connection = connect(peer, observer, Http2Connection.Listener.REFUSE_INCOMING_STREAMS)
        val client = connection.newStream(headerEntries("b", "banana"), false)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 75.5K bytes
    - Click Count (0)
  3. docs/changelogs/changelog_3x.md

    ## Version 3.7.0
    
    _2017-04-15_
    
     *  **OkHttp no longer recovers from TLS handshake failures by attempting a TLSv1 connection.**
        The fallback was necessary for servers that implemented version negotiation incorrectly. Now
        that 99.99% of servers do it right this fallback is obsolete.
     *  Fix: Do not honor cookies set on a public domain. Previously a malicious site could inject
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 06 14:55:54 GMT 2022
    - 50.8K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/Futures.java

      //    (hypothetical) unsafe read by our caller. Note: adding 'volatile' does not fix this issue,
      //    it would just add an edge such that if done() observed non-null, then it would also
      //    definitely observe all earlier writes, but we still have no guarantee that done() would see
      //    the initial write (just stronger guarantees if it does).
      //
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 64.3K bytes
    - Click Count (0)
  5. CHANGELOG/CHANGELOG-1.3.md

    * Make addon-manager cross-platform and use it with hyperkube ([#25631](https://github.com/kubernetes/kubernetes/pull/25631), [@luxas](https://github.com/luxas))
    * kubelet: Optionally, have kubelet exit if lock file contention is observed, using --exit-on-lock-contention flag ([#25596](https://github.com/kubernetes/kubernetes/pull/25596), [@derekparker](https://github.com/derekparker))
    Created: Fri Dec 26 09:05:12 GMT 2025
    - Last Modified: Thu Dec 24 02:28:26 GMT 2020
    - 84K bytes
    - Click Count (0)
  6. docs/metrics/prometheus/grafana/minio-dashboard.json

              "intervalFactor": 1,
              "legendFormat": "",
              "metric": "process_start_time_seconds",
              "refId": "A",
              "step": 60
            }
          ],
          "title": "Total Online Servers",
          "type": "stat"
        },
        {
          "datasource": {
            "type": "prometheus",
            "uid": "${DS_PROMETHEUS}"
          },
          "fieldConfig": {
            "defaults": {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Aug 04 01:46:49 GMT 2025
    - 93.1K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

          }
    
          return value;
        }
    
        /**
         * Performs routine cleanup following a read. Normally cleanup happens during writes, or from
         * the cleanupExecutor. If cleanup is not observed after a sufficient number of reads, try
         * cleaning up from the read thread.
         */
        void postReadCleanup() {
          if ((readCount.incrementAndGet() & DRAIN_THRESHOLD) == 0) {
            runCleanup();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 89.9K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/cache/CacheBuilder.java

       * table is internally partitioned to try to permit the indicated number of concurrent updates
       * without contention. Because assignment of entries to these partitions is not necessarily
       * uniform, the actual concurrency observed may vary. Ideally, you should choose a value to
       * accommodate as many threads as will ever concurrently modify the table. Using a significantly
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 51.9K bytes
    - Click Count (0)
  9. docs/bucket/notifications/README.md

    > ```
    >
    > These are now deprecated, if you plan to upgrade to any releases after _RELEASE.2020-04-10T03-34-42Z_ make sure
    > to migrate to only using _connection_string_ option. To migrate, once you have upgraded all the servers use the
    > following command to update the existing notification targets.
    >
    > ```
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 84.2K bytes
    - Click Count (0)
  10. cmd/erasure-server-pool.go

    // disk failures are not returned.
    func (z *erasureServerPools) deleteAll(ctx context.Context, bucket, prefix string) {
    	for _, servers := range z.serverPools {
    		for _, set := range servers.sets {
    			set.deleteAll(ctx, bucket, prefix)
    		}
    	}
    }
    
    var listBucketsCache = cachevalue.New[[]BucketInfo]()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
Back to Top