- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 336 for Clock (0.02 sec)
-
api/maven-api-core/src/test/java/org/apache/maven/api/MonotonicClockTest.java
void testClockTimezone() { MonotonicClock clock = MonotonicClock.get(); assertEquals(ZoneOffset.UTC, clock.getZone(), "Clock should use UTC timezone"); // Verify that attempting to change timezone returns the same instance Clock newClock = clock.withZone(ZoneId.systemDefault()); assertSame(clock, newClock, "withZone() should return the same clock instance"); } @Test
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Jan 15 06:28:29 UTC 2025 - 5.8K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/MonotonicClock.java
package org.apache.maven.api; import java.time.Clock; import java.time.Duration; import java.time.Instant; import java.time.ZoneId; import java.time.ZoneOffset; /** * A Clock implementation that combines monotonic timing with wall-clock time. * <p> * This class provides precise time measurements using {@link System#nanoTime()} * while maintaining wall-clock time information in UTC. The wall-clock timeRegistered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Jan 15 06:28:29 UTC 2025 - 5.6K bytes - Viewed (0) -
internal/bucket/lifecycle/transition.go
trnDate, err := time.Parse(time.RFC3339, dateStr) if err != nil { return errTransitionInvalidDate } // Allow only date timestamp specifying midnight GMT hr, m, sec := trnDate.Clock() nsec := trnDate.Nanosecond() loc := trnDate.Location() if hr != 0 || m != 0 || sec != 0 || nsec != 0 || loc.String() != time.UTC.String() { return errTransitionDateNotMidnight }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 5.1K bytes - Viewed (0) -
guava/src/com/google/common/base/Stopwatch.java
* doing so does <i>not</i> give a reliable measurement of elapsed time, because wall time readings * are inherently approximate, routinely affected by periodic clock corrections. Because this class * (by default) uses {@link System#nanoTime}, it is unaffected by these changes. * * <p>Use this class instead of direct calls to {@link System#nanoTime} for two reasons: * * <ul>
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Oct 08 18:55:33 UTC 2025 - 9.2K bytes - Viewed (0) -
internal/bucket/lifecycle/expiration.go
expDate, err := time.Parse(time.RFC3339, dateStr) if err != nil { return errLifecycleInvalidDate } // Allow only date timestamp specifying midnight GMT hr, m, sec := expDate.Clock() nsec := expDate.Nanosecond() loc := expDate.Location() if hr != 0 || m != 0 || sec != 0 || nsec != 0 || loc.String() != time.UTC.String() { return errLifecycleDateNotMidnight }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 6.6K bytes - Viewed (0) -
cmd/namespace-lock.go
return LockContext{ctx: newCtx, cancel: cancel}, nil } // Unlock - block until write lock is released. func (di *distLockInstance) Unlock(lc LockContext) { if lc.cancel != nil { lc.cancel() } di.rwMutex.Unlock(context.Background()) } // RLock - block until read lock is taken or timeout has occurred.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 9.2K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
defer m.tlock.RUnlock() return m.bucketsThrottle[opts] } // SetBandwidthLimit sets the bandwidth limit for a bucket func (m *Monitor) SetBandwidthLimit(bucket, arn string, limit int64) { m.tlock.Lock() defer m.tlock.Unlock() limitBytes := limit / int64(m.NodeCount) throttle, ok := m.bucketsThrottle[BucketOptions{Name: bucket, ReplicationARN: arn}] if !ok { throttle = &bucketThrottle{} }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6K bytes - Viewed (0) -
cmd/lock-rest-client.go
err = errLockNotInitialized default: err = errors.New(r.Err) } return ok, err } // RLock calls read lock REST API. func (c *lockRESTClient) RLock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCRLock, &args) } // Lock calls lock REST API. func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCLock, &args) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 3.3K bytes - Viewed (0) -
cmd/lock-rest-client_test.go
t.Fatalf("unexpected result. connection was online") } // Attempt all calls. _, err = lkClient.RLock(t.Context(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Rlock to fail") } _, err = lkClient.Lock(t.Context(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Lock to fail") } _, err = lkClient.RUnlock(t.Context(), dsync.LockArgs{}) if err == nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 2K bytes - Viewed (0) -
cmd/lock-rest-server.go
} // RLockHandler - Acquires an RLock. func (l *lockRESTServer) RLockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) { // Add a timeout similar to what we expect upstream. ctx, cancel := context.WithTimeout(context.Background(), dsync.DefaultTimeouts.Acquire) defer cancel() resp := lockRPCRLock.NewResponse() success, err := l.ll.RLock(ctx, *args) if err == nil && !success { err = errLockConflict }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jan 31 19:54:34 UTC 2025 - 6.3K bytes - Viewed (0)