- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 343 for notifyCh (0.14 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)