- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 453 for LISTEN (0.22 sec)
-
src/net/mockserver_test.go
} listen := func(net, addr string) Listener { ln, err := lc.Listen(context.Background(), net, addr) if err != nil { t.Helper() t.Fatal(err) } return ln } switch network { case "tcp": if supportsIPv4() { return listen("tcp4", "127.0.0.1:0") } if supportsIPv6() { return listen("tcp6", "[::1]:0") } case "tcp4":
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 13.3K bytes - Viewed (0) -
tests/test_tutorial/test_response_change_status_code/test_tutorial001.py
client = TestClient(app) def test_path_operation(): response = client.put("/get-or-create-task/foo") print(response.content) assert response.status_code == 200, response.text assert response.json() == "Listen to the Bar Fighters" response = client.put("/get-or-create-task/bar") assert response.status_code == 201, response.text
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Jul 09 18:06:12 UTC 2020 - 521 bytes - Viewed (0) -
platforms/jvm/language-java/src/integTest/groovy/org/gradle/api/tasks/JavaExecDebugIntegrationTest.groovy
} def "can debug Java exec with socket listen type debugger (server = false) with task :#taskName"() { setup: sampleProject """ debugOptions { enabled = true server = false suspend = false port = $debugClient.port } """ debugClient.listen() expect: succeeds(taskName)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Feb 28 23:38:57 UTC 2024 - 8.4K bytes - Viewed (0) -
cmd/kube-controller-manager/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: Fri Oct 27 11:28:02 UTC 2023 - 5.4K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stacks.go
go func() { // func8 wg.Wait() }() cv := sync.NewCond(&sync.Mutex{}) go func() { // func9 cv.L.Lock() cv.Wait() cv.L.Unlock() }() ln, err := net.Listen("tcp", "127.0.0.1:0") if err != nil { log.Fatalf("failed to listen: %v", err) } go func() { // func10 c, err := ln.Accept() if err != nil { log.Printf("failed to accept: %v", err) return } c.Close() }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.4K bytes - Viewed (0) -
pkg/kubelet/config/mux.go
channel, exists := m.sources[source] if exists { return channel } newChannel := make(chan interface{}) m.sources[source] = newChannel go wait.Until(func() { m.listen(source, newChannel) }, 0, ctx.Done()) return newChannel } func (m *mux) listen(source string, listenChannel <-chan interface{}) { for update := range listenChannel { m.merger.Merge(source, update) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 20:02:23 UTC 2024 - 2.3K bytes - Viewed (0) -
docs/auditlog/auditlog-echo.md
# `auditlog-echo`: A tool to view MinIO Audit logs on the console 1. Run the tool with: ``` go run docs/auditlog/auditlog-echo.go ``` The listen port has a default value (8080), but can be set with the `-port` flag. 2. Configure audit logging in MinIO with for example: ``` mc admin config set myminio audit_webhook enable=on endpoint=http://localhost:8080 ```
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 01 21:31:13 UTC 2024 - 447 bytes - Viewed (0) -
src/net/file_plan9.go
} switch fd.laddr.(type) { case *TCPAddr: default: return nil, syscall.EPLAN9 } // check that file corresponds to a listener s, err := fd.status(len("Listen")) if err != nil { return nil, err } if s != "Listen" { return nil, errors.New("file does not represent a listener") } return &TCPListener{fd: fd}, nil } func filePacketConn(f *os.File) (PacketConn, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 2.8K bytes - Viewed (0) -
src/net/hook_unix.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 658 bytes - Viewed (0) -
pkg/ctrlz/ctrlz.go
WriteTimeout: time.Minute, // High timeout to allow profiles to run MaxHeaderBytes: 1 << 20, Handler: router, }, } s.shutdown.Add(1) go s.listen() return s, nil } func (s *Server) listen() { log.Infof("ControlZ available at %s", s.httpServer.Addr) if listeningTestProbe != nil { go listeningTestProbe() } err := s.httpServer.Serve(s.listener)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 21:22:53 UTC 2024 - 5.9K bytes - Viewed (0)