Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 611 for RANGE (0.17 sec)

  1. cmd/copy-part-range.go

    		apiErr.Description = err.Error()
    		writeErrorResponse(ctx, w, apiErr, url)
    		return
    	}
    }
    
    // Parses x-amz-copy-source-range for CopyObjectPart API. Its behavior
    // is different from regular HTTP range header. It only supports the
    // form `bytes=first-last` where first and last are zero-based byte
    // offsets. See
    // http://docs.aws.amazon.com/AmazonS3/latest/API/mpUploadUploadPartCopy.html
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Jun 18 03:27:04 GMT 2021
    - 2.5K bytes
    - Viewed (0)
  2. cmd/copy-part-range_test.go

    			t.Fatalf("expected: an error, got: <nil> for range %s", rangeString)
    		}
    	}
    
    	// Test error range strings.
    	errorRangeString := []string{
    		"bytes=10-10",
    		"bytes=20-30",
    	}
    	for _, rangeString := range errorRangeString {
    		rs, err := parseCopyPartRangeSpec(rangeString)
    		if err == nil {
    			err1 := checkCopyPartRangeWithSize(rs, objectSize)
    			if err1 != errInvalidRangeSource {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 2.5K bytes
    - Viewed (0)
  3. cmd/notification.go

    	ng := WithNPeers(len(sys.peerClients))
    	for idx, client := range sys.peerClients {
    		if client == nil {
    			continue
    		}
    		client := client
    		ng.Go(ctx, func() error {
    			return client.LoadBucketMetadata(bucketName)
    		}, idx, *client.host)
    	}
    	for _, nErr := range ng.Wait() {
    		reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", nErr.Host.String())
    		if nErr.Err != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  4. internal/config/config.go

    // like urls and credentials from the configuration
    func (c Config) RedactSensitiveInfo() Config {
    	nc := c.Clone()
    
    	for configName, configVals := range nc {
    		for _, helpKV := range HelpSubSysMap[configName] {
    			if helpKV.Sensitive {
    				for name, kvs := range configVals {
    					for i := range kvs {
    						if kvs[i].Key == helpKV.Key && len(kvs[i].Value) > 0 {
    							kvs[i].Value = "*redacted*"
    						}
    					}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 37.3K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v2_test.go

    			t.Fatal(err)
    		}
    		vers = append(vers, xl.versions)
    	}
    	for _, v2 := range vers {
    		for _, ver := range v2 {
    			b, _ := json.Marshal(ver.header)
    			t.Log(string(b))
    			var x xlMetaV2Version
    			_, _ = x.unmarshalV(0, ver.meta)
    			b, _ = json.Marshal(x)
    			t.Log(string(b), x.getSignature())
    		}
    	}
    
    	for i := range vers {
    		t.Run(fmt.Sprintf("non-strict-q%d", i), func(t *testing.T) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 36.4K bytes
    - Viewed (0)
  6. cmd/data-usage-cache.go

    		Tiers: make(map[string]tierStats),
    	}
    }
    
    func (ats *allTierStats) addSizes(tiers map[string]tierStats) {
    	for tier, st := range tiers {
    		ats.Tiers[tier] = ats.Tiers[tier].add(st)
    	}
    }
    
    func (ats *allTierStats) merge(other *allTierStats) {
    	for tier, st := range other.Tiers {
    		ats.Tiers[tier] = ats.Tiers[tier].add(st)
    	}
    }
    
    func (ats *allTierStats) clone() *allTierStats {
    	if ats == nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 41.3K bytes
    - Viewed (1)
  7. cmd/bootstrap-peer-server_gen.go

    	o = msgp.AppendArrayHeader(o, uint32(len(z.CmdLines)))
    	for za0001 := range z.CmdLines {
    		o = msgp.AppendString(o, z.CmdLines[za0001])
    	}
    	// string "MinioEnv"
    	o = append(o, 0xa8, 0x4d, 0x69, 0x6e, 0x69, 0x6f, 0x45, 0x6e, 0x76)
    	o = msgp.AppendMapHeader(o, uint32(len(z.MinioEnv)))
    	for za0002, za0003 := range z.MinioEnv {
    		o = msgp.AppendString(o, za0002)
    		o = msgp.AppendString(o, za0003)
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Jan 24 21:36:44 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  8. cmd/erasure.go

    	offlineDisks = make(madmin.BackendDisks)
    
    	for _, disk := range disksInfo {
    		ep := disk.Endpoint
    		if _, ok := offlineDisks[ep]; !ok {
    			offlineDisks[ep] = 0
    		}
    		if _, ok := onlineDisks[ep]; !ok {
    			onlineDisks[ep] = 0
    		}
    	}
    
    	// Wait for the routines.
    	for _, disk := range disksInfo {
    		ep := disk.Endpoint
    		state := disk.State
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 10:02:39 GMT 2024
    - 16K bytes
    - Viewed (1)
  9. cmd/admin-handlers.go

    	}
    
    	if globalIsTLS {
    		for _, c := range globalPublicCerts {
    			check := xxh3.Hash(c.RawIssuer)
    			check ^= xxh3.Hash(c.RawSubjectPublicKeyInfo)
    			// We XOR, so order doesn't matter.
    			for _, v := range c.DNSNames {
    				check ^= xxh3.HashString(v)
    			}
    			for _, v := range c.EmailAddresses {
    				check ^= xxh3.HashString(v)
    			}
    			for _, v := range c.IPAddresses {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  10. internal/http/listener_test.go

    	}
    
    	for testIdx, testCase := range testCases {
    		listener, listenErrs := newHTTPListener(context.Background(),
    			testCase.serverAddrs,
    			TCPOptions{},
    		)
    		for i, expectedListenErr := range testCase.expectedListenErrs {
    			if !expectedListenErr {
    				if listenErrs[i] != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Jun 12 16:09:28 GMT 2023
    - 11.8K bytes
    - Viewed (0)
Back to top