Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 12 of 12 for drain (0.12 sec)

  1. cmd/bucket-replication.go

    	client := &http.Client{
    		Transport: globalRemoteTargetTransport,
    		Timeout:   10 * time.Second,
    	}
    
    	resp, err := client.Do(req)
    	if err != nil {
    		return err
    	}
    	if err == nil {
    		// Drain the connection.
    		xhttp.DrainBody(resp.Body)
    	}
    	if resp != nil {
    		amzid := resp.Header.Get(xhttp.AmzRequestHostID)
    		if _, ok := globalNodeNamesHex[amzid]; ok {
    			return BucketRemoteIdenticalToSource{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  2. internal/dsync/drwmutex.go

    	// for this instance of unlocker, we should let the
    	// caller know that lock is not successfully released
    	// yet.
    	if len(locks)-tolerance == tolerance {
    		// In case of split brain scenarios where
    		// tolerance is exactly half of the len(*locks)
    		// then we need to make sure we have unlocked
    		// upto tolerance+1 - especially for RUnlock
    		// to ensure that we don't end up with active
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
Back to top