Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 1,747 for synced (0.07 sec)

  1. internal/kms/secret-key.go

    func (secretKey) Version(ctx context.Context) (string, error) { return "v1", nil }
    
    // APIs returns an error since the builtin KMS does not provide a list of APIs.
    func (secretKey) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
    	return nil, ErrNotSupported
    }
    
    // Status returns a set of endpoints and their KMS status. Since, the builtin KMS is not
    // external it returns "127.0.0.1: online".
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/Futures.java

      }
    
      /**
       * Schedules {@code callable} on the specified {@code executor}, returning a {@code Future}.
       *
       * @throws RejectedExecutionException if the task cannot be scheduled for execution
       * @since 28.0 (but only since 33.4.0 in the Android flavor)
       */
      @J2ktIncompatible
      @GwtIncompatible // java.util.concurrent.ScheduledExecutorService
      // TODO(cpovirk): Return ListenableScheduledFuture?
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/ImmutableBiMap.java

       * reconstructed using public factory methods. This ensures that the implementation types remain
       * as implementation details.
       *
       * <p>Since the bimap is immutable, ImmutableBiMap doesn't require special logic for keeping the
       * bimap and its inverse in sync during serialization, the way AbstractBiMap does.
       */
      @J2ktIncompatible // serialization
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 22.6K bytes
    - Viewed (0)
  4. cmd/os-instrumented.go

    	operations [osMetricLast]uint64
    	latency    [osMetricLast]lockedLastMinuteLatency
    }
    
    // time an os action.
    func (o *osMetrics) time(s osMetric) func() {
    	startTime := time.Now()
    	return func() {
    		duration := time.Since(startTime)
    
    		atomic.AddUint64(&o.operations[s], 1)
    		o.latency[s].add(duration)
    	}
    }
    
    // incTime will increment time on metric s with a specific duration.
    func (o *osMetrics) incTime(s osMetric, d time.Duration) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 15 01:09:38 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  5. internal/dsync/drwmutex.go

    		defer done()
    		for !releaseAll(ctx, dm.clnt, tolerance, owner, &locks, isReadLock, restClnts, dm.Names...) {
    			time.Sleep(time.Duration(dm.rng.Float64() * float64(dm.lockRetryMinInterval)))
    			if time.Since(started) > dm.clnt.Timeouts.UnlockCall {
    				return
    			}
    		}
    	}()
    }
    
    // RUnlock releases a read lock held on dm.
    //
    // It is a run-time error if dm is not locked on entry to RUnlock.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  6. internal/config/identity/plugin/config.go

    		}
    	}
    
    	// Round the request time *down* to whole minute.
    	reqTimeMinute := reqStartTime.Truncate(time.Minute)
    	if reqTimeMinute.After(h.currentMinute.statsTime) {
    		// Drop the last full minute now, since we got a request for a time we
    		// are not yet tracking.
    		h.updateLastFullMinute(reqTimeMinute)
    	}
    	var entry *serviceRTTMinuteStats
    	switch {
    	case reqTimeMinute.Equal(h.currentMinute.statsTime):
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. cmd/metrics-resource.go

    // It also maintains the count of number of times this metric
    // was collected since the server started, and the sum,
    // average and max values across the same.
    type ResourceMetric struct {
    	Name   MetricName
    	Labels map[string]string
    
    	// value captured in current cycle
    	Current float64
    
    	// Used when system provides cumulative (since uptime) values
    	// helps in calculating the current value by comparing the new
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/FluentFuture.java

       * ({@code this}) will be cancelled and interrupted.
       *
       * @param timeout when to time out the future
       * @param scheduledExecutor The executor service to enforce the timeout.
       * @since 28.0 (but only since 33.4.0 in the Android flavor)
       */
      @J2ktIncompatible
      @GwtIncompatible // ScheduledExecutorService
      public final FluentFuture<V> withTimeout(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  9. cmd/tier-last-day-stats.go

    func (l *lastDayTierStats) forwardTo(t time.Time) {
    	if t.IsZero() {
    		t = time.Now()
    	}
    
    	since := t.Sub(l.UpdatedAt).Hours()
    	// within the hour since l.UpdatedAt
    	if since < 1 {
    		return
    	}
    
    	idx, lastIdx := t.Hour(), l.UpdatedAt.Hour()
    
    	l.UpdatedAt = t // update to the latest time index
    
    	if since >= 24 {
    		l.Bins = [24]tierStats{}
    		return
    	}
    
    	for lastIdx != idx {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.6.md

        - [Node Binaries](#node-binaries)
      - [Changelog since v1.6.12](#changelog-since-v1612)
        - [Other notable changes](#other-notable-changes)
    - [v1.6.12](#v1612)
      - [Downloads for v1.6.12](#downloads-for-v1612)
        - [Client Binaries](#client-binaries-1)
        - [Server Binaries](#server-binaries-1)
        - [Node Binaries](#node-binaries-1)
      - [Changelog since v1.6.11](#changelog-since-v1611)
        - [Other notable changes](#other-notable-changes-1)
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 304K bytes
    - Viewed (0)
Back to top