- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 115 for chain (0.07 sec)
-
src/cmd/go/go_test.go
// test (send to acquire), with a low enough limit that the overall number of // connections (summed across subprocesses) stays at or below base.NetLimit. var netTestSem chan struct{} var exeSuffix string = func() string { if runtime.GOOS == "windows" { return ".exe" } return "" }() func tooSlow(t *testing.T, reason string) { if testing.Short() { t.Helper()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 81.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go
go r.tearDown(crdInfo) } } } // Wait up to a minute for requests to drain, then tear down storage func (r *crdHandler) tearDown(oldInfo *crdInfo) { requestsDrained := make(chan struct{}) go func() { defer close(requestsDrained) // Allow time for in-flight requests with a handle to the old info to register themselves time.Sleep(time.Second) // Wait for in-flight requests to drain
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 52.9K bytes - Viewed (0) -
tensorflow/compiler/jit/mark_for_compilation_pass_test.cc
std::sort(p.second.begin(), p.second.end()); } if (cluster_names != nullptr) { std::sort(cluster_names->begin(), cluster_names->end()); } return cluster_sets; } TEST(XlaCompilationTest, Chains) { std::unique_ptr<Graph> graph(new Graph(OpRegistry::Global())); { GraphDefBuilder builder(GraphDefBuilder::kFailImmediately); Node* a =
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 14 10:11:10 UTC 2024 - 79.6K bytes - Viewed (0) -
cmd/kubelet/app/server.go
} // Obtain Kubelet Lock File if s.ExitOnLockContention && s.LockFilePath == "" { return errors.New("cannot exit on lock file contention: no lock file specified") } done := make(chan struct{}) if s.LockFilePath != "" { klog.InfoS("Acquiring file lock", "path", s.LockFilePath) if err := flock.Acquire(s.LockFilePath); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/admission_test.go
func TestInvalidParamSourceGVK(t *testing.T) { compiler := &fakeCompiler{} matcher := &fakeMatcher{ DefaultMatch: true, } testContext := setupFakeTest(t, compiler, matcher) passedParams := make(chan *unstructured.Unstructured) badPolicy := *denyPolicy badPolicy.Spec.ParamKind = &admissionregistrationv1.ParamKind{ APIVersion: paramsGVK.GroupVersion().String(), Kind: "BadParamKind", }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 25 01:39:01 UTC 2024 - 63.8K bytes - Viewed (0) -
src/bufio/bufio_test.go
} } type zeroReader struct{} func (zeroReader) Read(p []byte) (int, error) { return 0, nil } func TestZeroReader(t *testing.T) { var z zeroReader r := NewReader(z) c := make(chan error) go func() { _, err := r.ReadByte() c <- err }() select { case err := <-c: if err == nil { t.Error("error expected") } else if err != io.ErrNoProgress {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 10 18:56:01 UTC 2023 - 51.5K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
return func(o *frameworkOptions) { o.logger = &logger } } // defaultFrameworkOptions are applied when no option corresponding to those fields exist. func defaultFrameworkOptions(stopCh <-chan struct{}) frameworkOptions { return frameworkOptions{ metricsRecorder: metrics.NewMetricsAsyncRecorder(1000, time.Second, stopCh), parallelizer: parallelize.NewParallelizer(parallelize.DefaultParallelism), } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
src/time/time_test.go
} } } // golang.org/issue/4622 func TestLocationRace(t *testing.T) { ResetLocalOnceForTest() // reset the Once to trigger the race c := make(chan string, 1) go func() { c <- Now().String() }() _ = Now().String() <-c Sleep(100 * Millisecond) // Back to Los Angeles for subsequent tests: ForceUSPacificForTesting() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:13:47 UTC 2024 - 56.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/tests/mlrt/while_to_map_fn.mlir
return %outputs_20 : tensor<?x?x4xf32> } // ----- // Test a while to map_fn conversion in which the passed in max_iterations // is not in typical location of %arg3 and there are identify chains in function bodies. // CHECK-LABEL: @map_while_cond_170
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Apr 23 06:40:22 UTC 2024 - 68.6K bytes - Viewed (0) -
src/runtime/mgcscavenge.go
} // Background scavenger. // // The background scavenger maintains the RSS of the application below // the line described by the proportional scavenging statistics in // the mheap struct. func bgscavenge(c chan int) { scavenger.init() c <- 1 scavenger.park() for { released, workTime := scavenger.run() if released == 0 { scavenger.park() continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:48:45 UTC 2024 - 52.3K bytes - Viewed (0)