- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 4,605 for statx (0.05 sec)
-
guava/src/com/google/common/util/concurrent/AbstractService.java
+ this + " to reach a terminal state. " + "Current state: " + state()); } } /** Checks that the current state is equal to the expected state. */ @GuardedBy("monitor") private void checkCurrentState(State expected) { State actual = state(); if (actual != expected) { if (actual == FAILED) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.7K bytes - Viewed (0) -
tests/test_dependency_normal_exceptions.py
@pytest.fixture(autouse=True) def reset_state_and_db(): global fake_database global state fake_database = initial_fake_database.copy() state = initial_state.copy() client = TestClient(app) def test_dependency_gets_exception(): assert state["except"] is False assert state["finally"] is False response = client.put("/invalid-user/rick", json="Morty")
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Feb 24 23:06:37 UTC 2024 - 1.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/internal/resolve/result/DefaultBuildableComponentResolveResult.java
} @Override public void resolved(ComponentGraphResolveState state, ComponentGraphSpecificResolveState graphState) { this.state = state; this.graphState = graphState; } @Override public void setResult(ComponentGraphResolveState state) { assertResolved(); this.state = state; } @Override public ComponentIdentifier getId() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/async/ServiceLifecycle.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:55 UTC 2024 - 4K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy.go
"k8s.io/kubernetes/pkg/kubelet/cm/memorymanager/state" "k8s.io/kubernetes/pkg/kubelet/cm/topologymanager" ) // Type defines the policy type type policyType string // Policy implements logic for pod container to a memory assignment. type Policy interface { Name() string Start(s state.State) error // Allocate call is idempotent Allocate(s state.State, pod *v1.Pod, container *v1.Container) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 05 17:52:25 UTC 2021 - 1.8K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultFileLockManagerWithNewProtocolTest.groovy
} def "a lock has been updated when never written to"() { given: def lock = createLock(Shared) def state = lock.state lock.close() when: lock = createLock(lockMode) then: lock.state.hasBeenUpdatedSince(state) cleanup: lock?.close() where: lockMode << [Exclusive, Shared] }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jan 10 15:52:52 UTC 2024 - 7.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/build/DefaultBuildLifecycleController.java
state.notInState(State.Finished, modelController::getConfiguredModel); } @Override public <T> T withProjectsConfigured(Function<? super GradleInternal, T> action) { return state.notInState(State.Finished, () -> action.apply(modelController.getConfiguredModel())); } @Override public void resetModel() { state.restart(State.ReadyToReset, State.Configure, () -> {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 21 11:17:11 UTC 2024 - 16.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/ready.go
r.lock.RLock() defer r.lock.RUnlock() return r.generation, r.state == Ready } // set the state to Pending (false) or Ready (true), it does not have effect if the state is Stopped. func (r *ready) set(ok bool) { r.lock.Lock() defer r.lock.Unlock() if r.state == Stopped { return } if ok && r.state == Pending { r.state = Ready r.generation++ select { case <-r.waitCh: default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 16 13:32:11 UTC 2023 - 4.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/store/CachedStoreFactory.java
} @Override public void close() { LOG.debug(displayName + " cache closed. Cache reads: " + stats.readsFromCache + ", disk reads: " + stats.readsFromDisk + " (avg: " + TimeFormatting.formatDurationVerbose(stats.getDiskReadsAvgMs()) + ", total: " + TimeFormatting.formatDurationVerbose(stats.diskReadsTotalMs.get()) + ")"); } private static class Stats {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:50 UTC 2024 - 3.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
startUpCalled++; assertEquals(State.STARTING, state()); } @Override protected void shutDown() throws Exception { assertEquals(1, startUpCalled); assertEquals(0, shutDownCalled); shutDownCalled++; assertEquals(State.STOPPING, state()); } @Override protected Executor executor() { transitionStates.add(state()); return directExecutor(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.5K bytes - Viewed (0)