Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 178 for Listen (0.21 sec)

  1. cmd/listen-notification-handlers.go

    			return
    		}
    	}
    
    	rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()})
    
    	setEventStreamHeaders(w)
    
    	// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  2. internal/http/check_port_linux.go

    				}
    			})
    			return nil
    		},
    	}
    
    	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    	defer cancel()
    
    	l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port))
    	if err != nil {
    		return err
    	}
    
    	// As we are able to listen on this network, the port is not in use.
    	// Close the listener and continue check other networks.
    	return l.Close()
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed May 03 21:12:25 GMT 2023
    - 1.9K bytes
    - Viewed (0)
  3. internal/http/check_port_others.go

    // Note: The check method tries to listen on given port and closes it.
    // It is possible to have a disconnected client in this tiny window of time.
    func CheckPortAvailability(host, port string, opts TCPOptions) (err error) {
    	lc := &net.ListenConfig{}
    
    	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    	defer cancel()
    
    	l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port))
    	if err != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed May 03 21:12:25 GMT 2023
    - 1.5K bytes
    - Viewed (0)
  4. internal/grid/debug.go

    		}
    	}
    }
    
    func getHosts(n int) (hosts []string, listeners []net.Listener, err error) {
    	for i := 0; i < n; i++ {
    		l, err := net.Listen("tcp", "127.0.0.1:0")
    		if err != nil {
    			if l, err = net.Listen("tcp6", "[::1]:0"); err != nil {
    				return nil, nil, fmt.Errorf("httptest: failed to listen on a port: %v", err)
    			}
    		}
    		addr := l.Addr()
    		hosts = append(hosts, "http://"+addr.String())
    		listeners = append(listeners, l)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 08 18:15:27 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  5. .github/workflows/multipart/nginx-site1.conf

        upstream minio {
            server site1-minio1:9000;
            server site1-minio2:9000;
            server site1-minio3:9000;
            server site1-minio4:9000;
        }
    
        server {
            listen       9001;
            listen  [::]:9001;
            server_name  localhost;
    
            # To allow special characters in headers
            ignore_invalid_headers off;
            # Allow any size file to be uploaded.
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Sep 30 10:13:56 GMT 2023
    - 1.7K bytes
    - Viewed (0)
  6. internal/http/check_port_test.go

    	if runtime.GOOS != "linux" {
    		t.Skip()
    	}
    
    	l, err := net.Listen("tcp", "localhost:0") // ask kernel for a free port.
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer l.Close()
    
    	port := l.Addr().(*net.TCPAddr).Port
    
    	testCases := []struct {
    		host        string
    		port        int
    		expectedErr error
    	}{
    		{"", port, fmt.Errorf("listen tcp :%v: bind: address already in use", port)},
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed May 03 21:12:25 GMT 2023
    - 1.9K bytes
    - Viewed (0)
  7. .github/workflows/multipart/nginx-site2.conf

        upstream minio {
            server site2-minio1:9000;
            server site2-minio2:9000;
            server site2-minio3:9000;
            server site2-minio4:9000;
        }
    
        server {
            listen       9002;
            listen  [::]:9002;
            server_name  localhost;
    
            # To allow special characters in headers
            ignore_invalid_headers off;
            # Allow any size file to be uploaded.
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Sep 30 10:13:56 GMT 2023
    - 1.7K bytes
    - Viewed (0)
  8. internal/http/listener.go

    		Control: setTCPParametersFn(opts),
    	}
    
    	for i, serverAddr := range serverAddrs {
    		var (
    			l net.Listener
    			e error
    		)
    		if l, e = listenCfg.Listen(ctx, "tcp", serverAddr); e != nil {
    			if opts.Trace != nil {
    				opts.Trace(fmt.Sprint("listenCfg.Listen: ", e.Error()))
    			}
    
    			listenErrs[i] = e
    			continue
    		}
    
    		tcpListener, ok := l.(*net.TCPListener)
    		if !ok {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  9. cni/pkg/monitoring/monitoring.go

    	if port <= 0 {
    		return
    	}
    	mux := http.NewServeMux()
    	var listener net.Listener
    	var err error
    	if listener, err = net.Listen("tcp", fmt.Sprintf(":%d", port)); err != nil {
    		log.Errorf("unable to listen on socket: %v", err)
    		return
    	}
    	exporter, err := monitoring.RegisterPrometheusExporter(nil, nil)
    	if err != nil {
    		log.Errorf("could not set up prometheus exporter: %v", err)
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jun 09 07:54:01 GMT 2023
    - 1.5K bytes
    - Viewed (0)
  10. docs/de/docs/tutorial/body-nested-models.md

        ```
    
    Das bewirkt, dass `tags` eine Liste ist, wenngleich es nichts über den Typ der Elemente der Liste aussagt.
    
    ## Listen mit Typ-Parametern als Felder
    
    Aber Python erlaubt es, Listen mit inneren Typen, auch „Typ-Parameter“ genannt, zu deklarieren.
    
    ### `List` von `typing` importieren
    
    Plain Text
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Fri Mar 22 01:42:11 GMT 2024
    - 10.4K bytes
    - Viewed (0)
Back to top