Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for falu (0.32 sec)

  1. cmd/iam.go

    			return false
    		}
    
    		// Finally, if there is no parent policy, check if a policy claim is
    		// present in the session token.
    		if len(policies) == 0 {
    			// If there is no parent policy mapping, we fall back to
    			// using policy claim from JWT.
    			policySet, ok := args.GetPolicies(iamPolicyClaimNameOpenID())
    			if !ok {
    				// When claims are set, it should have a policy claim field.
    				return false
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  2. cmd/erasure-object.go

    	// For negative length read everything.
    	if length < 0 {
    		length = fi.Size - startOffset
    	}
    
    	// Reply back invalid range if the input offset and length fall out of range.
    	if startOffset > fi.Size || startOffset+length > fi.Size {
    		return InvalidRange{startOffset, length, fi.Size}
    	}
    
    	// Get start part index and offset.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  3. internal/grid/stream.go

    			for range s.responses {
    			}
    		}
    	}()
    	doneCh := s.ctx.Done()
    	for {
    		select {
    		case <-doneCh:
    			if err := context.Cause(s.ctx); !errors.Is(err, errStreamEOF) {
    				return err
    			}
    			// Fall through to be sure we have returned all responses.
    			doneCh = nil
    		case resp, ok := <-s.responses:
    			if !ok {
    				done = true
    				return nil
    			}
    			if resp.Err != nil {
    				return resp.Err
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 28 18:05:18 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  4. internal/logger/logrotate.go

    	MaximumFileSize int64
    
    	// FileNameFunc specifies the name a new file will take.
    	// FileNameFunc must ensure collisions in filenames do not occur.
    	// Do not rely on timestamps to be unique, high throughput writes
    	// may fall on the same timestamp.
    	// Eg.
    	// 	2020-03-28_15-00-945-<random-hash>.log
    	// When FileNameFunc is not specified, DefaultFilenameFunc will be used.
    	FileNameFunc func() string
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 11:38:40 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  5. cmd/format-erasure.go

    		return nil, err
    	}
    
    	return getFormatErasureInQuorum(formats)
    }
    
    // ecDrivesNoConfig returns the erasure coded drives in a set if no config has been set.
    // It will attempt to read it from env variable and fall back to drives/2.
    func ecDrivesNoConfig(setDriveCount int) (int, error) {
    	sc, err := storageclass.LookupConfig(config.KVS{}, setDriveCount)
    	if err != nil {
    		return 0, err
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  6. cmd/storage-rest-server.go

    		// See https://github.com/golang/go/blob/f7c5cbb82087c55aa82081e931e0142783700ce8/src/net/sendfile_linux.go#L20
    		// Windows can lock up with this optimization, so we fall back to regular copy.
    		sr, ok := rc.(*sendFileReader)
    		if ok {
    			// Sendfile sends in 4MiB chunks per sendfile syscall which is more than enough
    			// for most setups.
    			_, err = rf.ReadFrom(sr.Reader)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  7. cmd/metacache-entries.go

    	}
    	if !isXL2V1Format(e.metadata) {
    		return false
    	}
    	if meta, _, err := isIndexedMetaV2(e.metadata); meta != nil {
    		return meta.IsLatestDeleteMarker()
    	} else if err != nil {
    		return true
    	}
    	// Fall back...
    	xlMeta, err := e.xlmeta()
    	if err != nil || len(xlMeta.versions) == 0 {
    		return true
    	}
    	return xlMeta.versions[0].header.Type == DeleteType
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  8. cmd/object-api-utils.go

    			length = oi.Size - off
    			// For negative length we read everything.
    			if decLength < 0 {
    				decLength = actualSize - decOff
    			}
    
    			// Reply back invalid range if the input offset and length fall out of range.
    			if decOff > actualSize || decOff+decLength > actualSize {
    				return nil, 0, 0, errInvalidRange
    			}
    		}
    		fn = func(inputReader io.Reader, h http.Header, cFns ...func()) (r *GetObjectReader, err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
  9. cmd/data-usage-cache.go

    			// spl interval: [1024B, 1MiB)
    			res[szInt.name] = splCount
    		case humanize.KiByte <= szInt.start && szInt.end <= humanize.MiByte-1:
    			// intervals that fall within the spl interval above; they
    			// appear earlier in this array of intervals, see
    			// ObjectsHistogramIntervals
    			splCount += count
    			fallthrough
    		default:
    			res[szInt.name] = count
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  10. cmd/erasure-metadata-utils.go

    	// expected quorum, proceed with EcIndex based
    	// disk order.
    	if inconsistent < fi.Erasure.ParityBlocks {
    		return shuffledDisks, shuffledPartsMetadata
    	}
    
    	// fall back to original distribution based order.
    	return shuffleDisksAndPartsMetadata(disks, metaArr, fi)
    }
    
    // Return shuffled partsMetadata depending on fi.Distribution.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 11.3K bytes
    - Viewed (0)
Back to top