Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for recordRead (0.12 sec)

  1. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

        assertEquals(1, segment.writeQueue.size());
    
        segment.recordRead(entry, ticker.read());
        segment.expireEntries(ticker.read());
        assertSame(value, map.get(key));
        assertSame(entry, segment.writeQueue.peek());
        assertEquals(1, segment.writeQueue.size());
    
        ticker.advance(1);
        segment.recordRead(entry, ticker.read());
        segment.expireEntries(ticker.read());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 110.6K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/cache/LocalCacheTest.java

        assertEquals(1, segment.writeQueue.size());
    
        segment.recordRead(entry, ticker.read());
        segment.expireEntries(ticker.read());
        assertSame(value, map.get(key));
        assertSame(entry, segment.writeQueue.peek());
        assertEquals(1, segment.writeQueue.size());
    
        ticker.advance(1);
        segment.recordRead(entry, ticker.read());
        segment.expireEntries(ticker.read());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 112.3K bytes
    - Viewed (0)
  3. guava/src/com/google/common/cache/LocalCache.java

              if (e != null) {
                long now = map.ticker.read();
                V value = getLiveValue(e, now);
                if (value != null) {
                  recordRead(e, now);
                  statsCounter.recordHits(1);
                  return scheduleRefresh(e, key, hash, value, now, loader);
                }
                ValueReference<K, V> valueReference = e.getValueReference();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 149.2K bytes
    - Viewed (0)
  4. cmd/object-handlers_test.go

    	}
    	decoder := xml.NewDecoder(rec.Body)
    	multipartResponse := &InitiateMultipartUploadResponse{}
    	err = decoder.Decode(multipartResponse)
    	if err != nil {
    		t.Fatalf("Error decoding the recorded response Body")
    	}
    	uploadID := multipartResponse.UploadID
    
    	a := 0
    	b := globalMinPartSize
    	var parts []CompletePart
    	for partNumber := 1; partNumber <= 2; partNumber++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

        // We know that a fresh connection was created if the server recorded a request with sequence
        // number 0. Since the client may have attempted to reuse the broken connection just before
        // creating a fresh connection, the server may have recorded 2 requests at this point. The order
        // of recording is non-deterministic.
        val requestAfter = server.takeRequest()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 131.7K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.5.md

        * as being in state "Unknown", along with a longer description in `kubectl describe` output.
    * The hostname of the node (as autodetected by the kubelet, specified via --hostname-override, or determined by the cloudprovider) is now recorded as an address of type "Hostname" in the status of the Node API object. The hostname is expected to be resolveable from the apiserver. ([#25532](https://github.com/kubernetes/kubernetes/pull/25532), [@mkulke](https://github.com/mkulke))
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 136.4K bytes
    - Viewed (0)
Back to top