Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 115 for cout (0.18 sec)

  1. migrator/migrator.go

    func (m Migrator) HasTable(value interface{}) bool {
    	var count int64
    
    	m.RunWithValue(value, func(stmt *gorm.Statement) error {
    		currentDatabase := m.DB.Migrator().CurrentDatabase()
    		return m.DB.Raw("SELECT count(*) FROM information_schema.tables WHERE table_schema = ? AND table_name = ? AND table_type = ?", currentDatabase, stmt.Table, "BASE TABLE").Row().Scan(&count)
    	})
    
    	return count > 0
    }
    
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Fri Apr 26 07:15:49 GMT 2024
    - 29K bytes
    - Viewed (0)
  2. cmd/endpoint-ellipses.go

    	for i := 1; i < len(totalSizes); i++ {
    		result = gcd(result, totalSizes[i])
    	}
    	return result
    }
    
    // isValidSetSize - checks whether given count is a valid set size for erasure coding.
    var isValidSetSize = func(count uint64) bool {
    	return (count >= setSizes[0] && count <= setSizes[len(setSizes)-1])
    }
    
    func commonSetDriveCount(divisibleSize uint64, setCounts []uint64) (setSize uint64) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  3. cmd/erasure-metadata.go

    	for _, hash := range metaHashes {
    		if hash == "" {
    			continue
    		}
    		metaHashCountMap[hash]++
    	}
    
    	maxHash := ""
    	maxCount := 0
    	for hash, count := range metaHashCountMap {
    		if count > maxCount {
    			maxCount = count
    			maxHash = hash
    		}
    	}
    
    	if maxCount < quorum {
    		return FileInfo{}, InsufficientReadQuorum{Err: errErasureReadQuorum, Type: RQInconsistentMeta}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  4. cmd/metrics-resource.go

    		metric.Cumulative = val
    	} else {
    		metric.Current = val
    	}
    
    	if metric.Current > metric.Max {
    		metric.Max = val
    	}
    
    	metric.Sum += metric.Current
    	metric.Count++
    
    	metric.Avg = metric.Sum / float64(metric.Count)
    	subsysMetrics[key] = metric
    
    	resourceMetricsMap[subSys] = subsysMetrics
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 17.4K bytes
    - Viewed (0)
  5. cmd/format-erasure_test.go

    	for _, hash := range formatHashes {
    		if hash == "" {
    			continue
    		}
    		formatCountMap[hash]++
    	}
    
    	maxHash := ""
    	maxCount := 0
    	for hash, count := range formatCountMap {
    		if count > maxCount {
    			maxCount = count
    			maxHash = hash
    		}
    	}
    
    	if maxCount < len(formats)/2 {
    		return nil, errErasureReadQuorum
    	}
    
    	for i, hash := range formatHashes {
    		if hash == maxHash {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  6. cmd/admin-heal-ops.go

    		healFailedItemsMap:    make(map[string]int64),
    	}
    }
    
    // getScannedItemsCount - returns a count of all scanned items
    func (h *healSequence) getScannedItemsCount() int64 {
    	var count int64
    	h.mutex.RLock()
    	defer h.mutex.RUnlock()
    
    	for _, v := range h.scannedItemsMap {
    		count += v
    	}
    	return count
    }
    
    // getScannedItemsMap - returns map of all scanned items against type
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  7. cmd/etcd.go

    	defer cancel()
    	resp, err := client.Get(timeoutCtx, key)
    	if err != nil {
    		etcdLogOnceIf(ctx, err, "etcd-retrieve-keys")
    		return nil, etcdErrToErr(err, client.Endpoints())
    	}
    	if resp.Count == 0 {
    		return nil, errConfigNotFound
    	}
    	for _, ev := range resp.Kvs {
    		if string(ev.Key) == key {
    			return ev.Value, nil
    		}
    	}
    	return nil, errConfigNotFound
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 2.9K bytes
    - Viewed (0)
  8. cni/pkg/log/uds_test.go

    	assert.NoError(t, w.Close())
    	out, err := io.ReadAll(r)
    	assert.NoError(t, err)
    
    	// For each level, there should be two lines, one from direct log,
    	// the other one from UDS server
    	wantLevels := []string{"debug", "info", "warn", "error", "debug", "info", "warn", "error"}
    	gotLogs := strings.Split(
    		strings.TrimSuffix(string(out), "\n"), "\n")
    	if want, got := len(wantLevels), len(gotLogs); want != got {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Mar 16 00:20:01 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  9. cmd/object-api-datatypes.go

    	{"GREATER_THAN_512_MB", humanize.MiByte * 512, math.MaxInt64},
    }
    
    // ObjectsVersionCountIntervals is the list of all intervals
    // of object version count to be included in objects histogram.
    var ObjectsVersionCountIntervals = [dataUsageVersionLen]objectHistogramInterval{
    	{"UNVERSIONED", 0, 0},
    	{"SINGLE_VERSION", 1, 1},
    	{"BETWEEN_2_AND_10", 2, 9},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.8K bytes
    - Viewed (0)
  10. internal/config/storageclass/storage-class.go

    		}
    	}
    	return nil
    }
    
    // GetParityForSC - Returns the data and parity drive count based on storage class
    // If storage class is set using the env vars MINIO_STORAGE_CLASS_RRS and
    // MINIO_STORAGE_CLASS_STANDARD or server config fields corresponding values are
    // returned.
    //
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.8K bytes
    - Viewed (1)
Back to top