Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 343 for notifyCh (0.32 sec)

  1. subprojects/composite-builds/src/integTest/groovy/org/gradle/integtests/composite/CompositeBuildOperationsIntegrationTest.groovy

            graphNotifyOps.size() == 2
            graphNotifyOps[0].displayName == "Notify task graph whenReady listeners (:buildB)"
            graphNotifyOps[0].details.buildPath == ":buildB"
            graphNotifyOps[0].parentId == treeTaskGraphOps[0].id
            graphNotifyOps[1].displayName == 'Notify task graph whenReady listeners'
            graphNotifyOps[1].details.buildPath == ':'
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Feb 09 13:43:40 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  2. subprojects/composite-builds/src/integTest/groovy/org/gradle/integtests/composite/CompositeBuildBuildSrcBuildOperationsIntegrationTest.groovy

            graphNotifyOps.size() == 3
            graphNotifyOps[0].displayName == 'Notify task graph whenReady listeners (:buildB:buildSrc)'
            graphNotifyOps[0].details.buildPath == ':buildB:buildSrc'
            graphNotifyOps[0].parentId == treeTaskGraphOps[0].id
            graphNotifyOps[1].displayName == "Notify task graph whenReady listeners (:buildB)"
            graphNotifyOps[1].details.buildPath == ":buildB"
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Feb 09 13:43:40 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  3. subprojects/core/src/main/java/org/gradle/initialization/ProjectsEvaluatedNotifier.java

        public ProjectsEvaluatedNotifier(BuildOperationRunner buildOperationRunner) {
            this.buildOperationRunner = buildOperationRunner;
        }
    
        public void notify(GradleInternal gradle) {
            buildOperationRunner.run(new NotifyProjectsEvaluatedListeners(gradle));
        }
    
        private static class NotifyProjectsEvaluatedListeners implements RunnableBuildOperation {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Mar 08 13:46:07 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  4. tensorflow/cc/training/coordinator_test.cc

    namespace tensorflow {
    namespace {
    
    using error::Code;
    
    void WaitForStopThread(Coordinator* coord, Notification* about_to_wait,
                           Notification* done) {
      about_to_wait->Notify();
      coord->WaitForStop();
      done->Notify();
    }
    
    TEST(CoordinatorTest, TestStopAndWaitOnStop) {
      Coordinator coord;
      EXPECT_EQ(coord.ShouldStop(), false);
    
      Notification about_to_wait;
      Notification done;
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Mar 23 09:10:43 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  5. platforms/enterprise/enterprise/src/integTest/groovy/org/gradle/internal/enterprise/BaseBuildScanPluginCheckInFixture.groovy

    import org.gradle.internal.enterprise.core.GradleEnterprisePluginManager
    import org.gradle.internal.operations.notify.BuildOperationFinishedNotification
    import org.gradle.internal.operations.notify.BuildOperationNotificationListener
    import org.gradle.internal.operations.notify.BuildOperationProgressNotification
    import org.gradle.internal.operations.notify.BuildOperationStartedNotification
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 21 11:17:11 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  6. subprojects/core/src/test/groovy/org/gradle/api/internal/tasks/DefaultFinalizingValidatingPropertyTest.groovy

            1 * value.prepareValue()
            0 * value._
    
            when:
            property.cleanupValue()
    
            then:
            1 * value.cleanupValue()
            0 * value._
        }
    
        def "does not notify null property value"() {
            def valueWrapper = Stub(PropertyValue)
            def property = new DefaultFinalizingValidatingProperty("name", valueWrapper, true, ValidationActions.NO_OP)
    
            given:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Nov 15 21:15:55 UTC 2022
    - 2.4K bytes
    - Viewed (0)
  7. subprojects/core/src/main/java/org/gradle/configuration/project/LifecycleProjectEvaluator.java

     * wrapping the work in build operations.
     *
     * The build operation structure is:
     *
     * - Evaluate project
     * -- Notify before evaluate
     * -- Notify after evaluate
     *
     * Notably, there is no explicit operation for just the project.evaluate() (which is where the build scripts etc. run).
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Mar 08 13:46:07 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  8. pkg/cmd/cmd.go

    func WaitSignal(stop chan struct{}) {
    	sigs := make(chan os.Signal, 1)
    	signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
    	<-sigs
    	close(stop)
    	_ = log.Sync()
    }
    
    // WaitSignalFunc awaits for SIGINT or SIGTERM and calls the cancel function
    func WaitSignalFunc(cancel func()) {
    	sigs := make(chan os.Signal, 1)
    	signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
    	<-sigs
    	cancel()
    	_ = log.Sync()
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  9. src/os/exec_test.go

    		t.Skip("Process literals do not work on Windows. FindProcess/etc must initialize the process handle")
    	}
    	if runtime.GOARCH == "wasm" {
    		t.Skip("Signals send + notify not fully supported om wasm port")
    	}
    
    	c := make(chan os.Signal, 1)
    	signal.Notify(c, os.Interrupt)
    	defer signal.Stop(c)
    
    	p := &os.Process{Pid: os.Getpid()}
    	if err := p.Signal(os.Interrupt); err != nil {
    		t.Fatalf("Signal got err %v, want nil", err)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 18:08:44 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  10. src/runtime/testdata/testprogcgo/exec.go

    	}
    
    	c := make(chan os.Signal, 1)
    	signal.Notify(c, syscall.SIGTERM)
    	go func() {
    		for range c {
    		}
    	}()
    
    	const goCount = 10
    	const execCount = 10
    	var wg sync.WaitGroup
    	wg.Add(goCount*execCount + goCount)
    	for i := 0; i < goCount; i++ {
    		go func() {
    			defer wg.Done()
    			for j := 0; j < execCount; j++ {
    				c2 := make(chan os.Signal, 1)
    				signal.Notify(c2, syscall.SIGUSR1)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Dec 13 18:45:54 UTC 2021
    - 2.1K bytes
    - Viewed (0)
Back to top