- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 108 for perf (0.12 sec)
-
cmd/perf-tests.go
Downloads: totalBytesRead, UploadTimes: uploadTimes, DownloadTimes: downloadTimes, DownloadTTFB: downloadTTFB, Error: retError, }, nil } // To collect RX stats during "mc support perf net" // RXSample holds the RX bytes for the duration between // the last peer to connect and the first peer to disconnect. // This is to improve the RX throughput accuracy. type netPerfRX struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0) -
cmd/globals.go
globalNetPerfRX netPerfRX globalSiteNetPerfRX netPerfRX globalObjectPerfBucket = "minio-perf-test-tmp-bucket" globalObjectPerfUserMetadata = "X-Amz-Meta-Minio-Object-Perf" // Clients can set this to bypass S3 API service freeze. Used by object pref tests. // MinIO version unix timestamp globalVersionUnix uint64 // MinIO client globalMinioClient *minio.Client
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
cmd/speedtest.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 9K bytes - Viewed (0) -
cmd/os-instrumented.go
} // OpenFile captures time taken to call os.OpenFile func OpenFile(name string, flag int, perm os.FileMode) (f *os.File, err error) { switch flag & writeMode { case writeMode: defer updateOSMetrics(osMetricOpenFileW, name)(err) default: defer updateOSMetrics(osMetricOpenFileR, name)(err) } return os.OpenFile(name, flag, perm) } // Access captures time taken to call syscall.Access()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 6.3K bytes - Viewed (0) -
cmd/erasure-common.go
) func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) { disks := er.getDisks() var wg sync.WaitGroup var mu sync.Mutex r := rand.New(rand.NewSource(time.Now().UnixNano())) for _, i := range r.Perm(len(disks)) { i := i wg.Add(1) go func() { defer wg.Done() if disks[i] == nil { return } di, err := disks[i].DiskInfo(context.Background(), DiskInfoOptions{})
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/disk/directio_unix.go
// ODirectPlatform indicates if the platform supports O_DIRECT const ODirectPlatform = true // OpenFileDirectIO - bypass kernel cache. func OpenFileDirectIO(filePath string, flag int, perm os.FileMode) (*os.File, error) { return directio.OpenFile(filePath, flag, perm) } // DisableDirectIO - disables directio mode. func DisableDirectIO(f *os.File) error { fd := f.Fd() flag, err := unix.FcntlInt(fd, unix.F_GETFL, 0) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jun 17 14:31:36 GMT 2023 - 1.6K bytes - Viewed (0) -
cmd/metrics-v3-system-memory.go
package cmd import ( "context" ) const ( memTotal = "total" memUsed = "used" memFree = "free" memBuffers = "buffers" memCache = "cache" memUsedPerc = "used_perc" memShared = "shared" memAvailable = "available" ) var ( memTotalMD = NewGaugeMD(memTotal, "Total memory on the node") memUsedMD = NewGaugeMD(memUsed, "Used memory on the node")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:10:25 GMT 2024 - 2.2K bytes - Viewed (0) -
cmd/object-handlers.go
// proxy to replication target if active-active replication is in place. reader, proxy, perr = proxyGetToReplicationTarget(ctx, bucket, object, rs, r.Header, opts, proxytgts) if perr != nil { globalReplicationStats.incProxy(bucket, getObjectAPI, true) proxyGetErr := ErrorRespToObjectError(perr, bucket, object)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/object_api_suite_test.go
t.Fatalf("%s: <ERROR> %s", instanceType, err) } uploadID := res.UploadID parts := make(map[int]string) metadata := make(map[string]string) for i := 1; i <= 10; i++ { randomPerm := rand.Perm(10) randomString := "" for _, num := range randomPerm { randomString += strconv.Itoa(num) } expectedETaghex := getMD5Hash([]byte(randomString)) metadata["md5"] = expectedETaghex
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 32.3K bytes - Viewed (0) -
cmd/site-replication.go
for i := 1; i < len(s); i++ { if !reflect.DeepEqual(s[i], s[0]) { return errSRIAMConfigMismatch(peers[0].Name, peers[i].Name, s[0], s[i]) } } return nil } // Netperf for site-replication net perf func (c *SiteReplicationSys) Netperf(ctx context.Context, duration time.Duration) (results madmin.SiteNetPerfResult, err error) { infos, err := globalSiteReplicationSys.GetClusterInfo(ctx) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1)