- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 93 for stopCh (0.15 sec)
-
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/ConfigurationCacheClassLoaderScopeRegistryListener.kt
private val loaders = mutableMapOf<ClassLoader, Pair<ClassLoaderScopeSpec, ClassLoaderRole>>() override fun afterStart() { listenerManager.add(this) } /** * Stops recording [ClassLoaderScopeSpec]s and releases any recorded state. */ fun dispose() { synchronized(lock) { // TODO:configuration-cache find a way to make `dispose` unnecessary;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 4.7K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/integTest/groovy/org/gradle/internal/remote/UnicastMessagingIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 09:21:43 UTC 2024 - 8.9K bytes - Viewed (0) -
src/iter/iter.go
// next and stop. // // Next returns the next value in the sequence // and a boolean indicating whether the value is valid. // When the sequence is over, next returns the zero V and false. // It is valid to call next after reaching the end of the sequence // or after calling stop. These calls will continue // to return the zero V and false. // // Stop ends the iteration. It must be called when the caller is
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:09:28 UTC 2024 - 6.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/namespacecontroller_test.go
meshWatcher := mesh.NewTestWatcher(&meshconfig.MeshConfig{}) stop := test.NewStop(t) discoveryNamespacesFilter := filter.NewDiscoveryNamespacesFilter( kclient.New[*v1.Namespace](client), meshWatcher, stop, ) kube.SetObjectFilter(client, discoveryNamespacesFilter) nc := NewNamespaceController(client, watcher) client.RunAndWait(stop) go nc.Run(stop) retry.UntilOrFail(t, nc.queue.HasSynced)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 8.1K bytes - Viewed (0) -
src/internal/trace/parser.go
EvGoStart = 14 // goroutine starts running [timestamp, goroutine id, seq] EvGoEnd = 15 // goroutine ends [timestamp] EvGoStop = 16 // goroutine stops (like in select{}) [timestamp, stack] EvGoSched = 17 // goroutine calls Gosched [timestamp, stack] EvGoPreempt = 18 // goroutine is preempted [timestamp, stack]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:31:04 UTC 2024 - 4.7K bytes - Viewed (0) -
doc/next/6-stdlib/1-time.md
now unbuffered, with capacity 0. The main effect of this change is that Go now guarantees that for any call to a `Reset` or `Stop` method, no stale values prepared before that call will be sent or received after the call. Earlier versions of Go used channels with a one-element buffer, making it difficult to use `Reset` and `Stop` correctly. A visible effect of this change is that `len` and `cap` of timer channels
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 20:49:22 UTC 2024 - 1.5K bytes - Viewed (0) -
.github/workflows/run-mint.sh
docker volume prune -f || true docker volume rm $(docker volume ls -q -f dangling=true) || true # Stop two nodes, one of each pool, to check that all S3 calls work while quorum is still there [ "${MODE}" == "pools" ] && docker-compose -f minio-${MODE}.yaml stop minio2 [ "${MODE}" == "pools" ] && docker-compose -f minio-${MODE}.yaml stop minio6 # Pause one node, to check that all S3 calls work while one node goes wrong
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 1.9K bytes - Viewed (0) -
platforms/core-runtime/client-services/src/test/groovy/org/gradle/internal/daemon/client/clientinput/DaemonClientInputForwarderTest.groovy
then: receiveClosed() when: forwarder.stop() then: !receivedCommand() } def "stream being closed without sending anything just sends close input command"() { when: forwarder.stop() then: receiveClosed() } def cleanup() { source.close()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 12:11:05 UTC 2024 - 5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/api/DaemonConnection.java
* <li>A {@link org.gradle.launcher.daemon.protocol.CloseInput} event received from the client.</li> * <li>When the client connection disconnects unexpectedly.</li> * <li>When the connection is closed using {@link #stop()}.</li> * </ul> * * Note: the end of input may be signalled from another thread before this method returns. * * @param handler the handler. Use null to remove the current handler. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 3.8K bytes - Viewed (0) -
src/cmd/link/testdata/linkname/ok.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:05:33 UTC 2024 - 433 bytes - Viewed (0)