Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 699 for float64 (0.16 sec)

  1. internal/s3select/jstream/decoder.go

    func (d *Decoder) number() (float64, error) {
    	d.scratch.reset()
    
    	var (
    		c       = d.cur()
    		n       float64
    		isFloat bool
    	)
    
    	// digits first
    	switch {
    	case c == '0':
    		d.scratch.add(c)
    		c = d.next()
    	case '1' <= c && c <= '9':
    		for ; c >= '0' && c <= '9'; c = d.next() {
    			n = 10*n + float64(c-'0')
    			d.scratch.add(c)
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  2. cmd/metrics-v3-system-cpu.go

    	cpuMetrics, _ := c.cpuMetrics.Get()
    
    	if cpuMetrics.LoadStat != nil {
    		m.Set(sysCPULoad, cpuMetrics.LoadStat.Load1)
    		perc := cpuMetrics.LoadStat.Load1 * 100 / float64(cpuMetrics.CPUCount)
    		m.Set(sysCPULoadPerc, math.Round(perc*100)/100)
    	}
    
    	ts := cpuMetrics.TimesStat
    	if ts != nil {
    		tot := ts.User + ts.System + ts.Idle + ts.Iowait + ts.Nice + ts.Steal
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 20 17:55:03 UTC 2024
    - 3K bytes
    - Viewed (0)
  3. cmd/server-main.go

    			}
    			return nil
    		}
    
    		if configRetriableErrors(err) {
    			logger.Info("Waiting for all MinIO sub-systems to be initialized.. possible cause (%v)", err)
    			time.Sleep(time.Duration(r.Float64() * float64(5*time.Second)))
    			continue
    		}
    
    		// Any other unhandled return right here.
    		return fmt.Errorf("Unable to initialize sub-systems: %w", err)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  4. scan.go

    			scanIntoMap(mapValue, values, columns)
    			*dest = append(*dest, mapValue)
    		}
    	case *int, *int8, *int16, *int32, *int64,
    		*uint, *uint8, *uint16, *uint32, *uint64, *uintptr,
    		*float32, *float64,
    		*bool, *string, *time.Time,
    		*sql.NullInt32, *sql.NullInt64, *sql.NullFloat64,
    		*sql.NullBool, *sql.NullString, *sql.NullTime:
    		for initialized || rows.Next() {
    			initialized = false
    			db.RowsAffected++
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  5. cmd/storage-rest_test.go

    		t.Fatal(err)
    	}
    
    	for {
    		_, err := restClient.DiskInfo(context.Background(), DiskInfoOptions{})
    		if err == nil || errors.Is(err, errUnformattedDisk) {
    			break
    		}
    		time.Sleep(time.Duration(rand.Float64() * float64(100*time.Millisecond)))
    	}
    
    	return restClient
    }
    
    func TestStorageRESTClientDiskInfo(t *testing.T) {
    	restClient := newStorageRESTHTTPServerClient(t)
    
    	testStorageAPIDiskInfo(t, restClient)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  6. cmd/data-scanner.go

    	go func() {
    		r := rand.New(rand.NewSource(time.Now().UnixNano()))
    		// Run the data scanner in a loop
    		for {
    			runDataScanner(ctx, objAPI)
    			duration := time.Duration(r.Float64() * float64(scannerCycle.Load()))
    			if duration < time.Second {
    				// Make sure to sleep at least a second to avoid high CPU ticks.
    				duration = time.Second
    			}
    			time.Sleep(duration)
    		}
    	}()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  7. internal/s3select/parquet/reader.go

    				duration := time.Duration(val) * time.Microsecond
    				value = sql.FormatSQLTimestamp(time.Unix(0, 0).Add(duration))
    			}
    		}
    	case float32:
    		value = float64(val)
    	default:
    		value = v
    	}
    	return value, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  8. internal/s3select/sql/evaluate.go

    	switch rval := result.(type) {
    	case string:
    		return FromString(rval), nil
    	case float64:
    		return FromFloat(rval), nil
    	case int64:
    		return FromInt(rval), nil
    	case uint64:
    		if rval <= math.MaxInt64 {
    			return FromInt(int64(rval)), nil
    		}
    		return FromFloat(float64(rval)), nil
    	case bool:
    		return FromBool(rval), nil
    	case jstream.KVS:
    		bs, err := json.Marshal(result)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12K bytes
    - Viewed (0)
  9. cmd/perf-tests.go

    		}(index)
    	}
    
    	time.Sleep(duration)
    	xioutil.SafeClose(r.eof)
    	wg.Wait()
    	for {
    		if globalNetPerfRX.ActiveConnections() == 0 {
    			break
    		}
    		time.Sleep(time.Second)
    	}
    	rx := float64(globalNetPerfRX.RXSample)
    	delta := globalNetPerfRX.firstToDisconnect.Sub(globalNetPerfRX.lastToConnect)
    	if delta < 0 {
    		rx = 0
    		errStr = "network disconnection issues detected"
    	}
    
    	globalNetPerfRX.Reset()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  10. internal/s3select/sql/timestampfuncs.go

    		_, zoneOffset := t.Zone()
    		return FromInt(int64((zoneOffset % 3600) / 60)), nil
    	default:
    		// This does not happen
    		return nil, errNotImplemented
    	}
    }
    
    func dateAdd(timePart string, qty float64, t time.Time) (*Value, error) {
    	var duration time.Duration
    	switch timePart {
    	case timePartYear:
    		return FromTimestamp(t.AddDate(int(qty), 0, 0)), nil
    	case timePartMonth:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
Back to top