- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 74 for window (0.18 sec)
-
cmd/bucket-replication-metrics.go
prev := s.buf[s.idx] s.buf[s.idx] = next if s.filledBuf { s.prevSMA += (next - prev) / float64(s.window) s.CAvg += (next - s.CAvg) / float64(s.window) } else { s.CAvg = s.simpleMovingAvg() s.prevSMA = s.CAvg } if s.idx == s.window-1 { s.filledBuf = true } s.idx = (s.idx + 1) % s.window } func (s *SMA) simpleMovingAvg() float64 { if s.filledBuf { return s.prevSMA }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/http/check_port_others.go
"time" ) // CheckPortAvailability - check if given host and port is already in use. // Note: The check method tries to listen on given port and closes it. // It is possible to have a disconnected client in this tiny window of time. func CheckPortAvailability(host, port string, opts TCPOptions) (err error) { lc := &net.ListenConfig{} ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.5K bytes - Viewed (0) -
internal/s3select/progress.go
pbzip2.BZConcurrency((runtime.GOMAXPROCS(0)+1)/2), pbzip2.BZConcurrencyPool(bz2Limiter), )) pr.closer = &nopReadCloser{fn: cancel} case zstdType: // Set a max window of 64MB. More than reasonable. zr, err := zstd.NewReader(scannedReader, zstd.WithDecoderConcurrency(2), zstd.WithDecoderMaxWindow(64<<20)) if err != nil { return nil, errInvalidCompression(err, compType) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Oct 18 15:44:36 GMT 2021 - 4.2K bytes - Viewed (0) -
internal/bucket/bandwidth/measurement.go
type bucketMeasurement struct { lock sync.Mutex bytesSinceLastWindow uint64 // Total bytes since last window was processed startTime time.Time // Start time for window expMovingAvg float64 // Previously calculate sliding window } // newBucketMeasurement creates a new instance of the measurement with the initial start time.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Jun 03 20:41:51 GMT 2023 - 2.9K bytes - Viewed (0) -
cmd/handler-api.go
} if cap(t.requestsPool) != apiRequestsMaxPerNode { // Only replace if needed. // Existing requests will use the previous limit, // but new requests will use the new limit. // There will be a short overlap window, // but this shouldn't last long. t.requestsPool = make(chan struct{}, apiRequestsMaxPerNode) } t.requestsDeadline = cfg.RequestsDeadline listQuorum := cfg.ListQuorum if listQuorum == "" {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 09:22:27 GMT 2024 - 10K bytes - Viewed (0) -
internal/http/check_port_linux.go
"time" ) // CheckPortAvailability - check if given host and port is already in use. // Note: The check method tries to listen on given port and closes it. // It is possible to have a disconnected client in this tiny window of time. func CheckPortAvailability(host, port string, opts TCPOptions) (err error) { lc := &net.ListenConfig{ Control: func(network, address string, c syscall.RawConn) error { c.Control(func(fdPtr uintptr) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.9K bytes - Viewed (0) -
internal/disk/stat_windows.go
package disk import ( "errors" "fmt" "os" "syscall" "unsafe" "golang.org/x/sys/windows" ) var ( kernel32 = windows.NewLazySystemDLL("kernel32.dll") // GetDiskFreeSpaceEx - https://msdn.microsoft.com/en-us/library/windows/desktop/aa364937(v=vs.85).aspx // Retrieves information about the amount of space that is available on a disk volume,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 4.1K bytes - Viewed (0) -
cmd/os_windows.go
//go:build windows // +build windows // Copyright (c) 2015-2021 MinIO, Inc. // // This file is part of MinIO Object Storage stack // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU Affero General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. //
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 5.1K bytes - Viewed (0) -
internal/ioutil/append-file_nix.go
//go:build !windows // +build !windows // Copyright (c) 2015-2021 MinIO, Inc. // // This file is part of MinIO Object Storage stack // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU Affero General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. //
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 1.3K bytes - Viewed (0) -
internal/disk/stat_test.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 3.6K bytes - Viewed (0)