- Sort Score
- Num 10 results
- Language All
Results 601 - 610 of 1,148 for Rome (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
} }); // Don't copy this into your own test! // Use e.g. awaitClear or await(CountDownLatch) instead. GcFinalization.awaitFullGc(); // Attempt to help with some flakiness that we've seen: b/387521512. GcFinalization.awaitFullGc(); assertEquals(0, finalizerRan.getCount()); assertThat(ref.get()).isNull(); }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Dec 08 17:02:07 GMT 2025 - 7.9K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java
* synchronization primitives. The strategies are all implemented as subtypes of AtomicHelper and * the strategy is selected in the static initializer of AggregateFutureState. This is convenient * and performant but introduces some testing difficulties. This test exercises the two fallback * strategies. * * <ul> * <li>SafeAtomicHelper: uses Atomic FieldsUpdaters to implement synchronization
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 6.5K bytes - Click Count (0) -
guava/src/com/google/common/hash/SipHashFunction.java
// The initial state corresponds to the ASCII string "somepseudorandomlygeneratedbytes", // big-endian encoded. There is nothing special about this value; the only requirement // was some asymmetry so that the initial v0 and v1 differ from v2 and v3. private long v0 = 0x736f6d6570736575L; private long v1 = 0x646f72616e646f6dL; private long v2 = 0x6c7967656e657261L;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Feb 13 17:34:21 GMT 2025 - 5.3K bytes - Click Count (0) -
internal/kms/conn.go
// DEK is a data encryption key. It consists of a // plaintext-ciphertext pair and the ID of the key // used to generate the ciphertext. // // The plaintext can be used for cryptographic // operations - like encrypting some data. The // ciphertext is the encrypted version of the // plaintext data and can be stored on untrusted // storage. type DEK struct { KeyID string // Name of the master keyCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Aug 18 06:43:03 GMT 2024 - 5K bytes - Click Count (0) -
internal/s3select/simdj/reader.go
} return nil } // startReader will start a reader that accepts input from r.input. // Input should be root -> object input. Each root indicates a record. // If r.input is closed, it is assumed that no more input will come. // When this function returns r.readerWg will be decremented and r.decoded will be closed. // On errors, r.err will be set. This should only be accessed after r.decoded has been closed. func (r *Reader) startReader() {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt
* * Clients call [get] to read a snapshot of an entry. The read will observe the value at the time * that [get] was called. Updates and removals after the call do not impact ongoing reads. * * This class is tolerant of some I/O errors. If files are missing from the filesystem, the * corresponding entries will be dropped from the cache. If an error occurs while writing a cache
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 34.7K bytes - Click Count (0) -
src/bufio/bufio_test.go
// the ReadSlice test since ReadLine simply calls // ReadSlice, and it's that function that handles // the last byte. } // Try all readers with UnreadByte. for rno, read := range readers { // Some input data that is longer than the minimum reader buffer size. const n = 10 var buf bytes.Buffer for i := 0; i < n; i++ { buf.WriteString("abcdefg") } r := NewReaderSize(&buf, minReadBufferSize)
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Feb 07 01:08:54 GMT 2025 - 51.6K bytes - Click Count (0) -
docs/changelogs/changelog_2x.md
logs. * **WebSocket API now uses `RequestBody` and `ResponseBody` for messages.** This is a backwards-incompatible API change. * **The DNS service is now pluggable.** In some situations this may be useful to manually prioritize specific IP addresses. * Fix: Don't throw when converting an `HttpUrl` to a `java.net.URI`. Previously URLs with special characters like `|` and `[` would break whenCreated: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 26.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
* Other contributors include Andrew Wright, Jeffrey Hayes, * Pat Fisher, Mike Judd. */ /* * Source: * http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/test/tck/JSR166TestCase.java?revision=1.90 * (We have made some trivial local modifications (commented out * uncompilable code).) */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:07:52 GMT 2025 - 37.8K bytes - Click Count (0) -
docs/features/calls.md
`User-Agent`, `Host`, `Connection`, and `Content-Type`. It will add an `Accept-Encoding` header for transparent response compression unless the header is already present. If you’ve got cookies, OkHttp will add a `Cookie` header with them. Some requests will have a cached response. When this cached response isn’t fresh, OkHttp can do a _conditional GET_ to download an updated response if it’s newer than what’s cached. This requires headers like `If-Modified-Since` and `If-None-Match` to be...
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 3.9K bytes - Click Count (0)