Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for paste (0.17 sec)

  1. cmd/bucket-replication.go

    	}
    
    	// queue replication heal in a goroutine to avoid holding up mrf save routine
    	go func() {
    		for vID, e := range mrfRec.Entries {
    			ctx, cancel := context.WithTimeout(p.ctx, time.Second) // Do not waste more than a second on this.
    
    			oi, err := p.objLayer.GetObjectInfo(ctx, e.Bucket, e.Object, ObjectOptions{
    				VersionID: vID,
    			})
    			cancel()
    			if err != nil {
    				continue
    			}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  2. cmd/bucket-object-lock.go

    // Objects under site wide WORM can never be overwritten.
    // For objects in "Governance" mode, overwrite is allowed if a) object retention date is past OR
    // governance bypass headers are set and user has governance bypass permissions.
    // Objects in "Compliance" mode can be overwritten only if retention date is past.
    func enforceRetentionBypassForDelete(ctx context.Context, r *http.Request, bucket string, object ObjectToDelete, oi ObjectInfo, gerr error) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 13.2K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/podcgroupns.go

    }
    
    func GetFd(f fs.File) (uintptr, error) {
    	if fdable, ok := f.(interface{ Fd() uintptr }); ok {
    		return fdable.Fd(), nil
    	}
    
    	return 0, fmt.Errorf("unable to get fd")
    }
    
    /// mostly copy pasted from spire below:
    
    // regexes listed here have to exclusively match a cgroup path
    // the regexes must include two named groups "poduid" and "containerid"
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 11K bytes
    - Viewed (0)
  4. cmd/auth-handler.go

    				atomic.AddUint64(&globalHTTPStats.rejectedRequestsTime, 1)
    				return
    			}
    			// Verify if the request date header is shifted by less than globalMaxSkewTime parameter in the past
    			// or in the future, reject request otherwise.
    			curTime := UTCNow()
    			if curTime.Sub(amzDate) > globalMaxSkewTime || amzDate.Sub(curTime) > globalMaxSkewTime {
    				if ok {
    					tc.FuncName = "handler.Auth"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 26K bytes
    - Viewed (0)
  5. src/bytes/bytes.go

    		panic("bytes: negative Repeat count")
    	}
    	if len(b) >= maxInt/count {
    		panic("bytes: Repeat output length overflow")
    	}
    	n := len(b) * count
    
    	if len(b) == 0 {
    		return []byte{}
    	}
    
    	// Past a certain chunk size it is counterproductive to use
    	// larger chunks as the source of the write, as when the source
    	// is too large we are basically just thrashing the CPU D-cache.
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Feb 19 19:51:15 GMT 2024
    - 33.8K bytes
    - Viewed (0)
  6. internal/bucket/lifecycle/lifecycle_test.go

    			isDelMarker:     true,
    			hasManyVersions: true,
    			expectedAction:  NoneAction,
    		},
    		// Should delete all versions of this object since the latest version has past the expiry days criteria
    		{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 53.2K bytes
    - Viewed (0)
  7. cmd/metacache-set.go

    	resCh := resultsDone
    	var done bool
    	var mu sync.Mutex
    	resErr := io.EOF
    
    	go func() {
    		var results metaCacheEntriesSorted
    		var returned bool
    		for entry := range in {
    			if returned {
    				// past limit
    				continue
    			}
    			mu.Lock()
    			returned = done
    			mu.Unlock()
    			if returned {
    				resCh = nil
    				continue
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  8. internal/bucket/lifecycle/lifecycle.go

    				}
    			}
    		}
    	}
    
    	if len(events) > 0 {
    		slices.SortFunc(events, func(a, b Event) int {
    			// Prefer Expiration over Transition for both current
    			// and noncurrent versions when,
    			// - now is past the expected time to action
    			// - expected time to action is the same for both actions
    			if now.After(a.Due) && now.After(b.Due) || a.Due.Equal(b.Due) {
    				switch a.Action {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 17.5K bytes
    - Viewed (0)
  9. src/archive/tar/reader.go

    // The bytes written matches the number of remaining bytes in the current file.
    //
    // If the current file is sparse and w is an io.WriteSeeker,
    // then writeTo uses Seek to skip past holes defined in Header.SparseHoles,
    // assuming that skipped regions are filled with NULs.
    // This always writes the last byte to ensure w is the right size.
    //
    // TODO(dsnet): Re-export this when adding sparse file support.
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Mar 08 01:59:14 GMT 2024
    - 26.8K bytes
    - Viewed (0)
Back to top