- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 2,236 for stops (0.24 sec)
-
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandlerTest.groovy
when: handler.reservePort() handler.start(10, {}) handler.stop() then: 1 * factory.create(_ as String) >> lockRequestListener 1 * factory.create(_ as String) >> releaseLockActionExecutor 1 * lockRequestListener.stop() 1 * releaseLockActionExecutor.stop() } def "stopping is safe even if the handler was not initialized"() { when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 6.1K bytes - Viewed (0) -
testing/performance/src/performanceTest/groovy/org/gradle/performance/regression/android/AndroidIncrementalExecutionPerformanceTest.groovy
// See: https://android.googlesource.com/platform/tools/base/+/studio-master-dev/build-system/gradle-core/src/main/java/com/android/build/gradle/tasks/ShaderCompile.java#120 // TODO: remove this once AGP stops checking for the existence of these directories at configuration time workingDir.listFiles().findAll { it.isDirectory() && new File(it, "build.gradle").exists() }.each {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:24:57 UTC 2024 - 6.8K bytes - Viewed (0) -
src/cmd/go/testdata/script/govcs.txt
env GO111MODULE=on env proxy=$GOPROXY env GOPROXY=direct # GOVCS stops go get env GOVCS='*:none' ! go get github.com/google/go-cmp stderr '^go: GOVCS disallows using git for public github.com/google/go-cmp; see ''go help vcs''$' env GOPRIVATE='github.com/google' ! go get github.com/google/go-cmp stderr '^go: GOVCS disallows using git for private github.com/google/go-cmp; see ''go help vcs''$' # public pattern works
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 16 14:41:02 UTC 2023 - 3.1K bytes - Viewed (0) -
src/runtime/trace/trace.go
}() tracing.enabled.Store(true) return nil } // Stop stops the current tracing, if any. // Stop only returns after all the writes for the trace have completed. func Stop() { tracing.Lock() defer tracing.Unlock() tracing.enabled.Store(false) runtime.StopTrace() } var tracing struct { sync.Mutex // gate mutators (Start, Stop) enabled atomic.Bool
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 20 00:47:09 UTC 2023 - 5.1K bytes - Viewed (0) -
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) -
staging/src/k8s.io/apimachinery/pkg/util/wait/backoff.go
func (b Backoff) DelayFunc() DelayFunc { steps := b.Steps duration := b.Duration cap := b.Cap factor := b.Factor jitter := b.Jitter return func() time.Duration { var nextDuration time.Duration // jitter is applied per step and is not cumulative over multiple steps nextDuration, duration, steps = delay(steps, duration, cap, factor, jitter) return nextDuration } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 16.5K 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)