- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for stopped_ (0.16 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) -
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) -
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) -
src/time/tick_test.go
// to have the same signatures as Timer. type tickerTimer struct { *Ticker stopped bool } func (t *tickerTimer) Stop() bool { pending := !t.stopped t.stopped = true t.Ticker.Stop() return pending } func (t *tickerTimer) Reset(d Duration) bool { pending := !t.stopped t.stopped = false t.Ticker.Reset(d) return pending }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java
finalizeReferentCalled = true; } } /** * Keeps a weak reference to the underlying reference queue. When this reference is cleared, we * know that the background thread has stopped and released its strong reference. */ private WeakReference<ReferenceQueue<Object>> queueReference; public void testThatFinalizerStops() { weaklyReferenceQueue();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// Pop already expired watchers. However, explicitly ignore stopped ones, // as we don't delete watcher from bookmarkWatchers when it is stopped. for _, watchers := range c.bookmarkWatchers.popExpiredWatchersThreadUnsafe() { for _, watcher := range watchers { // c.Lock() is held here. // watcher.stopThreadUnsafe() is protected by c.Lock() if watcher.stopped { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/services/internal/RegisteredBuildServiceProvider.java
} /** * Registers a callback to be called just before the service represented by this provider is stopped. * The callback runs even if the service wasn't created. * This provider is used as a callback argument. * <p> * The service will only be stopped after completing all registered callbacks. * * @param stopAction the callback */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 09:24:00 UTC 2024 - 8.1K bytes - Viewed (0) -
platforms/core-runtime/stdlib-java-extensions/src/main/java/org/gradle/internal/service/scopes/ServiceScope.java
import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * Attached to a service interface to indicate in which scopes it is defined in. * Services are lifecycled with their scope, and stopped/closed when the scope is closed. * <p> * Services are visible to other services in the same scope and descendent scopes. * Services are not visible to services in ancestor scopes. * <p>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 1.7K bytes - Viewed (0) -
platforms/core-runtime/daemon-server/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonMain.java
import java.util.List; /** * The entry point for a daemon process. * * If the daemon hits the specified idle timeout the process will exit with 0. If the daemon encounters an internal error or is explicitly stopped (which can be via receiving a stop command, or * unexpected client disconnection) the process will exit with 1. */ public class DaemonMain extends EntryPoint {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 9.8K bytes - Viewed (0) -
platforms/core-runtime/build-state/src/main/java/org/gradle/internal/buildprocess/BuildProcessState.java
} public ServiceRegistry getServices() { return services; } @Override public void close() { // Force the user home services to be stopped first, because the dependencies between the user home services and the global services are not preserved currently CompositeStoppable.stoppable(services.get(GradleUserHomeScopeServiceRegistry.class), services).stop(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 2.5K bytes - Viewed (0)