- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for pawn (0.22 sec)
-
src/runtime/callers_test.go
"strings" "testing" ) func f1(pan bool) []uintptr { return f2(pan) // line 15 } func f2(pan bool) []uintptr { return f3(pan) // line 19 } func f3(pan bool) []uintptr { if pan { panic("f3") // line 24 } ret := make([]uintptr, 20) return ret[:runtime.Callers(0, ret)] // line 27 } func testCallers(t *testing.T, pcs []uintptr, pan bool) { m := make(map[string]int, len(pcs))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 28 21:36:31 UTC 2023 - 12.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler_test.go
apis := fuzzAPIGroups(1, 3, 15) manager.SetGroups(apis.Items) waitGroup := sync.WaitGroup{} numReaders := 100 numRequestsPerReader := 100 // Spawn a bunch of readers that will keep sending requests to the server for i := 0; i < numReaders; i++ { waitGroup.Add(1) go func() { defer waitGroup.Done() etag := ""
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 00:29:39 UTC 2024 - 28.6K bytes - Viewed (0) -
hack/make-rules/test.sh
# 'go test' commands at once. # To properly parse the test results if generating a JUnit test report, we # must make sure the output from PARALLEL runs is not mixed. To achieve this, # we spawn a subshell for each PARALLEL process, redirecting the output to # separate files. printf "%s\n" "${@}" \ | xargs -I{} -n 1 -P "${KUBE_COVERPROCS}" \
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 22:40:10 UTC 2024 - 10.8K bytes - Viewed (0) -
build-logic/integration-testing/src/main/kotlin/gradlebuild/integrationtests/shared-configuration.kt
"${prefix}TestFullDistributionRuntimeClasspath"(project(":distributions-full")) // Add the agent JAR to the test runtime classpath so the InProcessGradleExecuter can find the module and spawn daemons. // This doesn't apply the agent to the test process. "${prefix}TestRuntimeOnly"(project(":instrumentation-agent")) "${prefix}TestAgentsClasspath"(project(":instrumentation-agent"))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 13 23:14:25 UTC 2024 - 12K bytes - Viewed (0) -
pilot/pkg/xds/xds_test.go
Select("{.resources[?(@.address.socketAddress.portValue==27018)]}"). Equals("0.0.0.0", "{.address.socketAddress.address}"). // Example doing a struct comparison, note the pain with oneofs.... Equals(&core.SocketAddress{ Address: "0.0.0.0", PortSpecifier: &core.SocketAddress_PortValue{ PortValue: uint32(27018), }, }, "{.address.socketAddress}").
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 13.8K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_device.h
// The name of the device that is used to compile Ops for this XlaDevice. const DeviceType jit_device_name_; // The platform for this device. se::Platform* const platform_; // Not owned. // Intra-op threads to spawn (from SessionOptions). const int intra_op_parallelism_threads_; // Memory allocator associated with this device. Allocator* xla_allocator_ TF_GUARDED_BY(mu_) = nullptr; // Not owned.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 09:53:30 UTC 2024 - 13.4K bytes - Viewed (0) -
cni/pkg/cmd/root.go
installDaemonReady, watchServerReady := nodeagent.StartHealthServer() if cfg.InstallConfig.AmbientEnabled { // Start ambient controller // node agent will spawn a goroutine and watch the K8S API for events, // as well as listen for messages from the CNI binary. log.Info("Starting ambient node agent with inpod redirect mode")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:35 UTC 2024 - 13K bytes - Viewed (0) -
cluster/images/etcd-version-monitor/etcd-version-monitor.go
pflag.CommandLine.AddGoFlagSet(goflag.CommandLine) pflag.Parse() // Register the metrics we defined above with prometheus. customMetricRegistry.MustRegister(etcdVersion) // Spawn threads for periodically scraping etcd version metrics. stopCh := make(chan struct{}) defer close(stopCh) go getVersionPeriodically(stopCh) // Serve our metrics on listenAddress/metricsPath.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 16 06:50:02 UTC 2023 - 11.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/sparsecore/embedding_sequencing.cc
core_tpu_ops.insert(&op); } GatherOpsForExtraction(&core_tpu_ops, merged_set, /*predecessors=*/true, /*successors=*/true); // TODO(patn): Verify that all the ops here fall between the forward pass // and backward pass ops (i.e., not before the forward pass or after the // backward pass). return LogicalResult::success(); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 39.4K bytes - Viewed (0) -
internal/logger/target/http/http.go
if time.Since(lastBatchProcess).Seconds() < 1 { continue } } } lastBatchProcess = time.Now() retry: // If the channel reaches above half capacity // we spawn more workers. The workers spawned // from this main worker routine will exit // once the channel drops below half capacity // and when it's been at least 30 seconds since // we launched a new worker.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 14.9K bytes - Viewed (0)