Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 42 for recvq (0.1 sec)

  1. src/go/ast/filter.go

    // nameOf returns the function (foo) or method name (foo.bar) for
    // the given function declaration. If the AST is incorrect for the
    // receiver, it assumes a function instead.
    func nameOf(f *FuncDecl) string {
    	if r := f.Recv; r != nil && len(r.List) == 1 {
    		// looks like a correct receiver declaration
    		t := r.List[0].Type
    		// dereference pointer receiver types
    		if p, _ := t.(*StarExpr); p != nil {
    			t = p.X
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  2. src/cmd/compile/internal/types2/issues_test.go

    		// must match the method's name per the choice in the source file.
    		for i := 0; i < iface.NumMethods(); i++ {
    			m := iface.Method(i)
    			recvName := m.Type().(*Signature).Recv().Type().(*Named).Obj().Name()
    			if recvName != m.Name() {
    				t.Errorf("perm %v: got recv %s; want %s", perm, recvName, m.Name())
    			}
    		}
    	}
    }
    
    func TestIssue28282(t *testing.T) {
    	// create type interface { error }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  3. src/go/types/decl.go

    	// The object map contains the package scope objects and the non-interface methods.
    	if debug {
    		info := check.objMap[obj]
    		inObjMap := info != nil && (info.fdecl == nil || info.fdecl.Recv == nil) // exclude methods
    		isPkgObj := obj.Parent() == check.pkg.scope
    		if isPkgObj != inObjMap {
    			check.dump("%v: inconsistent object map for %s (isPkgObj = %v, inObjMap = %v)", obj.Pos(), obj, isPkgObj, inObjMap)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 31K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/dra/plugin/noderesources.go

    				select {
    				case <-time.After(backOff.Get(backOffID)):
    					backOff.Next(backOffID, time.Now())
    				case <-ctx.Done():
    				}
    			}
    			continue
    		}
    		for {
    			response, err := stream.Recv()
    			if err != nil {
    				switch {
    				case errors.Is(err, io.EOF):
    					// This is okay. Some plugins might never change their
    					// resources after reporting them once.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 20:12:53 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  5. src/go/printer/printer_test.go

    // Test case for issue #63362.
    func TestChanType(t *testing.T) {
    	expr := &ast.UnaryExpr{
    		Op: token.ARROW,
    		X: &ast.CallExpr{
    			Fun: &ast.ChanType{
    				Dir:   ast.RECV,
    				Value: &ast.Ident{Name: "int"},
    			},
    			Args: []ast.Expr{&ast.Ident{Name: "nil"}},
    		},
    	}
    	var buf bytes.Buffer
    	if err := Fprint(&buf, fset, expr); err != nil {
    		t.Fatal(err)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 03 14:56:25 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  6. cmd/common-main.go

    	ctxt.SFTP = ctx.StringSlice("sftp")
    	ctxt.Interface = ctx.String("interface")
    	ctxt.UserTimeout = ctx.Duration("conn-user-timeout")
    	ctxt.SendBufSize = ctx.Int("send-buf-size")
    	ctxt.RecvBufSize = ctx.Int("recv-buf-size")
    	ctxt.IdleTimeout = ctx.Duration("idle-timeout")
    	ctxt.UserTimeout = ctx.Duration("conn-user-timeout")
    	ctxt.ShutdownTimeout = ctx.Duration("shutdown-timeout")
    
    	if conf := ctx.String("config"); len(conf) > 0 {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 30 11:58:12 UTC 2024
    - 31.5K bytes
    - Viewed (0)
  7. src/cmd/go/internal/load/test.go

    	if err != nil {
    		return err
    	}
    	for _, d := range f.Decls {
    		n, ok := d.(*ast.FuncDecl)
    		if !ok {
    			continue
    		}
    		if n.Recv != nil {
    			continue
    		}
    		name := n.Name.String()
    		switch {
    		case name == "TestMain":
    			if isTestFunc(n, "T") {
    				t.Tests = append(t.Tests, testFunc{pkg, name, "", false})
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 14:01:23 UTC 2024
    - 28.2K bytes
    - Viewed (0)
  8. cmd/server-main.go

    		Hidden: true,
    		EnvVar: "MINIO_MEMLIMIT",
    	},
    	cli.IntFlag{
    		Name:   "send-buf-size",
    		Value:  4 * humanize.MiByte,
    		EnvVar: "MINIO_SEND_BUF_SIZE",
    		Hidden: true,
    	},
    	cli.IntFlag{
    		Name:   "recv-buf-size",
    		Value:  4 * humanize.MiByte,
    		EnvVar: "MINIO_RECV_BUF_SIZE",
    		Hidden: true,
    	},
    	cli.StringFlag{
    		Name:   "log-dir",
    		Usage:  "specify the directory to save the server log",
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 04 15:12:57 UTC 2024
    - 34.5K bytes
    - Viewed (1)
  9. src/cmd/cover/cover.go

    		// written in Go). See #57445 for more details.
    		if atomicOnAtomic() && (fname == "AddUint32" || fname == "StoreUint32") {
    			return nil
    		}
    		// Determine proper function or method name.
    		if r := n.Recv; r != nil && len(r.List) == 1 {
    			t := r.List[0].Type
    			star := ""
    			if p, _ := t.(*ast.StarExpr); p != nil {
    				t = p.X
    				star = "*"
    			}
    			if p, _ := t.(*ast.Ident); p != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 19:41:17 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  10. src/text/template/exec.go

    		if val.IsNil() {
    			break
    		}
    		if val.Type().ChanDir() == reflect.SendDir {
    			s.errorf("range over send-only channel %v", val)
    			break
    		}
    		i := 0
    		for ; ; i++ {
    			elem, ok := val.Recv()
    			if !ok {
    				break
    			}
    			oneIteration(reflect.ValueOf(i), elem)
    		}
    		if i == 0 {
    			break
    		}
    		return
    	case reflect.Invalid:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:22:24 UTC 2024
    - 32K bytes
    - Viewed (0)
Back to top