Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 84 for atomsvc (0.06 sec)

  1. cmd/xl-storage-disk-id-check.go

    	diskHealthOK int32 = iota
    	diskHealthFaulty
    )
    
    type diskHealthTracker struct {
    	// atomic time of last success
    	lastSuccess int64
    
    	// atomic time of last time a token was grabbed.
    	lastStarted int64
    
    	// Atomic status of disk.
    	status atomic.Int32
    
    	// Atomic number indicates if a disk is hung
    	waiting atomic.Int32
    }
    
    // newDiskHealthTracker creates a new disk health tracker.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    	src     lcEventSrc
    }
    
    // expiryStats records metrics related to ILM expiry activities
    type expiryStats struct {
    	missedExpiryTasks      atomic.Int64
    	missedFreeVersTasks    atomic.Int64
    	missedTierJournalTasks atomic.Int64
    	workers                atomic.Int32
    }
    
    // MissedTasks returns the number of ILM expiry tasks that were missed since
    // there were no available workers.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

    import java.util.concurrent.CyclicBarrier;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /** Test case for {@link TrustedListenableFutureTask}. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java

    @ElementTypesAreNonnullByDefault
    public final class ConcurrentHashMultiset<E> extends AbstractMultiset<E> implements Serializable {
    
      /*
       * The ConcurrentHashMultiset's atomic operations are implemented primarily in terms of
       * AtomicInteger's atomic operations, with some help from ConcurrentMap's atomic operations on
       * creation and removal (including automatic removal of zeroes). If the modification of an
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  5. cmd/bucket-replication.go

    		atomic.AddUint64(&p.stats.mrfStats.TotalDroppedCount, 1)
    		atomic.AddUint64(&p.stats.mrfStats.TotalDroppedBytes, uint64(entry.sz))
    		return
    	}
    
    	select {
    	case <-GlobalContext.Done():
    		return
    	case <-p.mrfStopCh:
    		return
    	default:
    		select {
    		case p.mrfSaveCh <- entry:
    		default:
    			atomic.AddUint64(&p.stats.mrfStats.TotalDroppedCount, 1)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  6. android/guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java

    import java.util.concurrent.SynchronousQueue;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicLong;
    import java.util.concurrent.atomic.AtomicReference;
    import java.util.regex.MatchResult;
    import java.util.regex.Pattern;
    import junit.framework.TestCase;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionException;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    
    /**
     * Tests {@link SequentialExecutor}.
     *
     * @author JJ Furman
     */
    public class SequentialExecutorTest extends TestCase {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/cache/CacheLoaderTest.java

    import com.google.common.util.concurrent.ListenableFuture;
    import java.util.Deque;
    import java.util.Map;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    
    /**
     * Unit tests for {@link CacheLoader}.
     *
     * @author Charles Fry
     */
    public class CacheLoaderTest extends TestCase {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/testing/FakeTicker.java

    import com.google.common.base.Ticker;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import java.time.Duration;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicLong;
    
    /**
     * A Ticker whose value can be advanced programmatically in test.
     *
     * <p>The ticker can be configured so that the time is incremented whenever {@link #read} is called:
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionException;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    
    /**
     * Tests {@link SequentialExecutor}.
     *
     * @author JJ Furman
     */
    public class SequentialExecutorTest extends TestCase {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
Back to top