Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 334 for esse (0.16 sec)

  1. internal/rest/rpc-stats.go

    		if ds := atomic.LoadInt64(&dialStart); ds > 0 {
    			if de := atomic.LoadInt64(&dialEnd); de == 0 {
    				atomic.AddUint64(&globalStats.tcpDialErrs, 1)
    			} else if de >= ds {
    				atomic.AddUint64(&globalStats.tcpDialCount, 1)
    				atomic.AddUint64(&globalStats.tcpDialTotalDur, uint64(dialEnd-dialStart))
    			}
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 16:27:58 GMT 2022
    - 2.3K bytes
    - Viewed (0)
  2. cmd/signature-v4-utils.go

    	var (
    		v  []string
    		ok bool
    	)
    
    	if isRequestPresignedSignatureV4(r) {
    		v, ok = r.Form[xhttp.AmzContentSha256]
    		if !ok {
    			v, ok = r.Header[xhttp.AmzContentSha256]
    		}
    	} else {
    		v, ok = r.Header[xhttp.AmzContentSha256]
    	}
    
    	// Skip if no header was set.
    	if !ok {
    		return true
    	}
    
    	// If x-amz-content-sha256 is set and the value is not
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 18:56:45 GMT 2024
    - 9K bytes
    - Viewed (0)
  3. cmd/tier-last-day-stats.go

    func (l lastDayTierStats) merge(m lastDayTierStats) (merged lastDayTierStats) {
    	cl := l.clone()
    	cm := m.clone()
    
    	if cl.UpdatedAt.After(cm.UpdatedAt) {
    		cm.forwardTo(cl.UpdatedAt)
    		merged.UpdatedAt = cl.UpdatedAt
    	} else {
    		cl.forwardTo(cm.UpdatedAt)
    		merged.UpdatedAt = cm.UpdatedAt
    	}
    
    	for i := range cl.Bins {
    		merged.Bins[i] = cl.Bins[i].add(cm.Bins[i])
    	}
    
    	return merged
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  4. cmd/encryption-v1_test.go

    			t.Errorf("Test %d: Decryption returned wrong error code: got %d , want %d", i, err, test.expErr)
    		} else if _, enc := crypto.IsEncrypted(test.info.UserDefined); encrypted && enc != encrypted {
    			t.Errorf("Test %d: Decryption thinks object is encrypted but it is not", i)
    		} else if !encrypted && enc != encrypted {
    			t.Errorf("Test %d: Decryption thinks object is not encrypted but it is", i)
    		}
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Sep 24 04:17:08 GMT 2022
    - 19.9K bytes
    - Viewed (0)
  5. cmd/metrics-v2_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, "StaticLabels")
    				return
    			}
    			if z.StaticLabels == nil {
    				z.StaticLabels = make(map[string]string, zb0002)
    			} else if len(z.StaticLabels) > 0 {
    				for key := range z.StaticLabels {
    					delete(z.StaticLabels, key)
    				}
    			}
    			for zb0002 > 0 {
    				var za0001 string
    				var za0002 string
    				zb0002--
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 19.2K bytes
    - Viewed (0)
  6. buildscripts/gen-ldflags.go

    		fmt.Fprintln(os.Stderr, "Error generating git commit-time: ", err)
    		os.Exit(1)
    	}
    
    	return t.UTC()
    }
    
    func main() {
    	var version string
    	if len(os.Args) > 1 {
    		version = os.Args[1]
    	} else {
    		version = commitTime().Format(time.RFC3339)
    	}
    
    	fmt.Println(genLDFlags(version))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jun 16 23:10:48 GMT 2022
    - 3.3K bytes
    - Viewed (0)
  7. internal/grid/trace.go

    	resp, err := c.roundtrip(h, req)
    	end := time.Now()
    	status := http.StatusOK
    	errString := ""
    	if err != nil {
    		errString = err.Error()
    		if IsRemoteErr(err) == nil {
    			status = http.StatusInternalServerError
    		} else {
    			status = http.StatusBadRequest
    		}
    	}
    
    	prefix := t.Prefix
    	if p := handlerPrefixes[h]; p != "" {
    		prefix = p
    	}
    	trace := madmin.TraceInfo{
    		TraceType: t.TraceType,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 02 22:54:54 GMT 2024
    - 4K bytes
    - Viewed (0)
  8. docs/sts/assume-role.go

    	stsOpts.SecretKey = minioPassword
    
    	if sessionPolicyFile != "" {
    		var policy string
    		if f, err := os.Open(sessionPolicyFile); err != nil {
    			log.Fatalf("Unable to open session policy file: %v", err)
    		} else {
    			defer f.Close()
    			bs, err := io.ReadAll(f)
    			if err != nil {
    				log.Fatalf("Error reading session policy file: %v", err)
    			}
    			policy = string(bs)
    		}
    		stsOpts.Policy = policy
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 16:09:55 GMT 2024
    - 4K bytes
    - Viewed (1)
  9. cmd/generic-handlers_test.go

    		test := test
    		t.Run("", func(t *testing.T) {
    			contains := containsReservedMetadata(test.header)
    			if contains && !test.shouldFail {
    				t.Errorf("contains reserved header but should not fail")
    			} else if !contains && test.shouldFail {
    				t.Errorf("does not contain reserved header but failed")
    			}
    		})
    	}
    }
    
    var sseTLSHandlerTests = []struct {
    	URL               *url.URL
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  10. internal/logger/targets.go

    func splitTargets(targets []Target, t types.TargetType) (group1 []Target, group2 []Target) {
    	for _, target := range targets {
    		if target.Type() == t {
    			group1 = append(group1, target)
    		} else {
    			group2 = append(group2, target)
    		}
    	}
    	return
    }
    
    func cancelTargets(targets []Target) {
    	for _, target := range targets {
    		go target.Cancel()
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 22:56:14 GMT 2024
    - 6.1K bytes
    - Viewed (0)
Back to top