Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 191 for listen (0.18 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/listener.go

    		}
    	case <-listener.ctx.Done():
    	}
    	return nil, syscall.EINVAL
    }
    
    // Close - closes underneath all TCP listeners.
    func (listener *httpListener) Close() (err error) {
    	listener.ctxCanceler()
    
    	for i := range listener.tcpListeners {
    		listener.tcpListeners[i].Close()
    	}
    
    	return nil
    }
    
    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)
  3. internal/http/check_port_linux.go

    		},
    	}
    
    	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)
  4. 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)
  5. cni/pkg/pluginlistener/listener.go

    	}
    
    	var err error
    	listener, err := net.Listen("unix", path)
    	if err != nil {
    		return nil, fmt.Errorf("failed to listen on unix socket %q: %v", path, err)
    	}
    
    	// Update file permission so that cni plugin has permission to access it.
    	if _, err := os.Stat(path); err != nil {
    		return nil, fmt.Errorf("cni listener file %q doesn't exist", path)
    	}
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 1.7K bytes
    - Viewed (0)
  6. 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)
  7. internal/grid/debug.go

    				panic(err)
    			}
    		}
    	}
    }
    
    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())
    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)
  8. .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)
  9. 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)
  10. .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)
Back to top