Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 223 for recvs (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. src/cmd/go/testdata/script/cgo_badmethod_issue57926.txt

    ! stderr 'Alias'
    
    -- go.mod --
    module example.com
    go 1.12
    
    -- a.go --
    package a
    
    /*
    typedef int T;
    */
    import "C"
    
    func (C.T) f() {}
    func (recv *C.T) g() {}
    
    // The check is more education than enforcement,
    // and is easily defeated using a type alias.
    type Alias = C.T
    func (Alias) h() {}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 02 12:55:28 UTC 2023
    - 562 bytes
    - Viewed (0)
  10. 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)
Back to top