- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for netperf (0.05 sec)
-
cmd/peer-rest-client.go
} return *resp, nil } // DevNull - Used by netperf to pump data to peer func (client *peerRESTClient) DevNull(ctx context.Context, r io.Reader) error { respBody, err := client.callWithContext(ctx, peerRESTMethodDevNull, nil, r, -1) if err != nil { return err } defer xhttp.DrainBody(respBody) return err } // Netperf - To initiate netperf on peer
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 26.1K bytes - Viewed (0) -
cmd/globals.go
// Is MINIO_CI_CD set? globalIsCICD bool globalRootDiskThreshold uint64 // Used for collecting stats for netperf globalNetPerfMinDuration = time.Second * 10 globalNetPerfRX netPerfRX globalSiteNetPerfRX netPerfRX globalObjectPerfBucket = "minio-perf-test-tmp-bucket"
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 16.2K bytes - Viewed (1) -
cmd/perf-tests.go
activeConnections uint64 sync.RWMutex } func (n *netPerfRX) Connect() { n.Lock() defer n.Unlock() n.activeConnections++ atomic.StoreUint64(&n.RX, 0) n.lastToConnect = time.Now() } func (n *netPerfRX) Disconnect() { n.Lock() defer n.Unlock() n.activeConnections-- if n.firstToDisconnect.IsZero() {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.7K bytes - Viewed (0) -
cmd/notification.go
}, idx, *client.host) } nerrs := ng.Wait() if freeze { freezeServices() } else { unfreezeServices() } return nerrs } // Netperf - perform mesh style network throughput test func (sys *NotificationSys) Netperf(ctx context.Context, duration time.Duration) []madmin.NetperfNodeResult { length := len(sys.allPeerClients) if length == 0 { // For single node erasure setup. return nil
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.9K bytes - Viewed (0) -
cmd/admin-handlers-site-replication.go
} else { w.WriteHeader(http.StatusBadRequest) } break } } } // SiteReplicationNetPerf - everything goes to io.Discard // [POST] /minio/admin/v3/site-replication/netperf func (a adminAPIHandlers) SiteReplicationNetPerf(w http.ResponseWriter, r *http.Request) { durationStr := r.Form.Get(peerRESTDuration) duration, _ := time.ParseDuration(durationStr) if duration < globalNetPerfMinDuration {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 19.3K bytes - Viewed (0) -
cmd/admin-router.go
adminAPIVersionPrefix = SlashSeparator + adminAPIVersion adminAPISiteReplicationDevNull = "/site-replication/devnull" adminAPISiteReplicationNetPerf = "/site-replication/netperf" adminAPIClientDevNull = "/speedtest/client/devnull" adminAPIClientDevExtraTime = "/speedtest/client/devnull/extratime" ) var gzipHandler = func() func(http.Handler) http.HandlerFunc {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 16 07:34:24 UTC 2025 - 26.7K bytes - Viewed (0) -
docs/nl/docs/index.md
* Validatie zelfs voor diep geneste JSON objecten. * <abbr title="ook bekend als: serialisatie, parsing, marshalling">Conversie</abbr> van invoergegevens: afkomstig van het netwerk naar Python-data en -types. Zoals: * JSON. * Pad parameters. * Query parameters. * Cookies. * Headers. * Formulieren. * Bestanden.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 10:49:48 UTC 2025 - 21.2K bytes - Viewed (0)