- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 453 for LISTEN (0.13 sec)
-
src/runtime/testdata/testprognet/waiters.go
// //go:linkname netpollWaiters runtime.netpollWaiters var netpollWaiters atomic.Uint32 func init() { register("NetpollWaiters", NetpollWaiters) } func NetpollWaiters() { listener, err := net.Listen("tcp", "127.0.0.1:0") if err != nil { log.Fatal(err) } var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() conn, err := listener.Accept() if err != nil { log.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 1.3K bytes - Viewed (0) -
src/net/udpsock.go
case "udp", "udp4", "udp6": default: return nil, &OpError{Op: "listen", Net: network, Source: nil, Addr: laddr.opAddr(), Err: UnknownNetworkError(network)} } if laddr == nil { laddr = &UDPAddr{} } sl := &sysListener{network: network, address: laddr.String()} c, err := sl.listenUDP(context.Background(), laddr) if err != nil { return nil, &OpError{Op: "listen", Net: network, Source: nil, Addr: laddr.opAddr(), Err: err} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jul 20 16:58:25 UTC 2023 - 11.8K bytes - Viewed (0) -
cmd/cloud-controller-manager/providers.go
limitations under the License. */ // The external controller manager is responsible for running controller loops that // are cloud provider dependent. It uses the API to listen to new events on resources. package main // NOTE: Importing all in-tree cloud-providers is not required when // implementing an out-of-tree cloud-provider. Leaving this empty file // here as a reference.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 19:11:36 UTC 2024 - 1.2K bytes - Viewed (0) -
src/net/internal/socktest/switch.go
Closed uint64 // number of sockets closed OpenFailed uint64 // number of sockets open failed ConnectFailed uint64 // number of sockets connect failed ListenFailed uint64 // number of sockets listen failed AcceptFailed uint64 // number of sockets accept failed CloseFailed uint64 // number of sockets close failed } func (st Stat) String() string {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 4.8K bytes - Viewed (0) -
build/server-image/kube-apiserver/Dockerfile
# to setup qemu for the builder. FROM --platform=linux/$BUILDARCH ${SETCAP_IMAGE} ARG BINARY COPY ${BINARY} /${BINARY} # We apply cap_net_bind_service so that kube-apiserver can be run as # non-root and still listen on port less than 1024 RUN setcap cap_net_bind_service=+ep /${BINARY} FROM --platform=linux/$TARGETARCH ${BASEIMAGE} ARG BINARY
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 24 20:49:08 UTC 2021 - 1.1K bytes - Viewed (0) -
src/net/tcpsock_test.go
for read := 0; read != len(buf); { n, err := c.Read(buf) read += n if err != nil { b.Log(err) return false } } return true } ln, err := Listen("tcp", laddr) if err != nil { b.Fatal(err) } defer ln.Close() serverSem := make(chan bool, numConcurrent) // Acceptor. go func() { for { c, err := ln.Accept() if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 17.7K bytes - Viewed (0) -
platforms/core-runtime/build-operations/src/main/java/org/gradle/internal/operations/BuildOperationListenerManager.java
/** * Manages listeners of build operations. * * There is one global listener for the life of the build runtime. * Listeners must be sure to remove themselves if they want to only listen for a single build. * * Listeners are notified in registration order. * Started and progress notifications are emitted in registration order, * while finished notifications are emitted in reverse registration order. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 1.7K bytes - Viewed (0) -
src/syscall/net_js.go
func Socket(proto, sotype, unused int) (fd int, err error) { return 0, ENOSYS } func Bind(fd int, sa Sockaddr) error { return ENOSYS } func StopIO(fd int) error { return ENOSYS } func Listen(fd int, backlog int) error { return ENOSYS } func Accept(fd int) (newfd int, sa Sockaddr, err error) { return 0, nil, ENOSYS } func Connect(fd int, sa Sockaddr) error { return ENOSYS }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 25 00:12:41 UTC 2023 - 1.4K bytes - Viewed (0) -
cmd/kubeadm/app/phases/etcd/local.go
{Name: "experimental-initial-corrupt-check", Value: "true"}, {Name: "listen-client-urls", Value: fmt.Sprintf("%s,%s", etcdutil.GetClientURLByIP(etcdLocalhostAddress), etcdutil.GetClientURL(endpoint))}, {Name: "advertise-client-urls", Value: etcdutil.GetClientURL(endpoint)}, {Name: "listen-peer-urls", Value: etcdutil.GetPeerURL(endpoint)},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 14:07:27 UTC 2024 - 13.8K bytes - Viewed (1) -
src/crypto/tls/tls.go
l := new(listener) l.Listener = inner l.config = config return l } // Listen creates a TLS listener accepting connections on the // given network address using net.Listen. // The configuration config must be non-nil and must include // at least one certificate or else set GetCertificate. func Listen(network, laddr string, config *Config) (net.Listener, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 12.2K bytes - Viewed (0)