- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 351 for dtoi (0.06 sec)
-
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) -
src/cmd/go/testdata/script/test_fuzz_minimize_interesting.txt
package main import ( "bytes" "fmt" "io/ioutil" "os" "path/filepath" "regexp" "strconv" ) func main() { wantLen, err := strconv.Atoi(os.Args[2]) if err != nil { fmt.Fprintln(os.Stderr, err) os.Exit(1) } testName := os.Args[1] dir := filepath.Join("testdata/fuzz", testName) files, err := ioutil.ReadDir(dir) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:32 UTC 2023 - 5.5K bytes - Viewed (0) -
src/net/http/cgi/child.go
} r.URL = url } // Request.RemoteAddr has its port set by Go's standard http // server, so we do here too. remotePort, _ := strconv.Atoi(params["REMOTE_PORT"]) // zero if unset or invalid r.RemoteAddr = net.JoinHostPort(params["REMOTE_ADDR"], strconv.Itoa(remotePort)) return r, nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 5.5K bytes - Viewed (0) -
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) -
src/net/mockserver_test.go
conn, err := FileConn(f) if err != nil { log.Fatal(err) } var chunkSize int if chunkSize, err = strconv.Atoi(os.Getenv("GO_NET_TEST_TRANSFER_CHUNK_SIZE")); err != nil { log.Fatal(err) } buf := make([]byte, chunkSize) var totalSize int if totalSize, err = strconv.Atoi(os.Getenv("GO_NET_TEST_TRANSFER_TOTAL_SIZE")); err != nil { log.Fatal(err) } var fn func([]byte) (int, error)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/kubelet/kubelet_server_journal.go
if len(bootValue) > 0 { boot, err = strconv.Atoi(bootValue) if err != nil { allErrs = append(allErrs, field.Invalid(field.NewPath("boot"), bootValue, err.Error())) } else { nlq.Boot = &boot } } var tailLines int tailLinesValue := query.Get("tailLines") if len(tailLinesValue) > 0 { tailLines, err = strconv.Atoi(tailLinesValue) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 26 18:56:28 UTC 2023 - 13.5K bytes - Viewed (0) -
src/cmd/go/testdata/script/test_fuzz_minimize.txt
package main import ( "bytes" "fmt" "io/ioutil" "os" "path/filepath" "strconv" ) func main() { target := os.Args[1] numBytes, err := strconv.Atoi(os.Args[2]) if err != nil { fmt.Fprintln(os.Stderr, err) os.Exit(1) } // Open the file in testdata (there should only be one) dir := fmt.Sprintf("testdata/fuzz/%s", target)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 22 16:15:36 UTC 2021 - 5.8K bytes - Viewed (0) -
pkg/test/framework/resource/version.go
return "", nil } parts := strings.Split(s, ".") if len(parts) < 2 || len(parts) > 3 { return "", fmt.Errorf("cannot parse version from %s", s) } for _, part := range parts { if _, err := strconv.Atoi(part); err != nil { return "", fmt.Errorf("cannot use %s as version part", part) } } return IstioVersion(s), nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 25 19:30:47 UTC 2022 - 5.7K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcgen_test.go
} _, ports, _ := net.SplitHostPort(lis.Addr().String()) port, _ := strconv.Atoi(ports) // Echo service // initRBACTests(sd, store, "echo-rbac-plain", 14058, false) initRBACTests(sd, ds.Store(), "echo-rbac-mtls", port, true) initPersistent(sd) _, xdsPorts, _ := net.SplitHostPort(ds.Listener.Addr().String()) xdsPort, _ := strconv.Atoi(xdsPorts) addIstiod(sd, xdsPort)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/istio-agent/health/health_check_test.go
} httpServerEventCount++ })) host, ports, err := net.SplitHostPort(strings.TrimPrefix(sss.URL, "http://")) if err != nil { t.Fatal(err) } port, err := strconv.Atoi(ports) if err != nil { t.Fatal(err) } t.Cleanup(sss.Close) httpHealthChecker := NewWorkloadHealthChecker(&v1alpha3.ReadinessProbe{ InitialDelaySeconds: 0, TimeoutSeconds: 1,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 09 16:50:11 UTC 2023 - 6.3K bytes - Viewed (0)