- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 259 for recv3 (0.04 sec)
-
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) -
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) -
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) -
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) -
src/runtime/chan_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 31 20:47:35 UTC 2023 - 23.4K bytes - Viewed (0) -
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) -
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) -
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) -
cmd/bucket-policy-handlers_test.go
apiRouter.ServeHTTP(recV4, reqV4) if recV4.Code != testCase.expectedRespStatus { t.Errorf("Test %d: %s: Expected the response status to be `%d`, but instead found `%d`", i+1, instanceType, testCase.expectedRespStatus, recV4.Code) } // initialize HTTP NewRecorder, this records any mutations to response writer inside the handler. recV2 := httptest.NewRecorder()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 32.9K bytes - Viewed (0) -
test/struct0.go
// Issue 2232. package main func recv(c chan interface{}) struct{} { return (<-c).(struct{}) } var m = make(map[interface{}]int) func recv1(c chan interface{}) { defer rec() m[(<-c).(struct{})] = 0 } func rec() { recover() } func main() { c := make(chan interface{}) go recv(c) c <- struct{}{} go recv1(c) c <- struct{}{}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 565 bytes - Viewed (0)