- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 453 for LISTEN (0.09 sec)
-
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) -
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) -
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) -
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) -
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) -
src/net/internal/socktest/sys_unix.go
return nil } // Listen wraps syscall.Listen. func (sw *Switch) Listen(s, 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) if err = af.apply(so); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 4K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/util.go
} else if parsedIP.To4() != nil { ipBind = "tcp4" } } ln, err := tls.Listen(ipBind, net.JoinHostPort(ip, strconv.Itoa(port)), cfg) if err != nil { return nil, 0, err } port = ln.Addr().(*net.TCPAddr).Port return ln, port, nil } func listenOnUDS(uds string) (net.Listener, error) { _ = os.Remove(uds) ln, err := net.Listen("unix", uds) if err != nil { return nil, err } return ln, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.6K bytes - Viewed (0) -
src/net/dial.go
} // Listen announces on the local network address. // // See func Listen for a description of the network and address // parameters. func (lc *ListenConfig) Listen(ctx context.Context, network, address string) (Listener, error) { addrs, err := DefaultResolver.resolveAddrList(ctx, "listen", network, address, nil) if err != nil { return nil, &OpError{Op: "listen", Net: network, Source: nil, Addr: nil, Err: err} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 26.9K bytes - Viewed (0) -
tensorflow/compiler/jit/tests/device_compiler_test_helper.h
public: Status Listen( const XlaAutoClusteringActivity& auto_clustering_activity) override { return absl::OkStatus(); } Status Listen( const XlaJitCompilationActivity& jit_compilation_activity) override { activity_history_.push_back(jit_compilation_activity); return absl::OkStatus(); } Status Listen(const XlaOptimizationRemark& optimization_remark) override {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Feb 09 08:24:16 UTC 2024 - 3.6K bytes - Viewed (0) -
pkg/probe/grpc/grpc_test.go
assert.Equal(t, probe.Success, p) assert.Equal(t, nil, err) }) t.Run("Should: not return error because check was success, when listen port is 0", func(t *testing.T) { s := New() lis, _ := net.Listen("tcp", ":0") port := lis.Addr().(*net.TCPAddr).Port grpcServer := grpc.NewServer() defer grpcServer.Stop() grpchealth.RegisterHealthServer(grpcServer, &successServerMock{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 20 00:23:53 UTC 2021 - 5.7K bytes - Viewed (0)