Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 844 for steady (0.32 sec)

  1. platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/inputs/undeclared/UndeclaredBuildInputsTestKitInjectedJavaPluginIntegrationTest.groovy

            javaPlugin(builder.sourceFile("SneakyPlugin.java"), read)
            builder.resourceFile("META-INF/gradle-plugins/sneaky.properties") << """
    implementation-class: SneakyPlugin
            """
            builder.buildJar(jar)
            buildFile << """
                plugins { id("sneaky") }
            """
        }
    
        static class TestKitBackedGradleExecuter extends AbstractGradleExecuter {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:25 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  2. pkg/test/framework/components/echo/kube/workload_manager.go

    	for _, w := range m.workloads {
    		if w.pod.Name == pod.Name {
    			prevReady := w.IsReady()
    			if err := w.Update(*pod); err != nil {
    				return err
    			}
    
    			// Defer notifying the handler until after we release the mutex.
    			if !prevReady && w.IsReady() {
    				workloadReady = w
    			} else if prevReady && !w.IsReady() {
    				workloadNotReady = w
    			}
    			return nil
    		}
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 14 02:12:37 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  3. src/internal/trace/testdata/generators/go122-syscall-steal-proc-simple-bare-m.go

    	b0.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoRunning)
    	b0.Event("GoSyscallBegin", testgen.Seq(1), testgen.NoStack)
    	b0.Event("GoSyscallEndBlocked")
    
    	// A bare M steals the goroutine's P.
    	b1 := g.Batch(trace.ThreadID(1), 0)
    	b1.Event("ProcSteal", trace.ProcID(0), testgen.Seq(2), trace.ThreadID(0))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:15:28 UTC 2024
    - 855 bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/server.go

    	if err != nil {
    		return nil, fmt.Errorf("error starting cni server: %w", err)
    	}
    	s.cniServerStopFunc = cniServer.Stop
    
    	return s, nil
    }
    
    func (s *Server) Ready() {
    	s.isReady.Store(true)
    }
    
    func (s *Server) NotReady() {
    	s.isReady.Store(false)
    }
    
    // buildKubeClient creates the kube client
    func buildKubeClient(kubeConfig string) (kube.Client, error) {
    	// Used by validation
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 21:45:18 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  5. cni/pkg/install/install.go

    	}
    	return nil
    }
    
    // Sets isReady to true.
    func setReady(isReady *atomic.Value) {
    	installReady.Record(1)
    	isReady.Store(true)
    }
    
    // Sets isReady to false.
    func setNotReady(isReady *atomic.Value) {
    	installReady.Record(0)
    	isReady.Store(false)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 21:45:18 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  6. pkg/proxy/endpoint.go

    // IsLocal is part of proxy.Endpoint interface.
    func (info *BaseEndpointInfo) IsLocal() bool {
    	return info.isLocal
    }
    
    // IsReady returns true if an endpoint is ready and not terminating.
    func (info *BaseEndpointInfo) IsReady() bool {
    	return info.ready
    }
    
    // IsServing returns true if an endpoint is ready, regardless of if the
    // endpoint is terminating.
    func (info *BaseEndpointInfo) IsServing() bool {
    	return info.serving
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:38:25 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  7. platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/inputs/process/ProcessInPluginIntegrationTest.groovy

                }
    
                plugins {
                    id ("org.example.sneaky")
                }
            """)
    
            when:
            configurationCacheFails(":help")
    
            then:
            failure.assertOutputContains("Hello")
            problems.assertFailureHasProblems(failure) {
                withProblem("Plugin 'org.example.sneaky': external process started")
            }
    
            where:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:25 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. pkg/proxy/topology.go

    		clusterEndpoints = filterEndpoints(endpoints, func(ep Endpoint) bool {
    			if !ep.IsReady() {
    				return false
    			}
    			if useTopology && !availableForTopology(ep, nodeLabels) {
    				return false
    			}
    			return true
    		})
    
    		// if there are 0 cluster-wide endpoints, we can try to fallback to any terminating endpoints that are ready.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 06:46:03 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  9. src/internal/trace/testdata/generators/go122-syscall-steal-proc-reacquire-new-proc-bare-m.go

    	b0.Event("GoSyscallBegin", testgen.Seq(1), testgen.NoStack)
    	b0.Event("ProcStart", trace.ProcID(1), testgen.Seq(1))
    	b0.Event("GoSyscallEndBlocked")
    
    	// A bare M steals the goroutine's P.
    	b1 := g.Batch(trace.ThreadID(1), 0)
    	b1.Event("ProcSteal", trace.ProcID(0), testgen.Seq(2), trace.ThreadID(0))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:15:28 UTC 2024
    - 999 bytes
    - Viewed (0)
  10. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/testdata/swagger.json

          "properties": {
            "minReadySeconds": {
              "description": "Minimum number of seconds for which a newly created pod should be ready without any of its container crashing, for it to be considered available. Defaults to 0 (pod will be considered available as soon as it is ready)",
              "format": "int32",
              "type": "integer"
            },
            "paused": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 20 15:45:02 UTC 2024
    - 229.4K bytes
    - Viewed (0)
Back to top