- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,315 for stops (0.06 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) -
cmd/routers.go
} // configureServer handler returns final handler for the http server. func configureServerHandler(endpointServerPools EndpointServerPools) (http.Handler, error) { // Initialize router. `SkipClean(true)` stops minio/mux from // normalizing URL path minio/minio#3256 router := mux.NewRouter().SkipClean(true).UseEncodedPath() // Initialize distributed NS lock. if globalIsDistErasure {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Mar 08 19:08:18 UTC 2024 - 3.6K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultConditionalExecutionQueueTest.groovy
then: 1 * factory.create(_) >> executor when: queue.stop() then: 1 * executor.stop() } TestExecution testExecution(Callable<String> callable) { return new TestExecution(callable) } class TestExecution extends AbstractConditionalExecution { TestExecution(Callable callable) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 6.9K 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) -
pkg/kubelet/cm/devicemanager/types.go
// update the node capacity to reflect the currently available devices. UpdatePluginResources(node *schedulerframework.NodeInfo, attrs *lifecycle.PodAdmitAttributes) error // Stop stops the manager. Stop() error // GetDeviceRunContainerOptions checks whether we have cached containerDevices // for the passed-in <pod, container> and returns its DeviceRunContainerOptions
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/cli/BuildActionsFactoryTest.groovy
when: def action = convert('--status') then: unwrapAction(action) instanceof ReportDaemonStatusAction } def "stops daemon"() { when: def action = convert('--stop') then: unwrapAction(action) instanceof StopDaemonAction } def "runs daemon in foreground"() { when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 05:33:15 UTC 2024 - 7.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/AsyncDispatch.java
} } private void doRequestStop() { setState(State.Stopped); } /** * Stops accepting new messages, and blocks until all queued messages have been dispatched. */ @Override public void stop() { lock.lock(); try { setState(State.Stopped); waitForAllMessages(); } finally {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 6.7K bytes - Viewed (0) -
src/io/fs/walk.go
// if the function returns a non-nil error, WalkDir stops entirely and // returns that error. // // The err argument reports an error related to path, signaling that // [WalkDir] will not walk into that directory. The function can decide how // to handle that error; as described earlier, returning the error will // cause WalkDir to stop walking the entire tree. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 09 08:50:19 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/slices/slices.go
// Equal reports whether two slices are equal: the same length and all // elements equal. If the lengths are different, Equal returns false. // Otherwise, the elements are compared in increasing index order, and the // comparison stops at the first unequal pair. // Floating point NaNs are not considered equal. func Equal[E comparable](s1, s2 []E) bool { return slices.Equal(s1, s2) } // EqualUnordered reports whether two slices are equal, ignoring order
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 7.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/testing/v1beta1/kms_plugin_mock.go
} klog.InfoS("Starting KMS Plugin", "socketPath", s.socketPath) go s.grpcServer.Serve(s.listener) return nil } // CleanUp stops gRPC server and the underlying listener. func (s *Base64Plugin) CleanUp() { s.grpcServer.Stop() _ = s.listener.Close() _ = os.Remove(s.socketPath) } // EnterFailedState places the plugin into failed state. func (s *Base64Plugin) EnterFailedState() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 29 05:36:41 UTC 2023 - 5.2K bytes - Viewed (0)