Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 343 for notifyCh (0.14 sec)

  1. pkg/config/mesh/networks_watcher.go

    	if w == nil {
    		return nil
    	}
    	w.mutex.RLock()
    	defer w.mutex.RUnlock()
    	return w.prevNetworks
    }
    
    // SetNetworks will use the given value for mesh networks and notify all handlers of the change
    func (w *internalNetworkWatcher) SetNetworks(meshNetworks *meshconfig.MeshNetworks) {
    	var handlers []*WatcherHandlerRegistration
    
    	w.mutex.Lock()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Dec 20 18:33:38 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  2. platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/GradleEnterprisePluginService.java

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package org.gradle.internal.enterprise;
    
    import org.gradle.internal.operations.notify.BuildOperationNotificationListener;
    
    /**
     * A service for a particular build invocation
     *
     * Implemented by the Enterprise plugin.
     */
    public interface GradleEnterprisePluginService {
    
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Jul 17 10:17:11 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  3. platforms/enterprise/enterprise/src/main/java/org/gradle/internal/scan/eob/BuildScanEndOfBuildNotifier.java

             */
            BuildScanResult execute(BuildResult buildResult);
        }
    
        void notify(Listener listener);
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Jul 17 10:17:11 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  4. src/os/signal/signal_linux_test.go

    	if _, _, err := syscall.AllThreadsSyscall(syscall.SYS_PRCTL, prSetKeepCaps, 0, 0); err == syscall.ENOTSUP {
    		t.Skip("AllThreadsSyscall disabled with cgo")
    	}
    
    	sig := make(chan os.Signal, 1)
    	Notify(sig, os.Interrupt)
    
    	for i := 0; i <= 100; i++ {
    		if _, _, errno := syscall.AllThreadsSyscall(syscall.SYS_PRCTL, prSetKeepCaps, uintptr(i&1), 0); errno != 0 {
    			t.Fatalf("[%d] failed to set KEEP_CAPS=%d: %v", i, i&1, errno)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 28 18:17:57 UTC 2021
    - 1.1K bytes
    - Viewed (0)
  5. src/cmd/cgo/internal/testcshared/testdata/libgo5/libgo5.go

    // The channel used to read SIGIO signals.
    var sigioChan chan os.Signal
    
    // CatchSIGIO starts catching SIGIO signals.
    //
    //export CatchSIGIO
    func CatchSIGIO() {
    	sigioChan = make(chan os.Signal, 1)
    	signal.Notify(sigioChan, syscall.SIGIO)
    }
    
    // ResetSIGIO stops catching SIGIO signals.
    //
    //export ResetSIGIO
    func ResetSIGIO() {
    	signal.Reset(syscall.SIGIO)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Sep 14 13:19:50 UTC 2023
    - 986 bytes
    - Viewed (0)
  6. platforms/software/version-control/src/integTest/groovy/org/gradle/vcs/internal/SourceDependencyBuildOperationIntegrationTest.groovy

            graphNotifyOps.size() == 2
            graphNotifyOps[0].displayName == "Notify task graph whenReady listeners (:${buildName})"
            graphNotifyOps[0].details.buildPath == ":${buildName}"
            graphNotifyOps[0].parentId == treeGraphOps[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
    - 6.2K bytes
    - Viewed (0)
  7. subprojects/core/src/test/groovy/org/gradle/internal/operations/MaxWorkersTest.groovy

                                release.notify()
                            }
                        })
                        lease.leaseFinish()
                    }
                }
    
                leaseAcquiredLatch.await()
    
                // release the first queue to submit its work
                synchronized (release) {
                    release.notify()
                }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 05 16:29:26 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  8. cni/cmd/install-cni/main.go

    	"istio.io/istio/pkg/log"
    )
    
    func main() {
    	// Create context that cancels on termination signal
    	ctx, cancel := context.WithCancel(context.Background())
    	sigChan := make(chan os.Signal, 1)
    	signal.Notify(sigChan, os.Interrupt, syscall.SIGTERM)
    	go func(sigChan chan os.Signal, cancel context.CancelFunc) {
    		sig := <-sigChan
    		log.Infof("Exit signal received: %s", sig)
    		cancel()
    	}(sigChan, cancel)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  9. src/cmd/cgo/internal/testcarchive/testdata/libgo3/libgo3.go

    // The channel used to read SIGIO signals.
    var sigioChan chan os.Signal
    
    // CatchSIGIO starts catching SIGIO signals.
    //
    //export CatchSIGIO
    func CatchSIGIO() {
    	sigioChan = make(chan os.Signal, 1)
    	signal.Notify(sigioChan, syscall.SIGIO)
    }
    
    // ResetSIGIO stops catching SIGIO signals.
    //
    //export ResetSIGIO
    func ResetSIGIO() {
    	signal.Reset(syscall.SIGIO)
    }
    
    // SawSIGIO reports whether we saw a SIGIO.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 11:59:56 UTC 2023
    - 1020 bytes
    - Viewed (0)
  10. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/FileLockReleasedSignal.java

    /**
     * Signal that a file lock has been released.
     *
     * @see org.gradle.cache.internal.locklistener.FileLockContentionHandler
     */
    public interface FileLockReleasedSignal {
    
        /**
         * Triggers this signal to notify the lock requesters that the file
         * lock has been released.
         *
         * <p>Returns once the signal has been emitted but not necessarily
         * received by the lock requesters.
         */
        void trigger();
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:08:47 UTC 2023
    - 1.1K bytes
    - Viewed (0)
Back to top