Search Options

Results per page
Sort
Preferred Languages
Advance

Results 441 - 450 of 494 for evicting (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top