- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 258 for frecv (0.07 sec)
-
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/copylock/copylock.go
// inadvertently copy a lock, by checking whether // its receiver, parameters, or return values // are locks. func checkCopyLocksFunc(pass *analysis.Pass, name string, recv *ast.FieldList, typ *ast.FuncType) { if recv != nil && len(recv.List) > 0 { expr := recv.List[0].Type if path := lockPath(pass.Pkg, pass.TypesInfo.Types[expr].Type, nil); path != nil { pass.ReportRangef(expr, "%s passes lock by value: %v", name, path) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 9.9K bytes - Viewed (0) -
src/net/net_windows_test.go
}() // Receive first or second connection. s, err := recv(ln, true) if err != nil { t.Fatalf("recv failed: %v", err) } switch s { case "": // First connection data is received, let's get second connection data. case "abc": // First connection is lost forever, but that is ok. return default: t.Fatalf(`"%s" received from recv, but "" or "abc" expected`, s) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 16.3K bytes - Viewed (0) -
src/go/doc/comment/parse.go
pkg, name, ok := splitDocName(text) var recv string if ok { pkg, recv, _ = splitDocName(pkg) } if pkg != "" { if pkg, ok = d.lookupPkg(pkg); !ok { return nil, false } } else { if ok = d.lookupSym(recv, name); !ok { return nil, false } } link = &DocLink{ ImportPath: pkg, Recv: recv, Name: name, } return link, true }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:03 UTC 2023 - 33.5K bytes - Viewed (0) -
src/go/internal/gcimporter/iimport.go
mpos := r.pos() mname := r.ident() // TODO(mdempsky): Matches bimport.go, but I // don't agree with this. var recv *types.Var if base != nil { recv = types.NewVar(token.NoPos, r.currPkg, "", base) } msig := r.signature(recv, nil, nil) methods[i] = types.NewFunc(mpos, r.currPkg, mname, msig) } typ := types.NewInterfaceType(methods, embeddeds)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 19.2K bytes - Viewed (0) -
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) -
src/cmd/vendor/golang.org/x/build/relnote/links.go
s = strings.TrimPrefix(s, "*") pkg, name, ok = splitDocName(s) var recv string if ok { pkg, recv, _ = splitDocName(pkg) } if pkg != "" { if err := module.CheckImportPath(pkg); err != nil { return "", "", false } } if recv != "" { name = recv + "." + name } return pkg, name, true }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 8.2K 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) -
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) -
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/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)