- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 343 for notifyCh (0.25 sec)
-
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DefaultDaemonConnectionTest.groovy
} def "does not notify disconnect handler once it has been removed"() { Runnable handler = Mock() when: daemonConnection.onDisconnect(handler) daemonConnection.onDisconnect(null) connection.disconnect() daemonConnection.stop() then: 0 * handler._ } def "does not notify disconnect handler on stop"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 11.7K bytes - Viewed (0) -
src/sync/runtime2.go
//go:build !goexperiment.staticlockranking package sync import "unsafe" // Approximation of notifyList in runtime/sema.go. Size and alignment must // agree. type notifyList struct { wait uint32 notify uint32 lock uintptr // key field of the mutex head unsafe.Pointer tail unsafe.Pointer
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 465 bytes - Viewed (0) -
cmd/batch-expire_test.go
# retainVersions: 0 # (default) delete all versions of the object. This option is the fastest. # retainVersions: 5 # keep the latest 5 versions of the object including delete markers. notify: endpoint: https://notify.endpoint # notification endpoint to receive job completion status token: Bearer xxxxx # optional authentication token for the notification endpoint retry:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 3K bytes - Viewed (0) -
src/sync/runtime2_lockrank.go
//go:build goexperiment.staticlockranking package sync import "unsafe" // Approximation of notifyList in runtime/sema.go. Size and alignment must // agree. type notifyList struct { wait uint32 notify uint32 rank int // rank field of the mutex pad int // pad field of the mutex lock uintptr // key field of the mutex head unsafe.Pointer tail unsafe.Pointer
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 546 bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbWatchHandleImpl.java
import jcifs.internal.NotifyResponse; import jcifs.internal.smb1.trans.nt.NtTransNotifyChange; import jcifs.internal.smb1.trans.nt.NtTransNotifyChangeResponse; import jcifs.internal.smb2.notify.Smb2ChangeNotifyRequest; /** * @author mbechler * */ class SmbWatchHandleImpl implements SmbWatchHandle { private static final Logger log = LoggerFactory.getLogger(SmbWatchHandleImpl.class);
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 4.5K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/DefaultProjectConnection.java
operationParamsBuilder.setCancellationToken(new DefaultCancellationTokenSource().token()); operationParamsBuilder.setParameters(parameters); operationParamsBuilder.setEntryPoint("Notify daemons about changed paths API"); connection.run( new ConsumerAction<Void>() { @Override public ConsumerOperationParameters getParameters() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 12:11:05 UTC 2024 - 5K bytes - Viewed (0) -
pkg/revisions/tag_watcher.go
"istio.io/istio/pkg/kube/controllers" "istio.io/istio/pkg/kube/kclient" "istio.io/istio/pkg/kube/kubetypes" "istio.io/istio/pkg/util/sets" ) // TagWatcher keeps track of the current tags and can notify watchers // when the tags change. type TagWatcher interface { Run(stopCh <-chan struct{}) HasSynced() bool AddHandler(handler TagHandler) GetMyTags() sets.String }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/kube/namespace/filter.go
f.lock.Lock() defer f.lock.Unlock() // In rare cases, a namespace may be created after objects in the namespace, because there is no synchronization between watches // So we need to notify if we started selecting namespace if f.namespaceCreatedLocked(ns.ObjectMeta) { f.notifyHandlersLocked(sets.New(ns.Name), nil) } }, UpdateFunc: func(old, new *corev1.Namespace) { f.lock.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 9.3K bytes - Viewed (0) -
src/runtime/mem_wasip1.go
// license that can be found in the LICENSE file. //go:build wasip1 package runtime func resetMemoryDataView() { // This function is a no-op on WASI, it is only used to notify the browser // that its view of the WASM memory needs to be updated when compiling for // GOOS=js.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 17:48:24 UTC 2023 - 392 bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/service/scopes/CoreCrossBuildSessionServices.java
import org.gradle.internal.operations.DefaultBuildOperationQueueFactory; import org.gradle.internal.operations.logging.LoggingBuildOperationProgressBroadcaster; import org.gradle.internal.operations.notify.BuildOperationNotificationBridge; import org.gradle.internal.operations.notify.BuildOperationNotificationValve; import org.gradle.internal.operations.trace.BuildOperationTrace; import org.gradle.internal.resources.DefaultResourceLockCoordinationService;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 5.8K bytes - Viewed (0)