Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 601 - 610 of 970 for nil (0.03 seconds)

  1. internal/logger/logger.go

    func CriticalIf(ctx context.Context, err error, errKind ...any) {
    	if err != nil {
    		LogIf(ctx, "", err, errKind...)
    		panic(ErrCritical)
    	}
    }
    
    // FatalIf is similar to Fatal() but it ignores passed nil error
    func FatalIf(err error, msg string, data ...any) {
    	if err == nil {
    		return
    	}
    	fatal(err, msg, data...)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  2. cmd/erasure-coding.go

    	if len(data) == 0 {
    		return make([][]byte, e.dataBlocks+e.parityBlocks), nil
    	}
    	encoded, err := e.encoder().Split(data)
    	if err != nil {
    		return nil, err
    	}
    	if err = e.encoder().Encode(encoded); err != nil {
    		return nil, err
    	}
    	return encoded, nil
    }
    
    // DecodeDataBlocks decodes the given erasure-coded data.
    // It only decodes the data blocks but does not verify them.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  3. internal/config/config.go

    		text := scanner.Text()
    		if text == "" || strings.HasPrefix(text, KvComment) {
    			continue
    		}
    		_, _, tgt, err := GetSubSys(text)
    		if err != nil {
    			return nil, err
    		}
    		ids[tgt] = true
    	}
    	if err := scanner.Err(); err != nil {
    		return nil, err
    	}
    	return ids, err
    }
    
    // ReadConfig - read content from input and write into c.
    // Returns whether all parameters were dynamic.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 37.7K bytes
    - Click Count (0)
  4. cmd/http-stats.go

    func (stats *HTTPAPIStats) Inc(api string) {
    	if stats == nil {
    		return
    	}
    	stats.Lock()
    	defer stats.Unlock()
    	if stats.apiStats == nil {
    		stats.apiStats = make(map[string]int)
    	}
    	stats.apiStats[api]++
    }
    
    // Dec increments the api stats counter.
    func (stats *HTTPAPIStats) Dec(api string) {
    	if stats == nil {
    		return
    	}
    	stats.Lock()
    	defer stats.Unlock()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Sep 24 17:13:00 GMT 2024
    - 11.4K bytes
    - Click Count (0)
  5. internal/bucket/lifecycle/prefix.go

    	var s string
    	if err = d.DecodeElement(&s, &start); err != nil {
    		return err
    	}
    	*p = Prefix{string: s, set: true}
    	return nil
    }
    
    // MarshalXML - decodes XML data.
    func (p Prefix) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
    	if !p.set {
    		return nil
    	}
    	return e.EncodeElement(p.string, startElement)
    }
    
    // String returns the prefix string
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 15 14:45:25 GMT 2023
    - 1.5K bytes
    - Click Count (0)
  6. cmd/handler-api.go

    )
    
    func cgroupMemLimit() (limit uint64) {
    	buf, err := os.ReadFile(cgroupV2MemLimitFile)
    	if err != nil {
    		buf, err = os.ReadFile(cgroupV1MemLimitFile)
    	}
    	if err != nil {
    		return 0
    	}
    	limit, err = strconv.ParseUint(strings.TrimSpace(string(buf)), 10, 64)
    	if err != nil {
    		// The kernel can return valid but non integer values
    		// but still, no need to interpret more
    		return 0
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  7. internal/dsync/drwmutex_test.go

    func TestUnlockPanic(t *testing.T) {
    	defer func() {
    		if recover() == nil {
    			t.Fatalf("unlock of unlocked RWMutex did not panic")
    		}
    	}()
    	mu := NewDRWMutex(ds, "test")
    	mu.Unlock(t.Context())
    }
    
    // Borrowed from rwmutex_test.go
    func TestUnlockPanic2(t *testing.T) {
    	mu := NewDRWMutex(ds, "test-unlock-panic-2")
    	defer func() {
    		if recover() == nil {
    			t.Fatalf("unlock of unlocked RWMutex did not panic")
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  8. cmd/bucket-versioning.go

    func (sys *BucketVersioningSys) PrefixEnabled(bucket, prefix string) bool {
    	vc, err := sys.Get(bucket)
    	if err != nil {
    		logger.CriticalIf(GlobalContext, err)
    	}
    	return vc.PrefixEnabled(prefix)
    }
    
    // Suspended suspended versioning?
    func (sys *BucketVersioningSys) Suspended(bucket string) bool {
    	vc, err := sys.Get(bucket)
    	if err != nil {
    		logger.CriticalIf(GlobalContext, err)
    	}
    	return vc.Suspended()
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 2.6K bytes
    - Click Count (0)
  9. cmd/signature-v2.go

    	for query := range strings.SplitSeq(encodedQuery, "&") {
    		var unescapedQuery string
    		unescapedQuery, err = url.QueryUnescape(query)
    		if err != nil {
    			return nil, err
    		}
    		unescapedQueries = append(unescapedQueries, unescapedQuery)
    	}
    	return unescapedQueries, nil
    }
    
    // doesPresignV2SignatureMatch - Verify query headers with presigned signature
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.2K bytes
    - Click Count (0)
  10. tests/helper_test.go

    		return false
    	}
    
    	base := strings.SplitN(strings.TrimSpace(version), "-", 2)[0]
    	parts := strings.Split(base, ".")
    	if len(parts) < 2 {
    		return false
    	}
    
    	currentMajor, err := strconv.Atoi(parts[0])
    	if err != nil {
    		return false
    	}
    
    	currentMinor, err := strconv.Atoi(parts[1])
    	if err != nil {
    		return false
    	}
    
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:27:38 GMT 2026
    - 8.6K bytes
    - Click Count (0)
Back to Top