Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for netperf (0.21 sec)

  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)
  2. 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)
  3. 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)
  4. cmd/admin-handlers.go

    		// We need sample size of minimum 10 secs.
    		duration = globalNetPerfMinDuration
    	}
    
    	duration = duration.Round(time.Second)
    
    	results, err := globalSiteReplicationSys.Netperf(ctx, duration)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(toAPIErrorCode(ctx, err)), r.URL)
    		return
    	}
    	enc := json.NewEncoder(w)
    	if err := enc.Encode(results); err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  5. cmd/site-replication.go

    		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 {
    		return results, err
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
  6. 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)
Back to top