- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 75 for VarLive (0.12 sec)
-
test/typeparam/chansimp.dir/a.go
select { case <-ctx.Done(): return false case s.values <- v: return true case <-s.done: return false } } // Close tells the receiver that no more values will arrive. // After Close is called, the Sender may no longer be used. func (s *Sender[Elem]) Close() { close(s.values) } // A Receiver receives values from a Sender. type Receiver[Elem any] struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jul 28 21:40:40 UTC 2021 - 5.5K bytes - Viewed (0) -
pkg/proxy/nftables/README.md
network namespace processes always take the output path, while packets coming in from outside the host network namespace (whether that's from an external host or from a pod network namespace) arrive via `ingress` and take the input or forward path, depending on the routing decision made after `prerouting`; packets destined for an IP which is assigned
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 21 14:37:56 UTC 2024 - 5.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/tests/tfrt_fallback/batching_fallback.mlir
enable_large_batch_splitting = false, Tin = [i32], Tcaptured = [i32], Tout = [i32]} : 1 // Since batch function kernel scheduling is async, the above 2 batches can arrive in any order. // CHECK: Running @matmul_cpu // CHECK-NEXT: Tensor<type: int32 shape: [4,2] values: [[value_output:.*]]> // CHECK: Tensor<type: int32 shape: [2,2] values: [4 4]
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jul 18 22:58:56 UTC 2023 - 8.6K bytes - Viewed (0) -
src/cmd/doc/doc_test.go
`ConstTwo = 2`, // No second entry in constant block. `VarTwo = 2`, // No second entry in variable block. `VarFive = 5`, // From block starting with unexported variable. `type unexportedType`, // No unexported type. `unexportedTypedConstant`, // No unexported typed constant.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 07 19:16:55 UTC 2023 - 31.2K bytes - Viewed (0) -
src/cmd/compile/internal/ssagen/ssa.go
call.AuxInt = stksize // Call operations carry the argsize of the callee along with them } s.prevCall = call s.vars[memVar] = s.newValue1I(ssa.OpSelectN, types.TypeMem, int64(len(ACResults)), call) // Insert VarLive opcodes. for _, v := range n.KeepAlive { if !v.Addrtaken() { s.Fatalf("KeepAlive variable %v must have Addrtaken set", v) } switch v.Class { case ir.PAUTO, ir.PPARAM, ir.PPARAMOUT: default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 284.9K bytes - Viewed (0) -
src/cmd/go/testdata/script/mod_lazy_test_of_test_dep.txt
# The update should bring the version required by b, not the latest version of c. go list -m example.com/c stdout '^example.com/c v0.1.0 ' cmp go.mod go.mod.b # We should reach the same state if we arrive at it via `go test -mod=mod`. cp go.mod.117 go.mod [short] go list -mod=mod -test -deps example.com/a [!short] go test -mod=mod -c -o $devnull example.com/a [short] go list -mod=mod -test -deps example.com/b
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 08 19:32:28 UTC 2021 - 5.2K bytes - Viewed (0) -
src/time/tick_test.go
assertTick() Sleep(sched) tim.Reset(10000 * Second) drainAsync() noTick() // Test that len sees an immediate tick arrive // for Reset of timer in heap. tim.Reset(1) assertLen() assertTick() // Test that len sees an immediate tick arrive // for Reset of timer NOT in heap. tim.Stop() drainAsync() tim.Reset(1) assertLen() assertTick() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
test/typeparam/orderedmapsimp.dir/a.go
select { case <-ctx.Done(): return false case s.values <- v: return true case <-s.done: return false } } // Close tells the receiver that no more values will arrive. // After Close is called, the Sender may no longer be used. func (s *Sender[Elem]) Close() { close(s.values) } // A Receiver receives values from a Sender. type Receiver[Elem any] struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jul 28 21:40:40 UTC 2021 - 5.5K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/integTest/groovy/org/gradle/cache/internal/DefaultFileLockManagerContentionIntegrationTest.groovy
given: setupLockOwner() def pingRequestCount = 0 //do not handle requests: this simulates the situation were pings do not arrive replaceSocketReceiver { pingRequestCount++ } when: def build = executer.withTasks("lock").start() def timer = Time.startTimer() poll(120) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 15.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/audit_test.go
} // close body because the handler might block in Flush, unable to send the remaining event. response.Body.Close() // wait for events to arrive, at least the given number in the test events := []*auditinternal.Event{} err = wait.Poll(50*time.Millisecond, testTimeout(t), wait.ConditionFunc(func() (done bool, err error) { events = sink.Events()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 14 23:04:34 UTC 2022 - 12.1K bytes - Viewed (0)