Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 81 for hasPrefix (0.05 sec)

  1. cmd/metacache-server-pool.go

    	if o.Marker < o.Prefix {
    		o.Marker = ""
    	}
    
    	// Marker is set validate pre-condition.
    	if o.Marker != "" && o.Prefix != "" {
    		// Marker not common with prefix is not implemented. Send an empty response
    		if !HasPrefix(o.Marker, o.Prefix) {
    			return entries, io.EOF
    		}
    	}
    
    	// With max keys of zero we have reached eof, return right here.
    	if o.Limit == 0 {
    		return entries, io.EOF
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  2. cmd/http-tracer.go

    		reqEndTime := time.Now().UTC()
    
    		if globalTrace.NumSubscribers(madmin.TraceS3|madmin.TraceInternal) == 0 {
    			// no subscribers nothing to trace.
    			return
    		}
    
    		tt := madmin.TraceInternal
    		if strings.HasPrefix(tc.FuncName, "s3.") {
    			tt = madmin.TraceS3
    		}
    
    		// Calculate input body size with headers
    		reqHeaders := r.Header.Clone()
    		reqHeaders.Set("Host", r.Host)
    		if len(r.TransferEncoding) == 0 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. internal/s3select/sql/value.go

    		return nil
    	}
    	if x, ok := v.bytesToBool(); ok {
    		v.setBool(x)
    		return nil
    	}
    
    	asString := strings.TrimSpace(v.bytesToString())
    	if len(b) > 0 &&
    		(strings.HasPrefix(asString, "{") || strings.HasPrefix(asString, "[")) {
    		return nil
    	}
    
    	if t, err := parseSQLTimestamp(asString); err == nil {
    		v.setTimestamp(t)
    		return nil
    	}
    	if !utf8.Valid(b) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  4. internal/grid/connection.go

    	c.incomingBytes = func(n int64) {
    		if o.incomingBytes != nil {
    			o.incomingBytes(n)
    		}
    		c.inBytes.Add(n)
    	}
    	if !strings.HasPrefix(o.remote, "https://") && !strings.HasPrefix(o.remote, "wss://") {
    		c.baseFlags |= FlagCRCxxh3
    	}
    	if !strings.HasPrefix(o.local, "https://") && !strings.HasPrefix(o.local, "wss://") {
    		c.baseFlags |= FlagCRCxxh3
    	}
    	if o.publisher != nil {
    		c.traceRequests(o.publisher)
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 46.9K bytes
    - Viewed (0)
  5. callbacks/associations.go

    		refName        = rel.Name + "."
    		values         = rValues.Interface()
    	)
    
    	for name, ok := range selectColumns {
    		columnName := ""
    		if strings.HasPrefix(name, refName) {
    			columnName = strings.TrimPrefix(name, refName)
    		}
    
    		if columnName != "" {
    			if ok {
    				selects = append(selects, columnName)
    			} else {
    				omits = append(omits, columnName)
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Thu Feb 13 06:16:26 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  6. cmd/os_unix.go

    // directories that MkdirAll creates.
    // If path is already a directory, MkdirAll does nothing
    // and returns nil.
    func osMkdirAll(dirPath string, perm os.FileMode, baseDir string) error {
    	if baseDir != "" {
    		if strings.HasPrefix(baseDir, dirPath) {
    			return nil
    		}
    	}
    
    	// Slow path: make sure parent exists and then call Mkdir for path.
    	i := len(dirPath)
    	for i > 0 && os.IsPathSeparator(dirPath[i-1]) { // Skip trailing path separator.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  7. internal/http/listener_test.go

    			localIP4.Add(ip.String())
    		}
    	}
    
    	// Filter ipList by IPs those do not start with '127.'.
    	nonLoopBackIPs := localIP4.FuncMatch(func(ip string, matchString string) bool {
    		return !strings.HasPrefix(ip, "127.")
    	}, "")
    	if len(nonLoopBackIPs) == 0 {
    		t.Fatalf("No non-loop back IP address found for this host")
    	}
    	nonLoopBackIP := nonLoopBackIPs.ToSlice()[0]
    	return nonLoopBackIP
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  8. cmd/bucket-listobjects-handlers.go

    		if !strings.EqualFold(encodingType, "url") {
    			return ErrInvalidEncodingMethod
    		}
    	}
    
    	if !IsValidObjectPrefix(prefix) {
    		return ErrInvalidObjectName
    	}
    
    	if marker != "" && !HasPrefix(marker, prefix) {
    		return ErrNotImplemented
    	}
    
    	return ErrNone
    }
    
    func (api objectAPIHandlers) ListObjectVersionsHandler(w http.ResponseWriter, r *http.Request) {
    	api.listObjectVersionsHandler(w, r, false)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  9. cmd/common-main.go

    func parsEnvEntry(envEntry string) (envKV, error) {
    	envEntry = strings.TrimSpace(envEntry)
    	if envEntry == "" {
    		// Skip all empty lines
    		return envKV{
    			Skip: true,
    		}, nil
    	}
    	if strings.HasPrefix(envEntry, "#") {
    		// Skip commented lines
    		return envKV{
    			Skip: true,
    		}, nil
    	}
    	envTokens := strings.SplitN(strings.TrimSpace(strings.TrimPrefix(envEntry, "export")), config.EnvSeparator, 2)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (3)
  10. cmd/metrics-v3.go

    	metricsCache := newMetricsCache()
    	mgMap := make(map[collectorPath]*MetricsGroup)
    	bucketMGMap := make(map[collectorPath]*MetricsGroup)
    	for _, mg := range allMetricGroups {
    		if !strings.HasPrefix(string(mg.CollectorPath), clusterBasePath) {
    			mg.AddExtraLabels(
    				serverName, globalLocalNodeName,
    				// poolIndex, strconv.Itoa(globalLocalPoolIdx),
    			)
    		}
    		mg.SetCache(metricsCache)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 02 00:55:27 UTC 2024
    - 13.6K bytes
    - Viewed (0)
Back to top