- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 857 for crBlock (0.21 sec)
-
src/runtime/rwmutex.go
// while sleeping. acquireLockRankAndM(rw.readRank) lockWithRankMayAcquire(&rw.rLock, getLockRank(&rw.rLock)) if rw.readerCount.Add(1) < 0 { // A writer is pending. Park on the reader queue. systemstack(func() { lock(&rw.rLock) if rw.readerPass > 0 { // Writer finished. rw.readerPass -= 1 unlock(&rw.rLock) } else { // Queue this reader to be woken by // the writer. m := getg().m
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 5K bytes - Viewed (0) -
platforms/core-runtime/time/src/main/java/org/gradle/internal/time/MonotonicClock.java
* in between syncs with the system wall clock. * When issuing the first timestamp after the sync interval has expired, * The system wall clock will be read, and the current time set to the max of wall clock time or the most recently issued timestamp. * All other timestamps are calculated as the wall clock time at last sync + elapsed time since. * <p> * This clock deals relatively well when the system wall clock shift is adjusted by small amounts.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 20:20:17 UTC 2024 - 5K bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/main/java/org/gradle/api/internal/tasks/testing/detection/DefaultTestExecuter.java
private final ActorFactory actorFactory; private final ForkedTestClasspathFactory testClasspathFactory; private final WorkerLeaseService workerLeaseService; private final int maxWorkerCount; private final Clock clock; private final DocumentationRegistry documentationRegistry; private final DefaultTestFilter testFilter; private TestClassProcessor processor; public DefaultTestExecuter(
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 6.6K bytes - Viewed (0) -
platforms/core-runtime/build-profile/src/main/java/org/gradle/profile/ProfileEventAdapter.java
public ProfileEventAdapter(BuildProfile buildProfile, BuildStartedTime buildStartedTime, Clock clock) { this.buildProfile = buildProfile; this.buildStartedTime = buildStartedTime; this.clock = clock; } // BuildListener @Override public void beforeSettings(Settings settings) { long now = clock.getCurrentTime(); buildProfile.setBuildStarted(now);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:39 UTC 2024 - 5.4K bytes - Viewed (0) -
platforms/core-runtime/time/src/main/java/org/gradle/internal/time/Time.java
*/ public static Clock clock() { return CLOCK; } /** * Replacement for System.currentTimeMillis(), based on {@link #clock()}. */ public static long currentTimeMillis() { return CLOCK.getCurrentTime(); } /** * Measures elapsed time. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 20:20:17 UTC 2024 - 2.2K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/slf4j/OutputEventListenerBackedLogger.java
import org.gradle.internal.time.Clock; public class OutputEventListenerBackedLogger extends BuildOperationAwareLogger { private final String name; private final OutputEventListenerBackedLoggerContext context; private final Clock clock; public OutputEventListenerBackedLogger(String name, OutputEventListenerBackedLoggerContext context, Clock clock) { this.name = name;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 2K bytes - Viewed (0) -
platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/impl/legacy/DefaultBuildScanClock.java
import org.gradle.internal.time.Clock; import javax.inject.Inject; public class DefaultBuildScanClock implements BuildScanClock { private final Clock clock; @Inject public DefaultBuildScanClock(Clock clock) { this.clock = clock; } @Override public long getCurrentTime() { return clock.getCurrentTime(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 15 17:58:47 UTC 2024 - 1.1K bytes - Viewed (0) -
pkg/kubelet/util/queue/work_queue.go
} type basicWorkQueue struct { clock clock.Clock lock sync.Mutex queue map[types.UID]time.Time } var _ WorkQueue = &basicWorkQueue{} // NewBasicWorkQueue returns a new basic WorkQueue with the provided clock func NewBasicWorkQueue(clock clock.Clock) WorkQueue { queue := make(map[types.UID]time.Time) return &basicWorkQueue{queue: queue, clock: clock} } func (q *basicWorkQueue) GetWork() []types.UID {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 1.7K bytes - Viewed (0) -
pkg/kubelet/util/queue/work_queue_test.go
// Dial the time to 1 hour ahead. clock.Step(time.Hour) expected = []types.UID{types.UID("foo3"), types.UID("foo4")} compareResults(t, expected, q.GetWork()) compareResults(t, []types.UID{}, q.GetWork()) } func TestNewBasicWorkQueue(t *testing.T) { tests := []struct { clock clock.Clock expectedWorkQueue WorkQueue }{ { clock: clock.RealClock{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 2.4K bytes - Viewed (0) -
pkg/kubelet/active_deadline.go
recorder record.EventRecorder, clock clock.Clock, ) (*activeDeadlineHandler, error) { // check for all required fields if clock == nil || podStatusProvider == nil || recorder == nil { return nil, fmt.Errorf("required arguments must not be nil: %v, %v, %v", clock, podStatusProvider, recorder) } return &activeDeadlineHandler{ clock: clock, podStatusProvider: podStatusProvider,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 3.2K bytes - Viewed (0)