- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for newConditions (0.35 sec)
-
pkg/volume/util/resize_util_test.go
{ description: "when removing all conditions", pvc: pvc.DeepCopy(), newConditions: []v1.PersistentVolumeClaimCondition{}, finalConditions: []v1.PersistentVolumeClaimCondition{}, }, { description: "adding new condition", pvc: pvc.DeepCopy(), newConditions: []v1.PersistentVolumeClaimCondition{ { Type: v1.PersistentVolumeClaimFileSystemResizePending,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/kubelet/nodestatus/setters.go
for i := range node.Status.Conditions { if node.Status.Conditions[i].Type == v1.NodeMemoryPressure { condition = &node.Status.Conditions[i] } } newCondition := false // If the NodeMemoryPressure condition doesn't exist, create one if condition == nil { condition = &v1.NodeCondition{ Type: v1.NodeMemoryPressure, Status: v1.ConditionUnknown, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 12:12:04 UTC 2024 - 30.5K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/TestManagedExecutor.groovy
import java.util.concurrent.locks.ReentrantLock class TestManagedExecutor extends AbstractExecutorService implements ManagedExecutor { private final Lock lock = new ReentrantLock() private final Condition condition = lock.newCondition() private int count private final TestExecutor executor; TestManagedExecutor(TestExecutor executor) { this.executor = executor } void execute(Runnable command) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ChainingHttpHandler.java
private int requestsStarted; ChainingHttpHandler(Lock lock, int timeoutMs, AtomicInteger counter, WaitPrecondition first) { this.lock = lock; this.condition = lock.newCondition(); this.timeoutMs = timeoutMs; this.counter = counter; this.last = first; } public <T extends TrackingHttpHandler> T addHandler(HandlerFactory<T> factory) { lock.lock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 10.5K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/async/ServiceLifecycle.java
private enum State {RUNNING, STOPPING, STOPPED} private final String displayName; private final Lock lock = new ReentrantLock(); private final Condition condition = lock.newCondition(); private final Map<Thread, Integer> usages = new HashMap<>(); private State state = State.RUNNING; public ServiceLifecycle(String displayName) { this.displayName = displayName; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:55 UTC 2024 - 4K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/TestExecutor.groovy
import java.util.concurrent.locks.Lock import java.util.concurrent.locks.ReentrantLock class TestExecutor implements Executor { private final Lock lock = new ReentrantLock() private final Condition condition = lock.newCondition() private final Set<Thread> threads = new HashSet<Thread>() private final TestLogger logger private Thread owner private Throwable failure private int threadNum
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.9K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/SendPartialResponseThenBlock.java
SendPartialResponseThenBlock(Lock lock, Duration timeout, WaitPrecondition precondition, byte[] content) { this.lock = lock; this.timeout = timeout; condition = lock.newCondition(); this.precondition = precondition; this.content = content; } @Override public void writeTo(int requestId, HttpExchange exchange) throws IOException {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultDaemonConnection.java
} private static abstract class CommandQueue<C extends Message, H> implements Stoppable { private final Lock lock = new ReentrantLock(); private final Condition condition = lock.newCondition(); protected final LinkedList<C> queue = new LinkedList<C>(); private final String name; private ManagedExecutor executor; private boolean removed;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 16K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy
class ConcurrentTestUtil extends ExternalResource { private static final Logger LOG = LoggerFactory.getLogger(ConcurrentTestUtil.class) private Lock lock = new ReentrantLock() private Condition threadsChanged = lock.newCondition() private Set<TestThread> threads = [] as Set private Closure failureHandler private List<Throwable> failures = [] private timeout = 5000 ConcurrentTestUtil() {}
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 22.9K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
// OR if the number of failed jobs increased since the last syncJob jobCtx.finishedCondition = newCondition(batch.JobFailed, v1.ConditionTrue, batch.JobReasonBackoffLimitExceeded, "Job has reached the specified backoff limit", jm.clock.Now()) } else if jm.pastActiveDeadline(&job) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0)