Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for fRunner (0.57 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top