- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 226 for nbrecv (0.09 sec)
-
src/go/parser/resolver.go
} } func (r *resolver) walkRecv(recv *ast.FieldList) { // If our receiver has receiver type parameters, we must declare them before // trying to resolve the rest of the receiver, and avoid re-resolving the // type parameter identifiers. if recv == nil || len(recv.List) == 0 { return // nothing to do } typ := recv.List[0].Type if ptr, ok := typ.(*ast.StarExpr); ok { typ = ptr.X }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 02 12:56:53 UTC 2023 - 15.8K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
con := &ProxyConnection{ conID: connectionNumber.Inc(), upstreamError: make(chan error), // can be produced by recv and send downstreamError: make(chan error), // can be produced by recv and send // Requests channel is unbounded. The Envoy<->XDS Proxy<->Istiod system produces a natural // looping of Recv and Send. Due to backpressure introduced by gRPC natively (that is, Send() can
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta_test.go
t.Fatal(err) } res, err := downstream.Recv() if err != nil { t.Fatal(err) } if res == nil || res.TypeUrl != v3.ClusterType { t.Fatalf("Expected to get cluster response but got %v", res) } err = downstream.Send(&discovery.DeltaDiscoveryRequest{TypeUrl: v3.ListenerType, Node: node}) if err != nil { t.Fatal(err) } res, err = downstream.Recv() if err != nil { t.Fatal(err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 04:48:02 UTC 2024 - 6.3K bytes - Viewed (0) -
src/cmd/compile/internal/types2/interface.go
return &emptyInterface } // set method receivers if necessary typ := (*Checker)(nil).newInterface() for _, m := range methods { if sig := m.typ.(*Signature); sig.recv == nil { sig.recv = NewVar(m.pos, m.pkg, "", typ) } } // sort for API stability sortMethods(methods) typ.methods = methods typ.embeddeds = embeddeds typ.complete = true return typ }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 17:24:42 UTC 2023 - 6.2K bytes - Viewed (0) -
src/cmd/go/testdata/script/cgo_badmethod_issue57926.txt
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 02 12:55:28 UTC 2023 - 562 bytes - Viewed (0) -
src/cmd/cgo/out.go
gccExport = "__declspec(dllexport) " } s := fmt.Sprintf("%s%s %s(", gccExport, gccResult, exp.ExpName) if fn.Recv != nil { s += p.cgoType(fn.Recv.List[0].Type).C.String() s += " recv" } forFieldList(fntype.Params, func(i int, aname string, atype ast.Expr) { if i > 0 || fn.Recv != nil { s += ", " } s += fmt.Sprintf("%s %s", p.cgoType(atype).C, exportParamName(aname, i)) })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 29 16:41:10 UTC 2024 - 59.6K bytes - Viewed (0) -
src/cmd/compile/internal/noder/noder.go
err chan syntax.Error } // linkname records a //go:linkname directive. type linkname struct { pos syntax.Pos local string remote string } var unOps = [...]ir.Op{ syntax.Recv: ir.ORECV, syntax.Mul: ir.ODEREF, syntax.And: ir.OADDR, syntax.Not: ir.ONOT, syntax.Xor: ir.OBITNOT, syntax.Add: ir.OPLUS, syntax.Sub: ir.ONEG, } var binOps = [...]ir.Op{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 11 20:40:57 UTC 2023 - 12.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/unusedresult/unusedresult.go
if !ok { return // e.g. var or builtin } if sig := fn.Type().(*types.Signature); sig.Recv() != nil { // method (e.g. foo.String()) if types.Identical(sig, sigNoArgsStringResult) { if stringMethods[fn.Name()] { pass.Reportf(call.Lparen, "result of (%s).%s call not used", sig.Recv().Type(), fn.Name()) } } } else { // package-level function (e.g. fmt.Errorf)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 22 19:00:13 UTC 2024 - 4.5K bytes - Viewed (0) -
src/reflect/iter.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 13:40:11 UTC 2024 - 3.9K bytes - Viewed (0) -
test/ken/chan1.go
package main import "runtime" const N = 1000 // sent messages const M = 10 // receiving goroutines const W = 2 // channel buffering var h [N]int // marking of send/recv func r(c chan int, m int) { for { select { case r := <-c: if h[r] != 1 { println("r", "m=", m, "r=", r, "h=", h[r]) panic("fail") } h[r] = 2 } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 24 21:47:04 UTC 2012 - 879 bytes - Viewed (0)