Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 119 for we (0.13 sec)

  1. cmd/server-rlimit.go

    )
    
    func oldLinux() bool {
    	currentKernel, err := kernel.CurrentVersion()
    	if err != nil {
    		// Could not probe the kernel version
    		return false
    	}
    
    	if currentKernel == 0 {
    		// We could not get any valid value return false
    		return false
    	}
    
    	// legacy linux indicator for printing warnings
    	// about older Linux kernels and Go runtime.
    	return currentKernel < kernel.Version(4, 0, 0)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:06:57 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  2. cmd/metrics-v3-system-cpu.go

    	cpuStealVal := math.Round(ts.Steal/tot*100*100) / 100
    	m.Set(sysCPUSteal, cpuStealVal)
    
    	// metrics-resource.go runs a job to collect resource metrics including their Avg values and
    	// stores them in resourceMetricsMap. We can use it to get the Avg values of CPU idle and IOWait.
    	cpuResourceMetrics, found := resourceMetricsMap[cpuSubsystem]
    	if found {
    		if cpuIdleMetric, ok := cpuResourceMetrics[getResourceKey(cpuIdle, nil)]; ok {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 3K bytes
    - Viewed (0)
  3. internal/bucket/bandwidth/reader.go

    			need = int(math.Min(float64(b-hdr), float64(need))) // use remaining tokens towards payload
    			tokens = need + hdr
    
    		} else { // part of header can be accommodated
    			r.opts.HeaderSize -= b - 1
    			need = 1 // to ensure we read at least one byte for every Read
    			tokens = b
    		}
    	} else { // all tokens go towards payload
    		need = int(math.Min(float64(b), float64(need)))
    		tokens = need
    	}
    
    	err = r.throttle.WaitN(r.ctx, tokens)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Sep 06 03:21:59 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  4. internal/mountinfo/mountinfo_linux_test.go

    		`
    	var err error
    	dir := t.TempDir()
    	mountsPath := filepath.Join(dir, "mounts")
    	if err = os.WriteFile(mountsPath, []byte(successCase), 0o666); err != nil {
    		t.Fatal(err)
    	}
    	// Failure case where we detected successfully cross device mounts.
    	{
    		absPaths := []string{"/path/to/1"}
    		if err = checkCrossDevice(absPaths, mountsPath); err == nil {
    			t.Fatal("Expected to fail, but found success")
    		}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.3K bytes
    - Viewed (0)
  5. internal/bpool/bpool_test.go

    		t.Fatalf("bytepool length invalid: got %v want %v", len(b), width)
    	}
    	if cap(b) != capWidth {
    		t.Fatalf("bytepool length invalid: got %v want %v", cap(b), capWidth)
    	}
    
    	bufPool.Put(b)
    
    	// Close the channel so we can iterate over it.
    	close(bufPool.c)
    
    	// Check the size of the pool.
    	if uint64(len(bufPool.c)) != size {
    		t.Fatalf("bytepool size invalid: got %v want %v", len(bufPool.c), size)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 19:13:27 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  6. internal/grid/stream.go

    			}
    		}
    	}()
    	doneCh := s.ctx.Done()
    	for {
    		select {
    		case <-doneCh:
    			if err := context.Cause(s.ctx); !errors.Is(err, errStreamEOF) {
    				return err
    			}
    			// Fall through to be sure we have returned all responses.
    			doneCh = nil
    		case resp, ok := <-s.responses:
    			if !ok {
    				done = true
    				return nil
    			}
    			if resp.Err != nil {
    				return resp.Err
    			}
    			err = next(resp.Msg)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 28 18:05:18 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  7. cmd/bucket-versioning-handler.go

    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Call site replication hook.
    	//
    	// We encode the xml bytes as base64 to ensure there are no encoding
    	// errors.
    	cfgStr := base64.StdEncoding.EncodeToString(configData)
    	replLogIf(ctx, globalSiteReplicationSys.BucketMetaHook(ctx, madmin.SRBucketMeta{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 5K bytes
    - Viewed (0)
  8. internal/config/subnet/config.go

    	cfg.APIKey = strings.TrimSpace(env.Get(config.EnvMinIOSubnetAPIKey, kvs.Get(config.APIKey)))
    	cfg.Proxy = proxy
    
    	if transport == nil {
    		// when transport is nil, it means we are just validating the
    		// inputs not performing any network calls.
    		return cfg, nil
    	}
    
    	// Make sure to clone the transport before editing the ProxyURL
    	if proxyURL != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Nov 24 17:59:35 GMT 2023
    - 3.8K bytes
    - Viewed (0)
  9. cmd/update-notifier.go

    	line2InColor := fmt.Sprintf(msgLine2Fmt, color.CyanBold(updateString))
    
    	// calculate the rectangular box size.
    	maxContentWidth := max(line1Length, line2Length)
    
    	// termWidth is set to a default one to use when we are
    	// not able to calculate terminal width via OS syscalls
    	termWidth := 25
    	if width, err := pb.GetTerminalWidth(); err == nil {
    		termWidth = width
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Mar 09 03:07:08 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  10. cmd/config.go

    					continue
    				}
    
    				cfgEntry.Data = string(data)
    			}
    			configHistory = append(configHistory, cfgEntry)
    			count--
    			if count == 0 {
    				break
    			}
    		}
    		if !res.IsTruncated {
    			// We are done here
    			break
    		}
    		marker = res.NextMarker
    	}
    	sort.Slice(configHistory, func(i, j int) bool {
    		return configHistory[i].CreateTime.Before(configHistory[j].CreateTime)
    	})
    	return configHistory, nil
    }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Aug 23 10:07:06 GMT 2023
    - 6K bytes
    - Viewed (0)
Back to top