- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 2,236 for stops (0.06 sec)
-
pkg/kubelet/server/stats/volume_stat_calculator.go
s.calcAndStoreStats() }, s.jitterPeriod, 1.0, true, s.stopChannel) }) return s } // StopOnce stops background pod volume calculation. Will not stop a currently executing calculations until // they complete their current iteration. func (s *volumeStatCalculator) StopOnce() *volumeStatCalculator { s.stopO.Do(func() { close(s.stopChannel) }) return s }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 29 00:55:10 UTC 2022 - 7.1K 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) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/inet/TcpConnectorTest.groovy
thread.blockUntil.connected operation.stop { acceptor.stop() } then: operation.stop.end > instant.actionFinished cleanup: acceptor?.stop() connection?.stop() } def "can receive message from peer after peer has closed connection"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 10.4K bytes - Viewed (0) -
src/cmd/compile/internal/base/timings.go
} // Start marks the beginning of a new phase and implicitly stops the previous phase. // The phase name is the colon-separated concatenation of the labels. func (t *Timings) Start(labels ...string) { t.append(labels, true) } // Stop marks the end of a phase and implicitly starts a new phase. // The labels are added to the labels of the ended phase. func (t *Timings) Stop(labels ...string) { t.append(labels, false) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 5.8K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/jvm/test_report_aggregation_plugin.adoc
== Reports [IMPORTANT] ==== By default, Gradle stops executing tasks when any task fails -- including test failures. To ensure that your builds always generate aggregation reports, specify the `--continue` option in your Gradle command.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Dec 07 01:37:51 UTC 2023 - 5.6K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r25/BuildProgressCrossVersionSpec.groovy
} then: "build progress events must be forwarded to the attached listeners" events.assertIsABuild() } def "stops dispatching events to progress listeners when a listener fails and continues with build"() { given: goodCode() when: "launching a build" List<ProgressEvent> resultsOfFirstListener = []
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 7.7K bytes - Viewed (0) -
testing/smoke-test/src/smokeTest/groovy/org/gradle/smoketests/AndroidSantaTrackerSmokeTest.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 checkoutDir.listFiles().findAll { isGradleProjectDir(it) }.each { new File(it, "build/intermediates/merged_shaders/debug/out").mkdirs()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/kubelet/eviction/types.go
type CgroupNotifier interface { // Start causes the CgroupNotifier to begin notifying on the eventCh Start(eventCh chan<- struct{}) // Stop stops all processes and cleans up file descriptors associated with the CgroupNotifier Stop() } // NotifierFactory creates CgroupNotifer type NotifierFactory interface { // NewCgroupNotifier creates a CgroupNotifier that creates events when the threshold
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 7.1K 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) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/testing/v2/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: Fri Jul 21 19:25:52 UTC 2023 - 6.5K bytes - Viewed (0)