Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 381 - 390 of 833 for len2 (0.02 seconds)

  1. cmd/update-notifier.go

    	msgLine2Fmt := " Update: %s "
    
    	// Calculate length *without* color coding: with ANSI terminal
    	// color characters, the result is incorrect.
    	line1Length := len(fmt.Sprintf(msgLine1Fmt, newerThan))
    	line2Length := len(fmt.Sprintf(msgLine2Fmt, updateString))
    
    	// Populate lines with color coding.
    	line1InColor := fmt.Sprintf(msgLine1Fmt, color.YellowBold(newerThan))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Mar 09 03:07:08 GMT 2024
    - 3.6K bytes
    - Click Count (0)
  2. cmd/warm-backend-s3.go

    	result, err := s3.core.ListObjectsV2(s3.Bucket, s3.Prefix, "", "", slashSeparator, 1)
    	if err != nil {
    		return false, s3.ToObjectError(err)
    	}
    	return len(result.CommonPrefixes) > 0 || len(result.Contents) > 0, nil
    }
    
    func newWarmBackendS3(conf madmin.TierS3, tier string) (*warmBackendS3, error) {
    	u, err := url.Parse(conf.Endpoint)
    	if err != nil {
    		return nil, err
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Jun 08 16:13:30 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  3. cmd/update.go

    		if pcfTileVersion != "" {
    			uaAppend(" pcf-tile-", pcfTileVersion)
    		}
    	}
    	uaAppend("; ", "")
    
    	if cpus, err := gopsutilcpu.Info(); err == nil && len(cpus) > 0 {
    		cpuMap := make(map[string]struct{}, len(cpus))
    		coreMap := make(map[string]struct{}, len(cpus))
    		for i := range cpus {
    			cpuMap[cpus[i].PhysicalID] = struct{}{}
    			coreMap[cpus[i].CoreID] = struct{}{}
    		}
    		cpu := cpus[0]
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  4. tests/associations_has_one_test.go

    	// Count
    	AssertAssociationCount(t, users, "Account", 2, "")
    
    	// Find
    	var accounts []Account
    	if DB.Model(&users).Association("Account").Find(&accounts); len(accounts) != 2 {
    		t.Errorf("accounts count should be %v, but got %v", 3, len(accounts))
    	}
    
    	// Append
    	DB.Model(&users).Association("Account").Append(
    		&Account{Number: "account-slice-append-1"},
    		&Account{Number: "account-slice-append-2"},
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Wed Jun 12 10:49:45 GMT 2024
    - 7.1K bytes
    - Click Count (0)
  5. cmd/erasure-heal_test.go

    		}
    
    		readers := make([]io.ReaderAt, len(disks))
    		for i, disk := range disks {
    			shardFilesize := erasure.ShardFileSize(test.size)
    			readers[i] = newBitrotReader(disk, nil, "testbucket", "testobject", shardFilesize, test.algorithm, bitrotWriterSum(writers[i]), erasure.ShardSize())
    		}
    
    		// setup stale disks for the test case
    		staleDisks := make([]StorageAPI, len(disks))
    		copy(staleDisks, disks)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  6. cmd/bucket-metadata-sys.go

    }
    
    // concurrently load bucket metadata to speed up loading bucket metadata.
    func (sys *BucketMetadataSys) concurrentLoad(ctx context.Context, buckets []string) {
    	g := errgroup.WithNErrs(len(buckets))
    	bucketMetas := make([]BucketMetadata, len(buckets))
    	for index := range buckets {
    		g.Go(func() error {
    			// Sleep and stagger to avoid blocked CPU and thundering
    			// herd upon start up sequence.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  7. internal/hash/reader.go

    		if r.bytesRead > 0 {
    			return nil, errors.New("hash: already read from hash reader")
    		}
    		if len(r.checksum) != 0 && len(MD5) != 0 && !etag.Equal(r.checksum, MD5) {
    			return nil, BadDigest{
    				ExpectedMD5:   r.checksum.String(),
    				CalculatedMD5: md5Hex,
    			}
    		}
    		if len(r.contentSHA256) != 0 && len(SHA256) != 0 && !bytes.Equal(r.contentSHA256, SHA256) {
    			return nil, SHA256Mismatch{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  8. cmd/erasure-multipart-conditional_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Put an initial object so it exists
    	_, err = obj.PutObject(ctx, bucket, object,
    		mustGetPutObjReader(t, bytes.NewReader([]byte("initial-value")),
    			int64(len("initial-value")), "", ""), ObjectOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Get object info to capture the ETag
    	objInfo, err := obj.GetObjectInfo(ctx, bucket, object, ObjectOptions{})
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 6.9K bytes
    - Click Count (0)
  9. cmd/batch-handlers_gen.go

    func (z *batchJobInfo) Msgsize() (s int) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  10. tests/connection_test.go

    	"gorm.io/driver/mysql"
    	"gorm.io/gorm"
    )
    
    func TestWithSingleConnection(t *testing.T) {
    	expectedName := "test"
    	var actualName string
    
    	setSQL, getSQL := getSetSQL(DB.Dialector.Name())
    	if len(setSQL) == 0 || len(getSQL) == 0 {
    		return
    	}
    
    	err := DB.Connection(func(tx *gorm.DB) error {
    		if err := tx.Exec(setSQL, expectedName).Error; err != nil {
    			return err
    		}
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Mon Sep 08 09:19:22 GMT 2025
    - 943 bytes
    - Click Count (0)
Back to Top