Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 966 for fRunner (0.14 sec)

  1. src/testing/fuzz.go

    		f.chatty.Updatef(f.name, "=== RUN   %s\n", f.name)
    	}
    	go fRunner(f, fuzzTest.Fn)
    	<-f.signal
    	if f.chatty != nil {
    		f.chatty.Updatef(f.parent.name, "=== NAME  %s\n", f.parent.name)
    	}
    	return !f.failed
    }
    
    // fRunner wraps a call to a fuzz test and ensures that cleanup functions are
    // called and status flags are set. fRunner should be called in its own
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 22:55:25 UTC 2024
    - 22.9K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/cmd/phases/workflow/runner.go

    	// path of the phase in the workflow managed by the Runner.
    	generatedName string
    
    	// use is the phase usage string that will be printed in the workflow help.
    	// It corresponds to the relative path of the phase in the workflow managed by the Runner.
    	use string
    }
    
    // NewRunner return a new runner for composable kubeadm workflows.
    func NewRunner() *Runner {
    	return &Runner{
    		Phases: []Phase{},
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 21 05:35:15 UTC 2022
    - 16K bytes
    - Viewed (0)
  3. pkg/util/async/runner.go

    func NewRunner(f ...func(stop chan struct{})) *Runner {
    	return &Runner{loopFuncs: f}
    }
    
    // Start begins running.
    func (r *Runner) Start() {
    	r.lock.Lock()
    	defer r.lock.Unlock()
    	if r.stop == nil {
    		c := make(chan struct{})
    		r.stop = &c
    		for i := range r.loopFuncs {
    			go r.loopFuncs[i](*r.stop)
    		}
    	}
    }
    
    // Stop stops running.
    func (r *Runner) Stop() {
    	r.lock.Lock()
    	defer r.lock.Unlock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 29 06:37:00 UTC 2016
    - 1.4K bytes
    - Viewed (0)
  4. guava/src/com/google/common/hash/Funnel.java

     * 3: "Enforce the singleton property with a private constructor or an enum type". For example:
     *
     * <pre>{@code
     * public enum PersonFunnel implements Funnel<Person> {
     *   INSTANCE;
     *   public void funnel(Person person, PrimitiveSink into) {
     *     into.putUnencodedChars(person.getFirstName())
     *         .putUnencodedChars(person.getLastName())
     *         .putInt(person.getAge());
     *   }
     * }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 20 18:43:59 UTC 2021
    - 2.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/hash/Funnel.java

     * 3: "Enforce the singleton property with a private constructor or an enum type". For example:
     *
     * <pre>{@code
     * public enum PersonFunnel implements Funnel<Person> {
     *   INSTANCE;
     *   public void funnel(Person person, PrimitiveSink into) {
     *     into.putUnencodedChars(person.getFirstName())
     *         .putUnencodedChars(person.getLastName())
     *         .putInt(person.getAge());
     *   }
     * }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 20 18:43:59 UTC 2021
    - 2.2K bytes
    - Viewed (0)
  6. maven-core/src/test/resources/apiv4-repo/junit/junit/4.13.1/junit-4.13.1.jar

    File); private void MaxCore(java.io.File); public org.junit.runner.Result run(Class); public org.junit.runner.Result run(org.junit.runner.Request); public org.junit.runner.Result run(org.junit.runner.Request, org.junit.runner.JUnitCore); public org.junit.runner.Request sortRequest(org.junit.runner.Request); private org.junit.runner.Request constructLeafRequest(java.util.List); private org.junit.runner.Runner buildRunner(org.junit.runner.Description); private Class getMalformedTestClas(org.junit....
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Tue Dec 19 19:08:55 UTC 2023
    - 373.7K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/admission/conversion_test.go

    					u(`{"apiVersion": "mygroup.k8s.io/v1","kind": "Flunder","metadata":{"name":"newobj"}}`),
    					u(`{"apiVersion": "mygroup.k8s.io/v1","kind": "Flunder","metadata":{"name":"oldobj"}}`),
    				),
    				VersionedObject:    u(`{"apiVersion": "mygroup.k8s.io/v1","kind": "Flunder","metadata":{"name":"newobjversioned"}}`),
    				VersionedOldObject: u(`{"apiVersion": "mygroup.k8s.io/v1","kind": "Flunder","metadata":{"name":"oldobjversioned"}}`),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:48:03 UTC 2023
    - 13.7K bytes
    - Viewed (0)
  8. testing/performance/src/performanceTest/groovy/org/gradle/performance/regression/buildcache/TaskOutputCachingJavaPerformanceTest.groovy

        def setup() {
            runner.warmUpRuns = 11
            runner.runs = 21
            runner.minimumBaseVersion = "3.5"
        }
    
        def "clean assemble with remote http cache"() {
            setupTestProject(runner)
            protocol = "http"
            pushToRemote = true
            runner.useDaemon = false
            runner.warmUpRuns = 2
            runner.runs = 8
            runner.addBuildMutator { cleanLocalCache() }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 18 13:08:21 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  9. testing/performance/src/performanceTest/groovy/org/gradle/performance/regression/java/JavaFirstUsePerformanceTest.groovy

            given:
            runner.tasksToRun = ['tasks']
            runner.runs = (runner.testProject == (LARGE_JAVA_MULTI_PROJECT_KOTLIN_DSL.projectName) ? 5 : 10)
            runner.useDaemon = false
            runner.addBuildMutator { invocationSettings ->
                new ClearGradleUserHomeMutator(invocationSettings.gradleUserHome, AbstractCleanupMutator.CleanupSchedule.BUILD)
            }
            runner.addBuildMutator { invocationSettings ->
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  10. pkg/proxy/ipvs/util/ipvs_linux.go

    func (runner *runner) UpdateVirtualServer(vs *VirtualServer) error {
    	svc, err := toIPVSService(vs)
    	if err != nil {
    		return fmt.Errorf("could not convert local virtual server to IPVS service: %w", err)
    	}
    	runner.mu.Lock()
    	defer runner.mu.Unlock()
    	return runner.ipvsHandle.UpdateService(svc)
    }
    
    // DeleteVirtualServer is part of ipvs.Interface.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 9K bytes
    - Viewed (0)
Back to top