- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 453 for LISTEN (0.2 sec)
-
src/net/sock_windows.go
) func maxListenerBacklog() int { // When the socket backlog is SOMAXCONN, Windows will set the backlog to // "a reasonable maximum value". // See: https://learn.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-listen return syscall.SOMAXCONN } func sysSocket(family, sotype, proto int) (syscall.Handle, error) { s, err := wsaSocketFunc(int32(family), int32(sotype), int32(proto),
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 08 18:52:56 UTC 2024 - 802 bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/junit/junit4/AbstractJUnit4TestListenerIntegrationTest.groovy
abstract String getTestFrameworkJUnit3Dependencies() @Override String getAssertionError() { return "java.lang.AssertionError" } def "can listen for test results when JUnit3 is used"() { given: file('src/test/java/SomeTest.java') << """ public class SomeTest extends junit.framework.TestCase { public void testPass() { }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 5.4K bytes - Viewed (0) -
samples/jwt-server/src/main.go
response.Write([]byte(string(jwtKey))) } func (s *JWTServer) startHTTP(address string, wg *sync.WaitGroup) { defer func() { wg.Done() log.Printf("Stopped JWT HTTP server") }() listener, err := net.Listen("tcp", address) if err != nil { log.Fatalf("Failed to create HTTP server: %v", err) } // Store the port for test only. s.httpPort <- listener.Addr().(*net.TCPAddr).Port s.httpServer = &http.Server{Handler: s}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 16 23:56:50 UTC 2024 - 4.4K bytes - Viewed (0) -
security/pkg/nodeagent/caclient/providers/citadel/client_test.go
} func serve(t *testing.T, ca mockCAServer, opts ...grpc.ServerOption) string { // create a local grpc server s := grpc.NewServer(opts...) t.Cleanup(s.Stop) lis, err := net.Listen("tcp", mockServerAddress) if err != nil { t.Fatalf("failed to listen: %v", err) } go func() { pb.RegisterIstioCertificateServiceServer(s, &ca) if err := s.Serve(lis); err != nil { t.Logf("failed to serve: %v", err) } }()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 21:03:23 UTC 2024 - 11.8K bytes - Viewed (0) -
src/net/sockopt_solaris.go
return os.NewSyscallError("setsockopt", syscall.SetsockoptInt(s, syscall.SOL_SOCKET, syscall.SO_REUSEADDR, 1)) } func setDefaultMulticastSockopts(s int) error { // Allow multicast UDP and raw IP datagram sockets to listen // concurrently across multiple listeners. return os.NewSyscallError("setsockopt", syscall.SetsockoptInt(s, syscall.SOL_SOCKET, syscall.SO_REUSEADDR, 1))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 09 00:33:27 UTC 2020 - 1.3K bytes - Viewed (0) -
src/net/sockopt_linux.go
return os.NewSyscallError("setsockopt", syscall.SetsockoptInt(s, syscall.SOL_SOCKET, syscall.SO_REUSEADDR, 1)) } func setDefaultMulticastSockopts(s int) error { // Allow multicast UDP and raw IP datagram sockets to listen // concurrently across multiple listeners. return os.NewSyscallError("setsockopt", syscall.SetsockoptInt(s, syscall.SOL_SOCKET, syscall.SO_REUSEADDR, 1))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 09 00:33:27 UTC 2020 - 1.3K bytes - Viewed (0) -
cluster/images/etcd/migrate/migrate_server.go
"--name", r.cfg.name, "--initial-cluster", r.cfg.initialCluster, "--debug", "--data-dir", r.cfg.dataDirectory, "--listen-client-urls", r.cfg.clientListenUrls, "--advertise-client-urls", fmt.Sprintf("http://127.0.0.1:%d", r.cfg.port), "--listen-peer-urls", r.cfg.peerListenUrls, "--initial-advertise-peer-urls", r.cfg.peerAdvertiseUrls, ) if r.cfg.etcdServerArgs != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 30 16:29:59 UTC 2022 - 3.8K bytes - Viewed (0) -
src/net/sockopt_aix.go
return os.NewSyscallError("setsockopt", syscall.SetsockoptInt(s, syscall.SOL_SOCKET, syscall.SO_REUSEADDR, 1)) } func setDefaultMulticastSockopts(s int) error { // Allow multicast UDP and raw IP datagram sockets to listen // concurrently across multiple listeners. if err := syscall.SetsockoptInt(s, syscall.SOL_SOCKET, syscall.SO_REUSEADDR, 1); err != nil { return os.NewSyscallError("setsockopt", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 09 00:33:27 UTC 2020 - 1.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection_test.go
"github.com/moby/spdystream" "k8s.io/apimachinery/pkg/util/httpstream" ) func runProxy(t *testing.T, backendUrl string, proxyUrl chan<- string, proxyDone chan<- struct{}, errCh chan<- error) { listener, err := net.Listen("tcp4", "localhost:0") if err != nil { errCh <- err return } defer listener.Close() proxyUrl <- listener.Addr().String() clientConn, err := listener.Accept() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 01 11:58:57 UTC 2023 - 7.9K bytes - Viewed (0) -
cmd/kube-controller-manager/controller-manager.go
limitations under the License. */ // The controller manager is responsible for monitoring replication // controllers, and creating corresponding pods to achieve the desired // state. It uses the API to listen for new controllers and to create/delete // pods. package main import ( "os" _ "time/tzdata" // for CronJob Time Zone support "k8s.io/component-base/cli"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 28 21:33:00 UTC 2022 - 1.3K bytes - Viewed (0)