- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 114 for recv3 (0.04 sec)
-
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/timeformat/timeformat.go
func isTimeDotFormat(f *types.Func) bool { if f.Name() != "Format" || f.Pkg() == nil || f.Pkg().Path() != "time" { return false } // Verify that the receiver is time.Time. recv := f.Type().(*types.Signature).Recv() return recv != nil && analysisutil.IsNamedType(recv.Type(), "time", "Time") } func isTimeDotParse(f *types.Func) bool { return analysisutil.IsFunctionNamed(f, "time", "Parse") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 3.3K bytes - Viewed (0) -
src/go/internal/srcimporter/srcimporter_test.go
for i := 0; i < iface.NumExplicitMethods(); i++ { m := iface.ExplicitMethod(i) recv := m.Type().(*types.Signature).Recv() if recv == nil { t.Errorf("%s: missing receiver type", m) continue } if recv.Type() != named { t.Errorf("%s: got recv type %s; want %s", m, recv.Type(), named) } } // check embedded interfaces (they are named, too)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 12:00:02 UTC 2023 - 6.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/ir/tf_side_effects.h
}; struct Send : public ::mlir::SideEffects::Resource::Base<Send> { StringRef getName() final { return "Send"; } }; struct Recv : public ::mlir::SideEffects::Resource::Base<Recv> { StringRef getName() final { return "Recv"; } }; struct XlaHostCompute : public ::mlir::SideEffects::Resource::Base<XlaHostCompute> { StringRef getName() final { return "XlaHostCompute"; } };
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Dec 26 18:45:40 UTC 2023 - 4.7K bytes - Viewed (0) -
src/go/doc/comment/print.go
baseURL += "/" } switch { case l.Name == "": return baseURL + l.ImportPath + slash case l.Recv != "": return baseURL + l.ImportPath + slash + "#" + l.Recv + "." + l.Name default: return baseURL + l.ImportPath + slash + "#" + l.Name } } if l.Recv != "" { return "#" + l.Recv + "." + l.Name } return "#" + l.Name } // DefaultID returns the default anchor ID for the heading h.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:03 UTC 2023 - 7.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/stdmethods/stdmethods.go
return } // Special case: Is, As and Unwrap only apply when type // implements error. if id.Name == "Is" || id.Name == "As" || id.Name == "Unwrap" { if recv := sign.Recv(); recv == nil || !implementsError(recv.Type()) { return } } // Special case: Unwrap has two possible signatures. // Check for Unwrap() []error here. if id.Name == "Unwrap" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 09 01:28:01 UTC 2023 - 6.9K bytes - Viewed (0) -
src/net/rpc/client_test.go
} } // Test that errors in gob shut down the connection. Issue 7689. type R struct { msg []byte // Not exported, so R does not work with gob. } type S struct{} func (s *S) Recv(nul *struct{}, reply *R) error { *reply = R{[]byte("foo")} return nil } func TestGobError(t *testing.T) { defer func() { err := recover() if err == nil { t.Fatal("no error") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 1.7K bytes - Viewed (0) -
src/runtime/sigqueue.go
// //go:linkname signal_recv os/signal.signal_recv func signal_recv() uint32 { for { // Serve any signals from local copy. for i := uint32(0); i < _NSIG; i++ { if sig.recv[i/32]&(1<<(i&31)) != 0 { sig.recv[i/32] &^= 1 << (i & 31) return i } } // Wait for updates to be available from signal sender. Receive: for { switch sig.state.Load() { default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 7.6K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/DcerpcPipeHandle.java
if ( fraglen > getMaxRecv() ) { throw new IOException("Unexpected fragment length: " + fraglen); } while ( have < fraglen ) { int r = this.handle.recv(inB, have, fraglen - have); if ( r == 0 ) { throw new IOException("Unexpected EOF"); } have += r; } return have; }
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jan 26 11:51:07 UTC 2020 - 5.2K bytes - Viewed (0) -
pkg/istio-agent/tap_proxy.go
} const ( TypeDebugPrefix = "istio.io/debug/" ) func (p *tapProxy) StreamAggregatedResources(downstream DiscoveryStream) error { timeout := time.Second * 15 req, err := downstream.Recv() if err != nil { log.Errorf("failed to recv: %v", err) return err } if strings.HasPrefix(req.TypeUrl, TypeDebugPrefix) { if resp, err := p.xdsProxy.tapRequest(req, timeout); err == nil { err := downstream.Send(resp)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 1.9K bytes - Viewed (0) -
test/chan/nonblock.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Feb 19 06:44:02 UTC 2012 - 3.9K bytes - Viewed (0)