- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 2,536 for rerunning (0.3 sec)
-
staging/src/k8s.io/api/authentication/v1beta1/zz_generated.prerelease-lifecycle.go
// APILifecycleIntroduced is an autogenerated function, returning the release in which the API struct was introduced as int versions of major and minor for comparison. // It is controlled by "k8s:prerelease-lifecycle-gen:introduced" tags in types.go. func (in *SelfSubjectReview) APILifecycleIntroduced() (major, minor int) { return 1, 27 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 23:42:33 UTC 2023 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/api/storagemigration/v1alpha1/zz_generated.prerelease-lifecycle.go
// APILifecycleIntroduced is an autogenerated function, returning the release in which the API struct was introduced as int versions of major and minor for comparison. // It is controlled by "k8s:prerelease-lifecycle-gen:introduced" tags in types.go. func (in *StorageVersionMigration) APILifecycleIntroduced() (major, minor int) { return 1, 30 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 3K bytes - Viewed (0) -
pkg/kubelet/pleg/generic.go
g.runningMu.Lock() defer g.runningMu.Unlock() if !g.isRunning { g.isRunning = true g.stopCh = make(chan struct{}) go wait.Until(g.Relist, g.relistDuration.RelistPeriod, g.stopCh) } } func (g *GenericPLEG) Stop() { g.runningMu.Lock() defer g.runningMu.Unlock() if g.isRunning { close(g.stopCh) g.isRunning = false } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Callables.java
public final class Callables { private Callables() {} /** Creates a {@code Callable} which immediately returns a preset value each time it is called. */ public static <T extends @Nullable Object> Callable<T> returning(@ParametricNullness T value) { return () -> value; } /** * Creates an {@link AsyncCallable} from a {@link Callable}. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 4.4K bytes - Viewed (0) -
pilot/pkg/config/monitor/README.md
system components can be notified of changes via `controller.RegisterEventHandler()`. ### Start behavior The `Start` method will immediately check the provided `getSnapshotFunc` and update the controller appropriately before returning. This helps to simplify tests that rely on starting in a particular state.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Sep 14 20:15:07 UTC 2019 - 2.1K bytes - Viewed (0) -
staging/src/k8s.io/api/authorization/v1/zz_generated.prerelease-lifecycle.go
// APILifecycleIntroduced is an autogenerated function, returning the release in which the API struct was introduced as int versions of major and minor for comparison. // It is controlled by "k8s:prerelease-lifecycle-gen:introduced" tags in types.go. func (in *LocalSubjectAccessReview) APILifecycleIntroduced() (major, minor int) { return 1, 19 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 2K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1/zz_generated.prerelease-lifecycle.go
// APILifecycleIntroduced is an autogenerated function, returning the release in which the API struct was introduced as int versions of major and minor for comparison. // It is controlled by "k8s:prerelease-lifecycle-gen:introduced" tags in types.go. func (in *CronJob) APILifecycleIntroduced() (major, minor int) { return 1, 21 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractIdleService.java
} @Override public String toString() { return serviceName() + " [" + state() + "]"; } @Override public final boolean isRunning() { return delegate.isRunning(); } @Override public final State state() { return delegate.state(); } /** @since 13.0 */ @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 17 13:59:28 UTC 2023 - 5.3K bytes - Viewed (0) -
guava/src/com/google/common/base/Stopwatch.java
*/ public boolean isRunning() { return isRunning; } /** * Starts the stopwatch. * * @return this {@code Stopwatch} instance * @throws IllegalStateException if the stopwatch is already running. */ @CanIgnoreReturnValue public Stopwatch start() { checkState(!isRunning, "This stopwatch is already running."); isRunning = true; startTick = ticker.read();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 23 15:09:35 UTC 2023 - 9.2K bytes - Viewed (0) -
tensorflow/cc/training/coordinator.cc
mutex_lock l(runners_lock_); for (const auto& runner : runners_) { if (runner->IsRunning()) { return false; } } return true; } Status Coordinator::RequestStop() { mutex_lock l(mu_); if (should_stop_) { return Status(absl::StatusCode::kFailedPrecondition, "The Coordinator is not running."); } should_stop_ = true; wait_for_stop_.notify_all();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 3.2K bytes - Viewed (0)