Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 273 for Reads (0.04 sec)

  1. android/guava/src/com/google/common/util/concurrent/Futures.java

          }
          return null;
        }
      }
    
      private static final class InCompletionOrderState<T extends @Nullable Object> {
        // A happens-before edge between the writes of these fields and their reads exists, because
        // in order to read these fields, the corresponding write to incompleteOutputCount must have
        // been read.
        private boolean wasCancelled = false;
        private boolean shouldInterrupt = true;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        @Synchronized
        override fun dispatch(request: RecordedRequest): MockResponse {
          // This guarantees a deterministic sequence when handling the canceled request:
          // 1. Server reads request and dequeues first response
          // 2. Client cancels request
          // 3. Server tries to send response on the canceled stream
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 67.4K bytes
    - Viewed (0)
  3. src/archive/zip/reader_test.go

    	}
    
    	// test read of each file
    	for i, ft := range zt.File {
    		readTestFile(t, zt, ft, z.File[i], raw)
    	}
    	if t.Failed() {
    		return
    	}
    
    	// test simultaneous reads
    	n := 0
    	done := make(chan bool)
    	for i := 0; i < 5; i++ {
    		for j, ft := range zt.File {
    			go func(j int, ft ZipTestFile) {
    				readTestFile(t, zt, ft, z.File[j], raw)
    				done <- true
    			}(j, ft)
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Oct 17 20:10:27 UTC 2025
    - 56.5K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

        val updatedTimestamp = response2.receivedResponseAtMillis
        assertThat((updatedTimestamp - t1).toDouble()).isCloseTo(0.0, 250.0)
    
        // A full cache hit reads the cache.
        Thread.sleep(10)
        val response3 = get(server.url("/a"))
        assertThat(response3.body.string()).isEqualTo("A")
        assertThat(response3.header("Allow")).isEqualTo("GET, HEAD")
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Oct 03 17:41:45 UTC 2025
    - 116.8K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    			metaArr[index].ModTime = modTime
    			metaArr[index].VersionID = versionID
    			if !metaArr[index].InlineData() {
    				// If the data is not inlined, we may end up incorrectly
    				// inlining the data here, that leads to an inconsistent
    				// situation where some objects are were not inlined
    				// were now inlined, make sure to `nil` the Data such
    				// that xl.meta is written as expected.
    				metaArr[index].Data = nil
    			}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  6. RELEASE.md

    ## Major Features and Improvements
    
    *   Support for Python3.9 has been added.
    *   `tf.data`:
        *   `tf.data` service now supports strict round-robin reads, which is useful
            for synchronous training workloads where example sizes vary. With strict
            round robin reads, users can guarantee that consumers get similar-sized
            examples in the same step.
    Registered: Tue Dec 30 12:39:10 UTC 2025
    - Last Modified: Tue Oct 28 22:27:41 UTC 2025
    - 740.4K bytes
    - Viewed (3)
  7. cmd/metrics-v2.go

    				Namespace: minioNamespace,
    				Subsystem: "locks",
    				Name:      "read_total",
    				Help:      "Number of current READ locks on this peer",
    				Type:      gaugeMetric,
    			},
    			Value: float64(st.Reads),
    		})
    		return metrics
    	})
    	return mg
    }
    
    func getNotificationMetrics(opts MetricsGroupOpts) *MetricsGroupV2 {
    	mg := &MetricsGroupV2{
    		cacheInterval:    10 * time.Second,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 133.6K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

            } catch (final Exception e) {
                logger.debug("Failed to delete index: indexName={}", indexName, e);
            }
            return false;
        }
    
        /**
         * Reads and processes index settings from configuration file.
         *
         * @param fesenType          the search engine type
         * @param indexConfigFile    the path to the index configuration file
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 122.4K bytes
    - Viewed (1)
  9. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

        URLConnection.setDefaultRequestProperty("X-testSetDefaultRequestProperty", "A")
        assertThat(URLConnection.getDefaultRequestProperty("X-setDefaultRequestProperty")).isNull()
      }
    
      /**
       * Reads `count` characters from the stream. If the stream is exhausted before `count`
       * characters can be read, the remaining characters are returned and the stream is closed.
       */
      private fun readAscii(
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.25.md

        - [CVE-2023-3955: Insufficient input sanitization on Windows nodes leads to privilege escalation](#cve-2023-3955-insufficient-input-sanitization-on-windows-nodes-leads-to-privilege-escalation)
        - [CVE-2023-3676: Insufficient input sanitization on Windows nodes leads to privilege escalation](#cve-2023-3676-insufficient-input-sanitization-on-windows-nodes-leads-to-privilege-escalation)
      - [Changes by Kind](#changes-by-kind-2)
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Mon May 06 09:23:20 UTC 2024
    - 419.1K bytes
    - Viewed (0)
Back to top