Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 57 for dtoi (0.04 sec)

  1. cmd/kube-proxy/app/conntrack.go

    	}
    
    	return false, errors.New("no sysfs mounted")
    }
    
    func readIntStringFile(filename string) (int, error) {
    	b, err := os.ReadFile(filename)
    	if err != nil {
    		return -1, err
    	}
    	return strconv.Atoi(strings.TrimSpace(string(b)))
    }
    
    func writeIntStringFile(filename string, value int) error {
    	return os.WriteFile(filename, []byte(strconv.Itoa(value)), 0640)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  2. docs/debugging/s3-check-md5/main.go

    				continue
    			}
    			parts := 1
    			multipart := false
    			s := strings.Split(object.ETag, "-")
    			switch len(s) {
    			case 1:
    				// nothing to do
    			case 2:
    				if p, err := strconv.Atoi(s[1]); err == nil {
    					parts = p
    				} else {
    					log.Println("FAILED: ETAG of", objFullPath(object), "has a wrong format:", err)
    					continue
    				}
    				multipart = true
    			default:
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Feb 17 01:15:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  3. internal/config/browser/browser.go

    	hstsPreload := env.Get(EnvBrowserHSTSPreload, kvs.Get(browserHSTSPreload)) == config.EnableOn
    
    	hstsSeconds, err := strconv.Atoi(env.Get(EnvBrowserHSTSSeconds, kvs.GetWithDefault(browserHSTSSeconds, DefaultKVS)))
    	if err != nil {
    		return cfg, err
    	}
    
    	cfg.HSTSSeconds = hstsSeconds
    	cfg.HSTSIncludeSubdomains = hstsIncludeSubdomains
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (1)
  4. cmd/listen-notification-handlers.go

    		}
    		peer.Listen(ctx, mergeCh, values)
    	}
    
    	var (
    		emptyEventTicker <-chan time.Time
    		keepAliveTicker  <-chan time.Time
    	)
    
    	if p := values.Get("ping"); p != "" {
    		pingInterval, err := strconv.Atoi(p)
    		if err != nil {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidQueryParams), r.URL)
    			return
    		}
    		if pingInterval < 1 {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  5. pilot/cmd/pilot-agent/config/config.go

    	if v, f := annos[annotation.SidecarDiscoveryAddress.Name]; f {
    		config.DiscoveryAddress = v
    	}
    	if v, f := annos[annotation.SidecarStatusPort.Name]; f {
    		p, err := strconv.Atoi(v)
    		if err != nil {
    			log.Errorf("Invalid annotation %v=%v: %v", annotation.SidecarStatusPort.Name, v, err)
    		}
    		config.StatusPort = int32(p)
    	}
    	return config
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  6. src/internal/coverage/pods/pods.go

    	for k, f := range files {
    		base := filepath.Base(f)
    		if m := counterRE.FindStringSubmatch(base); m != nil {
    			tag := m[1] // meta hash
    			pid, err := strconv.Atoi(m[2])
    			if err != nil {
    				continue
    			}
    			if v, ok := mm[tag]; ok {
    				idx := -1
    				if dirIndices != nil {
    					idx = dirIndices[k]
    				}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  7. pkg/controller/ttl/ttl_controller.go

    	if node.Annotations == nil {
    		return 0, false
    	}
    	annotationValue, ok := node.Annotations[annotationKey]
    	if !ok {
    		return 0, false
    	}
    	intValue, err := strconv.Atoi(annotationValue)
    	if err != nil {
    		logger := klog.FromContext(ctx)
    		logger.Info("Could not convert the value with annotation key for the node", "annotationValue",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  8. pkg/config/security/security.go

    		info.Port = 80
    	case "https":
    		info.UseSSL = true
    		info.Port = 443
    	default:
    		return JwksInfo{}, fmt.Errorf("URI scheme %q is not supported", u.Scheme)
    	}
    
    	if u.Port() != "" {
    		info.Port, err = strconv.Atoi(u.Port())
    		if err != nil {
    			return JwksInfo{}, err
    		}
    	}
    	info.Hostname = host.Name(u.Hostname())
    	info.Scheme = u.Scheme
    
    	return info, nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 07 04:43:34 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  9. src/mime/multipart/formdata.go

    		combineFiles = false
    		// multipartfiles.IncNonDefault() // TODO: uncomment after documenting
    	}
    	maxParts := 1000
    	if s := multipartmaxparts.Value(); s != "" {
    		if v, err := strconv.Atoi(s); err == nil && v >= 0 {
    			maxParts = v
    			multipartmaxparts.IncNonDefault()
    		}
    	}
    	maxHeaders := maxMIMEHeaders()
    
    	defer func() {
    		if file != nil {
    			if cerr := file.Close(); err == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 21 16:12:35 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  10. pkg/test/framework/components/istio/ingress.go

    	for _, addr := range anyRemoteAddrs {
    		switch v := addr.(type) {
    		case string:
    			host, portStr, err := net.SplitHostPort(v)
    			if err != nil {
    				return nil, nil, err
    			}
    			mappedPort, err := strconv.Atoi(portStr)
    			if err != nil {
    				return nil, nil, err
    			}
    			addrs = append(addrs, host)
    			ports = append(ports, mappedPort)
    		case netip.AddrPort:
    			addrs = append(addrs, v.Addr().String())
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 29 17:13:34 UTC 2024
    - 8K bytes
    - Viewed (0)
Back to top