- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,389 for stops (0.05 sec)
-
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) -
tensorflow/compiler/jit/device_util.h
class DeviceSet { public: void Insert(DeviceId device_id); void UnionWith(const DeviceSet& other); bool IsEmpty() const; // Calls `func` on each DeviceId in the set. Stops iterating early if `func` // return false. // // TODO(sanjoy): Change this to take a typed std::function if that's // performance neutral. template <typename FnTy> void ForEach(FnTy func) const {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 15 17:18:31 UTC 2024 - 7.1K 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) -
src/os/dir.go
// group, and others while retaining any existing execute bits from // the file in fsys. // // Symbolic links in fsys are not supported, a *PathError with Err set // to ErrInvalid is returned on symlink. // // Copying stops at and returns the first error encountered. func CopyFS(dir string, fsys fs.FS) error { return fs.WalkDir(fsys, ".", func(path string, d fs.DirEntry, err error) error { if err != nil { return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 6.1K 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) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/structural.go
Title string Default JSON Nullable bool } // +k8s:deepcopy-gen=true // Extensions contains the Kubernetes OpenAPI v3 vendor extensions. type Extensions struct { // x-kubernetes-preserve-unknown-fields stops the API server // decoding step from pruning fields which are not specified // in the validation schema. This affects fields recursively, // but switches back to normal pruning behaviour if nested
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 20:13:14 UTC 2024 - 6.9K 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) -
security/pkg/nodeagent/sds/sdsservice.go
b := backoff.NewExponentialBackOff(backoff.DefaultOption()) // context for both timeout and channel, whichever stops first, the context will be done ctx, cancel := context.WithCancel(context.Background()) go func() { select { case <-ret.stop: cancel() case <-ctx.Done(): } }() defer cancel() _ = b.RetryWithContext(ctx, func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0)