- Sort Score
- Result 10 results
- Languages All
Results 441 - 450 of 494 for evicting (0.05 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt
/** * Returns an iterator over the URLs in this cache. This iterator doesn't throw * `ConcurrentModificationException`, but if new responses are added while iterating, their URLs * will not be returned. If existing responses are evicted during iteration, they will be absent * (unless they were already returned). * * The iterator supports [MutableIterator.remove]. Removing a URL from the iterator evicts the
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 16 09:39:51 UTC 2025 - 26.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/LinkedListMultimap.java
List<V> oldValues = getCopy(key); ListIterator<V> keyValues = new ValueForKeyIterator(key); Iterator<? extends V> newValues = values.iterator(); // Replace existing values, if any. while (keyValues.hasNext() && newValues.hasNext()) { keyValues.next(); keyValues.set(newValues.next()); } // Remove remaining old values, if any.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 26.6K bytes - Viewed (0) -
cmd/format-erasure.go
return errDiskNotFound } // Marshal and write to disk. formatData, err := json.Marshal(format) if err != nil { return err } tmpFormat := mustGetUUID() // Purge any existing temporary file, okay to ignore errors here. defer disk.Delete(context.TODO(), minioMetaBucket, tmpFormat, DeleteOptions{ Recursive: false, Immediate: false, }) // write to unique file.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 23.1K bytes - Viewed (0) -
src/archive/zip/writer.go
return &Writer{cw: &countWriter{w: bufio.NewWriter(w)}} } // SetOffset sets the offset of the beginning of the zip data within the // underlying writer. It should be used when the zip data is appended to an // existing file, such as a binary executable. // It must be called before any data is written. func (w *Writer) SetOffset(n int64) { if w.cw.count != 0 { panic("zip: SetOffset called after data was written") } w.cw.count = n
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Tue Jan 28 04:20:09 UTC 2025 - 19.4K bytes - Viewed (0) -
docs/smb3-features/06-witness-protocol-design.md
private long sequenceNumber; private int returnCode; public boolean isSuccess() { return returnCode == 0; } // Getters and setters... } ``` ## 5. Integration with Existing Code ### 5.1 Session Integration ```java // In SmbSession.java private WitnessClient witnessClient; private boolean witnessEnabled; public void initializeWitnessSupport() {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 42K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt
filesystem.setFaultyDelete(cacheDir / "a.0", true) taskFaker.runNextTask() // Confirm we prevent edits after a trim failure. assertThat(cache.edit("c")).isNull() // A successful eviction should allow new writes. filesystem.setFaultyDelete(cacheDir / "a.0", false) cache.evictAll() set("c", "cc", "cc") assertValue("c", "cc", "cc") } @ParameterizedTest
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 75.7K bytes - Viewed (0) -
src/archive/tar/common.go
format.mayOnlyBe(FormatPAX) } if len(h.PAXRecords) > 0 { for k, v := range h.PAXRecords { switch _, exists := paxHdrs[k]; { case exists: continue // Do not overwrite existing records case h.Typeflag == TypeXGlobalHeader: paxHdrs[k] = v // Copy all records case !basicKeys[k] && !strings.HasPrefix(k, paxGNUSparse): paxHdrs[k] = v // Ignore local records that may conflict }
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Fri Sep 13 21:03:27 UTC 2024 - 24.5K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
} encodedSuccessResponse := encodeResponse(response) // Write success response. writeSuccessResponseXML(w, encodedSuccessResponse) } // CopyObjectPartHandler - uploads a part by copying data from an existing object as data source. func (api objectAPIHandlers) CopyObjectPartHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "CopyObjectPart") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 39.5K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.33.md
Distributions or administrators of Kubernetes may want to control that new Service CIDRs added to the cluster do not overlap with other networks on the cluster, that only belong to a specific range of IPs. Administrators may also prefer to retain the existing behavior of only having one ServiceCIDR per cluster. You can use `ValidatingAdmissionPolicy` to achieve this. ([#128971](https://github.com/kubernetes/kubernetes/pull/128971), [@aojea](https://github.com/aojea)) [SIG Apps, Architecture, Auth, CLI,...
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Wed Aug 13 19:46:23 UTC 2025 - 294.3K bytes - Viewed (0) -
src/bytes/buffer_test.go
} var buf Buffer // Calling NewBuffer and immediately shallow copying the Buffer struct // should not result in any allocations. // This can be used to reset the underlying []byte of an existing Buffer. func TestNewBufferShallow(t *testing.T) { testenv.SkipIfOptimizationOff(t) n := testing.AllocsPerRun(1000, func() { buf = *NewBuffer(testBytes) }) if n > 0 {
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon May 19 16:13:04 UTC 2025 - 18.6K bytes - Viewed (0)