Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 113 for recvq (0.12 sec)

  1. src/go/types/methodset_test.go

    	T := pkg.Scope().Lookup("T").Type()
    	name := "m"
    	for _, recv := range []Type{T, NewPointer(T)} {
    		// LookupFieldOrMethod and NewMethodSet must match:
    		// either both find m or neither finds it.
    		obj1, _, _ := LookupFieldOrMethod(recv, false, pkg, name)
    		mset := NewMethodSet(recv)
    		if (obj1 != nil) != (mset.Len() == 1) {
    			t.Fatalf("lookup(%v.%s): got obj = %v, mset = %v", recv, name, obj1, mset)
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 08 15:27:57 UTC 2023
    - 6.7K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. src/cmd/compile/internal/walk/select.go

    			ch := n.Chan
    			cond = mkcall1(chanfn("selectnbsend", 2, ch.Type()), types.Types[types.TBOOL], r.PtrInit(), ch, n.Value)
    
    		case ir.OSELRECV2:
    			n := n.(*ir.AssignListStmt)
    			recv := n.Rhs[0].(*ir.UnaryExpr)
    			ch := recv.X
    			elem := n.Lhs[0]
    			if ir.IsBlank(elem) {
    				elem = typecheck.NodNil()
    			}
    			cond = typecheck.TempAt(base.Pos, ir.CurFunc, types.Types[types.TBOOL])
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Aug 22 01:53:41 UTC 2023
    - 7.8K 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. 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)
  8. 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)
  9. src/reflect/iter.go

    			i := v.MapRange()
    			for i.Next() {
    				if !yield(i.Key()) {
    					return
    				}
    			}
    		}
    	case Chan:
    		return func(yield func(Value) bool) {
    			for value, ok := v.Recv(); ok; value, ok = v.Recv() {
    				if !yield(value) {
    					return
    				}
    			}
    		}
    	}
    	panic("reflect: " + v.Type().String() + " cannot produce iter.Seq[Value]")
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 13:40:11 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  10. src/os/writeto_linux_test.go

    		for _, size := range sizes {
    			t.Run(strconv.Itoa(size), func(t *testing.T) {
    				testSendFile(t, "tcp", int64(size))
    			})
    		}
    	})
    }
    
    func testSendFile(t *testing.T, proto string, size int64) {
    	dst, src, recv, data, hook := newSendFileTest(t, proto, size)
    
    	// Now call WriteTo (through io.Copy), which will hopefully call poll.SendFile
    	n, err := io.Copy(dst, src)
    	if err != nil {
    		t.Fatalf("io.Copy error: %v", err)
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 18:12:56 UTC 2024
    - 4K bytes
    - Viewed (0)
Back to top