Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 113 for recvq (0.16 sec)

  1. src/go/ast/walk.go

    		// nothing to do
    
    	case *GenDecl:
    		if n.Doc != nil {
    			Walk(v, n.Doc)
    		}
    		walkList(v, n.Specs)
    
    	case *FuncDecl:
    		if n.Doc != nil {
    			Walk(v, n.Doc)
    		}
    		if n.Recv != nil {
    			Walk(v, n.Recv)
    		}
    		Walk(v, n.Name)
    		Walk(v, n.Type)
    		if n.Body != nil {
    			Walk(v, n.Body)
    		}
    
    	// Files and packages
    	case *File:
    		if n.Doc != nil {
    			Walk(v, n.Doc)
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:34:10 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  2. src/cmd/compile/internal/types2/universe.go

    	{
    		obj := NewTypeName(nopos, nil, "error", nil)
    		obj.setColor(black)
    		typ := NewNamed(obj, nil, nil)
    
    		// error.Error() string
    		recv := NewVar(nopos, nil, "", typ)
    		res := NewVar(nopos, nil, "", Typ[String])
    		sig := NewSignatureType(recv, nil, nil, nil, NewTuple(res), false)
    		err := NewFunc(nopos, nil, "Error", sig)
    
    		// interface{ Error() string }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 07 20:08:23 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  3. src/go/types/universe.go

    	{
    		obj := NewTypeName(nopos, nil, "error", nil)
    		obj.setColor(black)
    		typ := NewNamed(obj, nil, nil)
    
    		// error.Error() string
    		recv := NewVar(nopos, nil, "", typ)
    		res := NewVar(nopos, nil, "", Typ[String])
    		sig := NewSignatureType(recv, nil, nil, nil, NewTuple(res), false)
    		err := NewFunc(nopos, nil, "Error", sig)
    
    		// interface{ Error() string }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 07 20:08:23 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/serviceentry/util_test.go

    		{Namespace: "default", Name: "se-1"}: &se1,
    		{Namespace: "default", Name: "se-3"}: &se3,
    	}
    	got := getWorkloadServiceEntries(ses, wle)
    	if !reflect.DeepEqual(got, expected) {
    		t.Errorf("recv unexpected se: %v", got)
    	}
    }
    
    func TestCompareServiceEntries(t *testing.T) {
    	oldSes := map[types.NamespacedName]*config.Config{
    		{Namespace: "default", Name: "se-1"}: {},
    		{Namespace: "default", Name: "se-2"}: {},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jan 17 22:32:10 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  5. pkg/test/echo/server/forwarder/udp.go

    	if cfg.Request.ExpectedResponse != nil {
    		expected = cfg.Request.ExpectedResponse.GetValue()
    	}
    	if !strings.Contains(msg, expected) {
    		return msg, fmt.Errorf("expect to recv message with %s, got %s. Return EOF", expected, msg)
    	}
    	return msg, nil
    }
    
    func (c *udpProtocol) Close() error {
    	return nil
    }
    
    func newUDPConnection(cfg *Config) (net.Conn, error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Oct 13 17:19:22 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/devicemanager/plugin/v1beta1/client.go

    	if err != nil {
    		klog.ErrorS(err, "ListAndWatch ended unexpectedly for device plugin", "resource", c.resource)
    		return
    	}
    
    	for {
    		response, err := stream.Recv()
    		if err != nil {
    			klog.ErrorS(err, "ListAndWatch ended unexpectedly for device plugin", "resource", c.resource)
    			return
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 21:35:13 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  7. test/convT2X.go

    			case uc <- nil:
    			case uc <- u32:
    			case uc <- u64:
    			case uc <- u128:
    			}
    		}
    	}()
    	for i := 0; i < n; i++ {
    		if got := <-uc; got != nil && got != u32 && got != u64 && got != u128 {
    			println("recv: i", i, "got", got)
    			panic("fail")
    		}
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jul 02 23:09:05 UTC 2012
    - 3.3K bytes
    - Viewed (0)
  8. src/cmd/internal/goobj/mkbuiltin.go

    	}
    
    	decls := make(map[string]bool)
    
    	fmt.Fprintf(w, "var builtins = [...]struct{ name string; abi int }{\n")
    	for _, decl := range f.Decls {
    		switch decl := decl.(type) {
    		case *ast.FuncDecl:
    			if decl.Recv != nil {
    				log.Fatal("methods unsupported")
    			}
    			if decl.Body != nil {
    				log.Fatal("unexpected function body")
    			}
    			declName := pkg + "." + decl.Name.Name
    			decls[declName] = true
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:27 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  9. src/internal/trace/parser.go

    	EvGoUnblock         = 21 // goroutine is unblocked [timestamp, goroutine id, seq, stack]
    	EvGoBlockSend       = 22 // goroutine blocks on chan send [timestamp, stack]
    	EvGoBlockRecv       = 23 // goroutine blocks on chan recv [timestamp, stack]
    	EvGoBlockSelect     = 24 // goroutine blocks on select [timestamp, stack]
    	EvGoBlockSync       = 25 // goroutine blocks on Mutex/RWMutex [timestamp, stack]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:31:04 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  10. src/cmd/vendor/golang.org/x/tools/go/analysis/passes/internal/analysisutil/util.go

    func IsFunctionNamed(f *types.Func, pkgPath string, names ...string) bool {
    	if f == nil {
    		return false
    	}
    	if f.Pkg() == nil || f.Pkg().Path() != pkgPath {
    		return false
    	}
    	if f.Type().(*types.Signature).Recv() != nil {
    		return false
    	}
    	for _, n := range names {
    		if f.Name() == n {
    			return true
    		}
    	}
    	return false
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 02:38:00 UTC 2024
    - 3.9K bytes
    - Viewed (0)
Back to top