- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 613 for stops (0.47 sec)
-
platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/registry/impl/AbstractFileWatcherUpdaterTest.groovy
then: def exception = thrown(IllegalStateException) exception.message == "Unable to watch directory '${watchableHierarchy.absolutePath}' since it is within Gradle's caches" } def "stops watching hierarchies when maximum number of hierarchies to watch has been reached"() { int maxHierarchiesToWatch = 4 def oldestRegisteredWatchableHierarchy = file("oldestWatchable").createDir()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 21.5K bytes - Viewed (0) -
src/context/context.go
// one does not replace another. // // Calling the returned stop function stops the association of ctx with f. // It returns true if the call stopped f from being run. // If stop returns false, // either the context is done and f has been started in its own goroutine; // or f was already stopped. // The stop function does not wait for f to complete before returning.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 23.7K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
c1, c2, store := setup(t) c2.maxConnectionAge = maxConnAge stopped1 := false stop1, stop2 := make(chan struct{}), make(chan struct{}) defer func() { // stop1 should be killed early, as part of test if !stopped1 { close(stop1) } }() defer close(stop2) go c1.Run(stop1) go c2.Run(stop2) go store.Run(stop2) n := fakeNode("reg1", "zone1", "subzone1") var p1conn1, p1conn2 *fakeConn
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0) -
src/fmt/scan.go
// If that is less than the number of arguments, err will report why. func Scan(a ...any) (n int, err error) { return Fscan(os.Stdin, a...) } // Scanln is similar to [Scan], but stops scanning at a newline and // after the final item there must be a newline or EOF. func Scanln(a ...any) (n int, err error) { return Fscanln(os.Stdin, a...) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:56:20 UTC 2024 - 31.9K bytes - Viewed (0) -
platforms/core-execution/workers/src/test/groovy/org/gradle/workers/internal/WorkerDaemonClientsManagerTest.groovy
def client1 = Mock(WorkerDaemonClient) def client2 = Mock(WorkerDaemonClient) starter.startDaemon(options) >>> [client1, client2] when: manager.reserveNewClient(options) manager.reserveNewClient(options) manager.stop() then: noExceptionThrown()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Mar 21 14:56:11 UTC 2024 - 10.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/configuration/DaemonBuildOptions.java
} } public static class StopOption extends EnabledOnlyBooleanBuildOption<DaemonParameters> { public StopOption() { super(null, CommandLineOptionConfiguration.create("stop", "Stops the Gradle daemon if it is running.")); } @Override public void applyTo(DaemonParameters settings, Origin origin) { settings.setStop(true); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 08 19:00:19 UTC 2024 - 11.2K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet.go
var ctx context.Context ctx, m.cancelFn = context.WithCancel(context.Background()) go m.dynamicCertificateContent.Run(ctx, 1) } // Stop stops watching the certificate and key files func (m *kubeletServerCertificateDynamicFileManager) Stop() { if m.cancelFn != nil { m.cancelFn() } } // ServerHealthy always returns true since the file manager doesn't communicate with any server
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:16 UTC 2024 - 10.3K bytes - Viewed (0) -
src/runtime/HACKING.md
sharded for efficiency, but doesn't need to be per-thread or per-goroutine. The scheduler's job is to match up a G (the code to execute), an M (where to execute it), and a P (the rights and resources to execute it). When an M stops executing user Go code, for example by entering a system call, it returns its P to the idle P pool. In order to resume executing user Go code, for example on return from a system call, it must acquire a P from the idle pool.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 13.9K bytes - Viewed (0) -
pkg/test/framework/suite.go
// Otherwise it stops test execution. // // Deprecated: Tests should not make assumptions about number of clusters. RequireMinClusters(minClusters int) Suite // RequireMaxClusters ensures that the current environment contains at least the given number of clusters. // Otherwise it stops test execution. //
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 17.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/Daemon.java
} /** * Stops the daemon, blocking until any current requests/connections have been satisfied. * <p> * This is the semantically the same as sending the daemon the Stop command. * <p> * This method does not quite conform to the semantics of the Stoppable contract in that it will NOT * wait for any executing builds to stop before returning. This is by design as we currently have no way of
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 12.9K bytes - Viewed (0)