Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 258 for recvq (0.08 sec)

  1. src/runtime/chan.go

    			// we copy directly. Note that we need to increment
    			// the head/tail locations only when raceenabled.
    			racenotify(c, c.recvx, nil)
    			racenotify(c, c.recvx, sg)
    			c.recvx++
    			if c.recvx == c.dataqsiz {
    				c.recvx = 0
    			}
    			c.sendx = c.recvx // c.sendx = (c.sendx+1) % c.dataqsiz
    		}
    	}
    	if sg.elem != nil {
    		sendDirect(c.elemtype, sg, ep)
    		sg.elem = nil
    	}
    	gp := sg.g
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:50 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  2. src/runtime/select.go

    		}
    		racenotify(c, c.recvx, nil)
    	}
    	if msanenabled && cas.elem != nil {
    		msanwrite(cas.elem, c.elemtype.Size_)
    	}
    	if asanenabled && cas.elem != nil {
    		asanwrite(cas.elem, c.elemtype.Size_)
    	}
    	recvOK = true
    	qp = chanbuf(c, c.recvx)
    	if cas.elem != nil {
    		typedmemmove(c.elemtype, cas.elem, qp)
    	}
    	typedmemclr(c.elemtype, qp)
    	c.recvx++
    	if c.recvx == c.dataqsiz {
    		c.recvx = 0
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 13 21:36:04 UTC 2024
    - 15K bytes
    - Viewed (0)
  3. src/runtime/runtime-gdb.py

    		return str(self.val.type)
    
    	def children(self):
    		# see chan.c chanbuf(). et is the type stolen from hchan<T>::recvq->first->elem
    		et = [x.type for x in self.val['recvq']['first'].type.target().fields() if x.name == 'elem'][0]
    		ptr = (self.val.address["buf"]).cast(et)
    		for i in range(self.val["qcount"]):
    			j = (self.val["recvx"] + i) % self.val["dataqsiz"]
    			yield ('[{0}]'.format(i), (ptr + j).dereference())
    
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 10 12:59:20 UTC 2023
    - 15.4K bytes
    - Viewed (0)
  4. src/runtime/chan_test.go

    			for p := 0; p < P; p++ {
    				go func() {
    					recv := make(map[int]int)
    					for i := 0; i < L; i++ {
    						v := <-c
    						recv[v] = recv[v] + 1
    					}
    					done <- recv
    				}()
    			}
    			recv := make(map[int]int)
    			for p := 0; p < P; p++ {
    				for k, v := range <-done {
    					recv[k] = recv[k] + v
    				}
    			}
    			if len(recv) != L {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Oct 31 20:47:35 UTC 2023
    - 23.4K bytes
    - Viewed (0)
  5. test/chan/select7.go

    	select {
    	case c <- 1:
    	}
    }
    
    func send3(recv func(<-chan int)) {
    	c := make(chan int)
    	go recv(c)
    	runtime.Gosched()
    	c2 := make(chan int)
    	select {
    	case c <- 1:
    	case c2 <- 1:
    	}
    }
    
    func main() {
    	send1(recv1)
    	send2(recv1)
    	send3(recv1)
    	send1(recv2)
    	send2(recv2)
    	send3(recv2)
    	send1(recv3)
    	send2(recv3)
    	send3(recv3)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 02 13:43:18 UTC 2016
    - 932 bytes
    - Viewed (0)
  6. tensorflow/compiler/jit/encapsulate_subgraphs_pass_test.cc

        Node* recv1 = RecvAtHost(
            ops::NodeOut(key_constant, 0), "F1", "F1", "O1", {DT_FLOAT, DT_FLOAT},
            b2.opts().WithAttr(kXlaHasHostTransferAttrName, true));
        Node* e = Binary(ops::NodeOut(recv1, 0), ops::NodeOut(recv1, 1),
                         b2.opts()
                             .WithName("E")
                             .WithControlInputs({recv1})
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Feb 22 08:47:20 UTC 2024
    - 113.3K bytes
    - Viewed (0)
  7. src/cmd/vendor/golang.org/x/tools/internal/typesinternal/recv.go

    	"golang.org/x/tools/internal/aliases"
    )
    
    // ReceiverNamed returns the named type (if any) associated with the
    // type of recv, which may be of the form N or *N, or aliases thereof.
    // It also reports whether a Pointer was present.
    func ReceiverNamed(recv *types.Var) (isPtr bool, named *types.Named) {
    	t := recv.Type()
    	if ptr, ok := aliases.Unalias(t).(*types.Pointer); ok {
    		isPtr = true
    		t = ptr.Elem()
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  8. test/typeparam/append.go

    package main
    
    type Recv <-chan int
    
    type sliceOf[E any] interface {
    	~[]E
    }
    
    func _Append[S sliceOf[T], T any](s S, t ...T) S {
    	return append(s, t...)
    }
    
    func main() {
    	recv := make(Recv)
    	a := _Append([]Recv{recv}, recv)
    	if len(a) != 2 || a[0] != recv || a[1] != recv {
    		panic(a)
    	}
    
    	recv2 := make(chan<- int)
    	a2 := _Append([]chan<- int{recv2}, recv2)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 01 19:45:34 UTC 2022
    - 597 bytes
    - Viewed (0)
  9. src/cmd/link/internal/ld/dwarf.go

    		})
    
    		// hchan<T>
    		dwhs := d.mkinternaltype(ctxt, dwarf.DW_ABRV_STRUCTTYPE, "hchan", elemname, "", func(dwh *dwarf.DWDie) {
    			d.copychildren(ctxt, dwh, hchan)
    			d.substitutetype(dwh, "recvq", dwws)
    			d.substitutetype(dwh, "sendq", dwws)
    			newattr(dwh, dwarf.DW_AT_byte_size, dwarf.DW_CLS_CONSTANT, getattr(hchan, dwarf.DW_AT_byte_size).Value, nil)
    		})
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 16:25:18 UTC 2024
    - 72.4K bytes
    - Viewed (0)
  10. test/closedchan.go

    	if x := c.Recv(); x != 1 {
    		println("testasync1: Recv did not get 1:", x, c.Impl())
    		failed = true
    	}
    
    	test1(c)
    }
    
    func testasync2(c Chan) {
    	// should be able to get the last value via Recv2
    	if x, ok := c.Recv2(); x != 1 || !ok {
    		println("testasync1: Recv did not get 1, true:", x, ok, c.Impl())
    		failed = true
    	}
    
    	test1(c)
    }
    
    func testasync3(c Chan) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Feb 17 04:48:57 UTC 2012
    - 5.8K bytes
    - Viewed (0)
Back to top