Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 188 for recvq (0.04 sec)

  1. src/go/parser/parser.go

    		defer un(trace(p, "FunctionDecl"))
    	}
    
    	doc := p.leadComment
    	pos := p.expect(token.FUNC)
    
    	var recv *ast.FieldList
    	if p.tok == token.LPAREN {
    		_, recv = p.parseParameters(false)
    	}
    
    	ident := p.parseIdent()
    
    	tparams, params := p.parseParameters(true)
    	if recv != nil && tparams != nil {
    		// Method declarations do not have type parameters. We parse them for a
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Dec 08 20:07:50 UTC 2023
    - 72.2K bytes
    - Viewed (0)
  2. pilot/pkg/xds/adstest.go

    		_ = a.client.CloseSend()
    		if a.conn != nil {
    			_ = a.conn.Close()
    		}
    	})
    }
    
    func (a *AdsTest) adsReceiveChannel() {
    	context.AfterFunc(a.context, a.Cleanup)
    	for {
    		resp, err := a.client.Recv()
    		if err != nil {
    			if isUnexpectedError(err) {
    				log.Warnf("ads received error: %v", err)
    			}
    			select {
    			case a.error <- err:
    			case <-a.context.Done():
    			}
    			return
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Feb 04 03:39:42 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. src/syscall/ztypes_openbsd_ppc64.go

    	SizeofBpfStat    = 0x8
    	SizeofBpfProgram = 0x10
    	SizeofBpfInsn    = 0x8
    	SizeofBpfHdr     = 0x18
    )
    
    type BpfVersion struct {
    	Major uint16
    	Minor uint16
    }
    
    type BpfStat struct {
    	Recv uint32
    	Drop uint32
    }
    
    type BpfProgram struct {
    	Len   uint32
    	Insns *BpfInsn
    }
    
    type BpfInsn struct {
    	Code uint16
    	Jt   uint8
    	Jf   uint8
    	K    uint32
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Aug 22 03:24:15 UTC 2023
    - 6.7K bytes
    - Viewed (0)
  4. pilot/pkg/xds/deltaadstest.go

    		_ = a.client.CloseSend()
    		if a.conn != nil {
    			_ = a.conn.Close()
    		}
    	})
    }
    
    func (a *DeltaAdsTest) adsReceiveChannel() {
    	context.AfterFunc(a.context, a.Cleanup)
    	for {
    		resp, err := a.client.Recv()
    		if err != nil {
    			if isUnexpectedError(err) {
    				log.Warnf("ads received error: %v", err)
    			}
    			select {
    			case a.error <- err:
    			case <-a.context.Done():
    			}
    			return
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Feb 04 03:39:42 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  5. src/cmd/vendor/golang.org/x/sys/unix/ztypes_dragonfly_amd64.go

    	SizeofBpfStat    = 0x8
    	SizeofBpfProgram = 0x10
    	SizeofBpfInsn    = 0x8
    	SizeofBpfHdr     = 0x20
    )
    
    type BpfVersion struct {
    	Major uint16
    	Minor uint16
    }
    
    type BpfStat struct {
    	Recv uint32
    	Drop uint32
    }
    
    type BpfProgram struct {
    	Len   uint32
    	Insns *BpfInsn
    }
    
    type BpfInsn struct {
    	Code uint16
    	Jt   uint8
    	Jf   uint8
    	K    uint32
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:33 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  6. src/cmd/vendor/golang.org/x/sys/unix/ztypes_solaris_amd64.go

    	SizeofBpfStat    = 0x80
    	SizeofBpfProgram = 0x10
    	SizeofBpfInsn    = 0x8
    	SizeofBpfHdr     = 0x14
    )
    
    type BpfVersion struct {
    	Major uint16
    	Minor uint16
    }
    
    type BpfStat struct {
    	Recv uint64
    	Drop uint64
    	Capt uint64
    	_    [13]uint64
    }
    
    type BpfProgram struct {
    	Len   uint32
    	Insns *BpfInsn
    }
    
    type BpfInsn struct {
    	Code uint16
    	Jt   uint8
    	Jf   uint8
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:33 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  7. src/go/types/check.go

    		m[node] = obj
    	}
    }
    
    func (check *Checker) recordSelection(x *ast.SelectorExpr, kind SelectionKind, recv Type, obj Object, index []int, indirect bool) {
    	assert(obj != nil && (recv == nil || len(index) > 0))
    	check.recordUse(x.Sel, obj)
    	if m := check.Selections; m != nil {
    		m[x] = &Selection{kind, recv, obj, index, indirect}
    	}
    }
    
    func (check *Checker) recordScope(node ast.Node, scope *Scope) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  8. src/cmd/vendor/golang.org/x/tools/go/ast/astutil/rewrite.go

    	case *ast.BadDecl:
    		// nothing to do
    
    	case *ast.GenDecl:
    		a.apply(n, "Doc", nil, n.Doc)
    		a.applyList(n, "Specs")
    
    	case *ast.FuncDecl:
    		a.apply(n, "Doc", nil, n.Doc)
    		a.apply(n, "Recv", nil, n.Recv)
    		a.apply(n, "Name", nil, n.Name)
    		a.apply(n, "Type", nil, n.Type)
    		a.apply(n, "Body", nil, n.Body)
    
    	// Files and packages
    	case *ast.File:
    		a.apply(n, "Doc", nil, n.Doc)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Dec 18 21:28:13 UTC 2023
    - 12.2K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/dra/plugin/client_test.go

    			if err != nil {
    				t.Fatal(err)
    			}
    			var actualResponses []*drapbv1alpha3.NodeListAndWatchResourcesResponse
    			var actualErr error
    			for {
    				resp, err := stream.Recv()
    				if err != nil {
    					actualErr = err
    					break
    				}
    				actualResponses = append(actualResponses, resp)
    			}
    			assert.Equal(t, test.responses, actualResponses)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 19 16:27:05 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  10. src/cmd/compile/internal/types2/check.go

    		m[node] = obj
    	}
    }
    
    func (check *Checker) recordSelection(x *syntax.SelectorExpr, kind SelectionKind, recv Type, obj Object, index []int, indirect bool) {
    	assert(obj != nil && (recv == nil || len(index) > 0))
    	check.recordUse(x.Sel, obj)
    	if m := check.Selections; m != nil {
    		m[x] = &Selection{kind, recv, obj, index, indirect}
    	}
    }
    
    func (check *Checker) recordScope(node syntax.Node, scope *Scope) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 23.3K bytes
    - Viewed (0)
Back to top