- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 509 for meisten (0.26 sec)
-
cmd/kube-scheduler/app/testing/testserver.go
} func createListenerOnFreePort() (net.Listener, int, error) { ln, err := net.Listen("tcp", ":0") if err != nil { return nil, 0, err } // get port tcpAddr, ok := ln.Addr().(*net.TCPAddr) if !ok { ln.Close() return nil, 0, fmt.Errorf("invalid listen address: %q", ln.Addr().String()) } return ln, tcpAddr.Port, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 10:35:59 UTC 2023 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/routes/debugsocket.go
if err := os.Remove(s.path); err != nil && !os.IsNotExist(err) { return fmt.Errorf("failed to remove (%v): %v", s.path, err) } l, err := net.Listen("unix", s.path) if err != nil { return fmt.Errorf("listen error (%v): %v", s.path, err) } defer l.Close() srv := http.Server{Handler: s.mux} go func() { <-stopCh srv.Close() }() return srv.Serve(l)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 08 00:33:16 UTC 2022 - 2.2K bytes - Viewed (0) -
docs_src/response_change_status_code/tutorial001.py
from fastapi import FastAPI, Response, status app = FastAPI() tasks = {"foo": "Listen to the Bar Fighters"} @app.put("/get-or-create-task/{task_id}", status_code=200) def get_or_create_task(task_id: str, response: Response): if task_id not in tasks: tasks[task_id] = "This didn't exist before" response.status_code = status.HTTP_201_CREATED
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Mar 26 19:09:53 UTC 2020 - 391 bytes - Viewed (0) -
src/runtime/internal/wasitest/tcpecho_test.go
l, err := net.Listen("tcp", host) if err == nil { l.Close() break } port++ } subProcess := exec.Command("go", "run", "./testdata/tcpecho.go") subProcess.Env = append(os.Environ(), "GOOS=wasip1", "GOARCH=wasm") switch os.Getenv("GOWASIRUNTIME") { case "wazero": subProcess.Env = append(subProcess.Env, "GOWASIRUNTIMEARGS=--listen="+host) case "wasmtime", "":
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 22:01:11 UTC 2024 - 2.4K bytes - Viewed (0) -
pkg/hbone/dialer_test.go
// limitations under the License. package hbone import ( "net" "testing" "time" ) func newTCPServer(t testing.TB, data string) string { n, err := net.Listen("tcp", "127.0.0.1:0") if err != nil { t.Fatal(err) } t.Logf("opened listener on %v", n.Addr().String()) go func() { for { c, err := n.Accept() if err != nil { log.Info(err) return
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 26 23:44:52 UTC 2023 - 2.5K bytes - Viewed (0) -
cmd/kubeadm/app/util/staticpod/utils_test.go
{Name: "listen-metrics-urls", Value: "http://[::1]:1234"}, }, }, }, isIPv6: true, expectedHostname: "::1", expectedPort: 1234, expectedScheme: v1.URISchemeHTTP, }, { name: "etcd probe IPv6 URL with HTTP scheme", cfg: &kubeadmapi.Etcd{ Local: &kubeadmapi.LocalEtcd{ ExtraArgs: []kubeadmapi.Arg{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 12 15:44:44 UTC 2023 - 22.6K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/hbone.go
return nil, nil }, MinVersion: tls.VersionTLS12, } // Listen on the given port and update the port if it changed from what was passed in. listener, port, err = listenOnAddressTLS(c.ListenerIP, c.Port.Port, config) // Store the actual listening port back to the argument. c.Port.Port = port } else { // Listen on the given port and update the port if it changed from what was passed in.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Nov 14 20:23:34 UTC 2022 - 2.7K bytes - Viewed (0) -
src/cmd/trace/testdata/testprog/main.go
done := make(chan error) go blockingSyscall(50*time.Millisecond, done) if err := <-done; err != nil { log.Fatal(err) } // checkNetworkUnblock relies on this. ln, err := net.Listen("tcp", "127.0.0.1:0") if err != nil { log.Fatalf("listen failed: %v", err) } defer ln.Close() go func() { c, err := ln.Accept() if err != nil { return } time.Sleep(time.Millisecond) var buf [1]byte
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 17:15:58 UTC 2024 - 2.5K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stress-start-stop.go
timerDone := make(chan bool) go func() { time.Sleep(time.Millisecond) timerDone <- true }() <-timerDone // A bit of network. ln, err := net.Listen("tcp", "127.0.0.1:0") if err != nil { log.Fatalf("listen failed: %v", err) return } defer ln.Close() go func() { c, err := ln.Accept() if err != nil { return } time.Sleep(time.Millisecond)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.7K bytes - Viewed (0) -
src/net/unixsock_posix.go
laddr = nil } if raddr != nil && raddr.isWildcard() { raddr = nil } if raddr == nil && (sotype != syscall.SOCK_DGRAM || laddr == nil) { return nil, errMissingAddress } case "listen": default: return nil, errors.New("unknown mode: " + mode) } fd, err := socket(ctx, net, syscall.AF_UNIX, sotype, 0, false, laddr, raddr, ctxCtrlFn) if err != nil { return nil, err } return fd, nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 6.6K bytes - Viewed (0)