Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 336 for Clock (0.02 sec)

  1. 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)
  2. 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 time
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Jan 15 06:28:29 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top