- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for fRunner (0.57 sec)
-
src/testing/testing.go
// Instead of reducing the running count of this test before calling the // tRunner and increasing it afterwards, we rely on tRunner keeping the // count correct. This ensures that a sequence of sequential tests runs // without being preempted, even when their parent is a parallel test. This // may especially reduce surprises if *parallel == 1. go tRunner(t, f)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 76.1K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
machineInfo *cadvisorapi.MachineInfo // Container GC manager containerGC *containerGC // Keyring for pulling images keyring credentialprovider.DockerKeyring // Runner of lifecycle events. runner kubecontainer.HandlerRunner // RuntimeHelper that wraps kubelet to generate runtime container options. runtimeHelper kubecontainer.RuntimeHelper // Health check results.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/BUILD
"@llvm-project//mlir:Transforms", "@local_xla//xla/translate/hlo_to_mhlo:translate", "@stablehlo//:stablehlo_ops", ], ) tf_cc_binary( name = "mlir-tflite-runner", srcs = [ "mlir_tflite_runner.cc", ], deps = [ ":flatbuffer_translate_lib", ":flatbuffer_translate_registration", ":tensorflow_lite",
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jun 12 21:41:49 UTC 2024 - 49.9K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
if container.Lifecycle != nil && container.Lifecycle.PostStart != nil { kubeContainerID := kubecontainer.ContainerID{ Type: m.runtimeName, ID: containerID, } msg, handlerErr := m.runner.Run(ctx, kubeContainerID, pod, container, container.Lifecycle.PostStart) if handlerErr != nil { klog.ErrorS(handlerErr, "Failed to execute PostStartHook", "pod", klog.KObj(pod),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
serviceHealthServer := healthcheck.NewServiceHealthServer(hostname, recorder, nodePortAddresses, healthzServer) nfacctRunner, err := nfacct.New() if err != nil { logger.Error(err, "Failed to create nfacct runner") } proxier := &Proxier{ ipFamily: ipFamily, svcPortMap: make(proxy.ServicePortMap),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
gradle/verification-metadata.xml
</artifact> </component> <component group="gradle.plugin.org.ysb33r.gradle" name="gradle-runner" version="1.1"> <artifact name="gradle-runner-1.1.jar"> <sha256 value="7de9b7ade957c6a1996e9c3d0e1e4d1e1840c081ebf16bbd3c2a6a5b05b88891" reason="Artifact is not signed"/> </artifact> </component>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 21 22:30:36 UTC 2024 - 90.1K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/AbstractGradleExecuter.java
protected final static Set<String> PROPAGATED_SYSTEM_PROPERTIES = new HashSet<>(); // TODO - don't use statics to communicate between the test runner and executer public static void propagateSystemProperty(String name) { PROPAGATED_SYSTEM_PROPERTIES.add(name); } public static void doNotPropagateSystemProperty(String name) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 55.1K bytes - Viewed (0) -
cluster/gce/windows/k8s-node-setup.psm1
Log-Output -Fatal ` "A kubelet process is already running, don't know what to do" } Log-Output "Creating kubelet service" & sc.exe create kubelet binPath= "${env:NODE_DIR}\kube-log-runner.exe -log-file=${env:LOGS_DIR}\kubelet.log ${env:NODE_DIR}\kubelet.exe ${kubelet_args}" start= demand & sc.exe failure kubelet reset= 0 actions= restart/10000 Log-Output "Starting kubelet service" & sc.exe start kubelet
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 88.3K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
burstSyncs := 2 klog.V(3).InfoS("Record sync param", "minSyncPeriod", minSyncPeriod, "syncPeriod", syncPeriod, "burstSyncs", burstSyncs) proxier.syncRunner = async.NewBoundedFrequencyRunner("sync-runner", proxier.syncProxyRules, minSyncPeriod, syncPeriod, burstSyncs) return proxier, nil } func NewDualStackProxier( syncPeriod time.Duration, minSyncPeriod time.Duration, hostname string,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
} burstSyncs := 2 logger.V(2).Info("NFTables sync params", "minSyncPeriod", minSyncPeriod, "syncPeriod", syncPeriod, "burstSyncs", burstSyncs) proxier.syncRunner = async.NewBoundedFrequencyRunner("sync-runner", proxier.syncProxyRules, minSyncPeriod, syncPeriod, burstSyncs) return proxier, nil } // internal struct for string service information type servicePortInfo struct { *proxy.BaseServicePortInfo
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0)