Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 448 for meisten (0.12 sec)

  1. pkg/istio-agent/health/health_check_test.go

    	d.port = sa.(*syscall.SockaddrInet4).Port
    	return d, nil
    }
    
    func (d *DelayedListener) Address() string {
    	return net.JoinHostPort("127.0.0.1", strconv.Itoa(d.port))
    }
    
    func (d *DelayedListener) Listen() error {
    	if err := syscall.Listen(d.fd, 128); err != nil {
    		return nil
    	}
    	return nil
    }
    
    func (d *DelayedListener) Close() error {
    	if err := syscall.Close(d.fd); err != nil {
    		return nil
    	}
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Aug 09 16:50:11 UTC 2023
    - 6.3K 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()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  3. tensorflow/compiler/jit/xla_activity_logging_listener.cc

    class XlaActivityLoggingListener final : public XlaActivityListener {
     public:
      Status Listen(
          const XlaAutoClusteringActivity& auto_clustering_activity) override {
        if (!IsEnabled()) {
          VLOG(3) << "Logging XlaAutoClusteringActivity disabled";
          return absl::OkStatus();
        }
    
        return absl::OkStatus();
      }
    
      Status Listen(
          const XlaJitCompilationActivity& jit_compilation_activity) override {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Feb 22 08:47:20 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  4. 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)},
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  5. docs/de/docs/deployment/index.md

    Ich zeige Ihnen einige der wichtigsten Konzepte, die Sie beim Deployment einer **FastAPI**-Anwendung wahrscheinlich berücksichtigen sollten (obwohl das meiste davon auch für jede andere Art von Webanwendung gilt).
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Sat Mar 30 20:16:56 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  6. docs/de/docs/python-types.md

    Aber dann müssen Sie „diese Methode aufrufen, die den ersten Buchstaben in Großbuchstaben umwandelt“.
    
    War es `upper`? War es `uppercase`? `first_uppercase`? `capitalize`?
    
    Dann versuchen Sie es mit dem langjährigen Freund des Programmierers, der Editor-Autovervollständigung.
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Sat Mar 30 20:29:25 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  7. 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 {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  8. src/net/internal/socktest/sys_windows.go

    	return nil
    }
    
    // Listen wraps [syscall.Listen].
    func (sw *Switch) Listen(s syscall.Handle, backlog int) (err error) {
    	so := sw.sockso(s)
    	if so == nil {
    		return syscall.Listen(s, backlog)
    	}
    	sw.fmu.RLock()
    	f, _ := sw.fltab[FilterListen]
    	sw.fmu.RUnlock()
    
    	af, err := f.apply(so)
    	if err != nil {
    		return err
    	}
    	so.Err = syscall.Listen(s, backlog)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  9. src/vendor/golang.org/x/net/nettest/nettest.go

    		if canListenTCP4OnLoopback {
    			if ln, err := net.Listen("tcp4", "127.0.0.1:0"); err == nil {
    				return ln, nil
    			}
    		}
    		if canListenTCP6OnLoopback {
    			return net.Listen("tcp6", "[::1]:0")
    		}
    	case "tcp4":
    		if canListenTCP4OnLoopback {
    			return net.Listen("tcp4", "127.0.0.1:0")
    		}
    	case "tcp6":
    		if canListenTCP6OnLoopback {
    			return net.Listen("tcp6", "[::1]:0")
    		}
    	case "unix", "unixpacket":
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  10. tensorflow/compiler/jit/xla_activity_listener.cc

      return ForEachListener([&](XlaActivityListener* listener) {
        return listener->Listen(auto_clustering_activity);
      });
    }
    
    Status BroadcastXlaActivity(
        XlaJitCompilationActivity jit_compilation_activity) {
      return ForEachListener([&](XlaActivityListener* listener) {
        return listener->Listen(jit_compilation_activity);
      });
    }
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Feb 22 08:47:20 UTC 2024
    - 3.3K bytes
    - Viewed (0)
Back to top