- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for STOPPED (0.11 sec)
-
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
f.Lock() defer f.Unlock() if !f.stopped { klog.V(4).Infof("Stopping fake watcher.") close(f.result) f.stopped = true } } func (f *FakeWatcher) IsStopped() bool { f.Lock() defer f.Unlock() return f.stopped } // Reset prepares the watcher to be reused. func (f *FakeWatcher) Reset() { f.Lock() defer f.Unlock() f.stopped = false f.result = make(chan Event) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/actor/internal/DefaultActorFactory.java
synchronized (lock) { stopped = true; } stopped(this); } @Override public void dispatch(MethodInvocation message) { synchronized (lock) { if (stopped) { throw new IllegalStateException("This actor has been stopped."); } dispatch.dispatch(message);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress.go
defer timer.Stop() for { stopped := func() bool { pr.mux.Lock() defer pr.mux.Unlock() for pr.waiting == 0 && !pr.stopped { pr.cond.Wait() } return pr.stopped }() if stopped { return } select { case <-timer.C(): shouldRequest := func() bool { pr.mux.Lock() defer pr.mux.Unlock() return pr.waiting > 0 && !pr.stopped }() if !shouldRequest {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 09:56:38 UTC 2024 - 3K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/AbstractDaemonFixture.groovy
this } DaemonFixture stops() { waitForState(Stopped) this } @Override void assertIdle() { assertHasState(Idle) } @Override void assertBusy() { assertHasState(Busy) } @Override void assertStopped() { assertHasState(Stopped) } @Override void assertCanceled() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 15:22:16 UTC 2024 - 3.8K bytes - Viewed (0) -
security/pkg/nodeagent/sds/server.go
workloadSds *sdsservice grpcWorkloadListener net.Listener grpcWorkloadServer *grpc.Server stopped *atomic.Bool } // NewServer creates and starts the Grpc server for SDS. func NewServer(options *security.Options, workloadSecretCache security.SecretManager, pkpConf *mesh.PrivateKeyProvider) *Server { s := &Server{stopped: atomic.NewBool(false)} s.workloadSds = newSDSService(workloadSecretCache, options, pkpConf)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 07 17:44:41 UTC 2024 - 3.3K bytes - Viewed (0) -
src/internal/syscall/unix/siginfo_linux.go
_CLD_KILLED = 2 _CLD_DUMPED = 3 _CLD_TRAPPED = 4 _CLD_STOPPED = 5 _CLD_CONTINUED = 6 // These are the same as in syscall/syscall_linux.go. core = 0x80 stopped = 0x7f continued = 0xffff ) // WaitStatus converts SiginfoChild, as filled in by the waitid syscall, // to syscall.WaitStatus. func (s *SiginfoChild) WaitStatus() (ws syscall.WaitStatus) { switch s.Code {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 01:23:00 UTC 2024 - 1.6K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultConditionalExecutionQueue.java
} @Override public void submit(ConditionalExecution<T> execution) { if (queueState == QueueState.Stopped) { throw new IllegalStateException("DefaultConditionalExecutionQueue cannot be reused once it has been stopped."); } lock.lock(); try { // expand the thread pool until we hit max workers
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 7.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonProcessState.java
return buildProcessState.getServices(); } public void stopped(DaemonStopState stopState) { this.stopState.set(stopState); } @Override public void close() { if (stopState.get() == DaemonStopState.Forced) { // The daemon could not be stopped cleanly, so the services could still be doing work.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 3.1K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/reset/cleanupnode.go
klog.Warningln("[reset] The kubelet service could not be stopped by kubeadm. Unable to detect a supported init system!") klog.Warningln("[reset] Please ensure kubelet is stopped manually") } else { if !r.DryRun() { fmt.Println("[reset] Stopping the kubelet service") if err := initSystem.ServiceStop("kubelet"); err != nil { klog.Warningf("[reset] The kubelet service could not be stopped by kubeadm: [%v]\n", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 06:58:01 UTC 2024 - 7.1K bytes - Viewed (0) -
platforms/software/testing-base-infrastructure/src/test/groovy/org/gradle/api/internal/tasks/testing/worker/TestWorkerTest.groovy
when: async { worker.execute(workerContext) instant.completed } then: instant.completed > instant.stopped System.properties['org.gradle.test.worker'] == '<worker-id>' and: 1 * factory.create(_, _, _) >> processor 1 * connection.addOutgoing(TestResultProcessor) >> resultProcessor
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 2.9K bytes - Viewed (0)