Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 682 for Flock (0.07 sec)

  1. cmd/test-utils_test.go

    }
    
    // sets globalObjectAPI to `nil`.
    func resetGlobalObjectAPI() {
    	globalObjLayerMutex.Lock()
    	globalObjectAPI = nil
    	globalObjLayerMutex.Unlock()
    }
    
    // reset the value of the Global server config.
    // set it to `nil`.
    func resetGlobalConfig() {
    	// hold the mutex lock before a new config is assigned.
    	globalServerConfigMu.Lock()
    	// Save the loaded config globally.
    	globalServerConfig = nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  2. android/guava-tests/benchmark/com/google/common/util/concurrent/CycleDetectingLockFactoryBenchmark.java

      }
    
      @Benchmark
      void unorderedCycleDetectingLocks(int reps) {
        lockAndUnlock(factory.newReentrantLock("foo"), reps);
      }
    
      private static void lockAndUnlock(Lock lock, int reps) {
        for (int i = 0; i < reps; i++) {
          lock.lock();
          lock.unlock();
        }
      }
    
      @Benchmark
      void orderedPlainLocks(int reps) {
        lockAndUnlockNested(plainLocks, reps);
      }
    
      @Benchmark
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 2.4K bytes
    - Viewed (0)
  3. docs/bucket/retention/README.md

    ```sh
    aws s3api put-object --bucket testbucket --key lockme --object-lock-mode GOVERNANCE --object-lock-retain-until-date "2019-11-20"  --body /etc/issue
    ```
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  4. internal/bucket/bandwidth/measurement.go

    func (m *bucketMeasurement) updateExponentialMovingAverage(endTime time.Time) {
    	// Calculate aggregate avg bandwidth and exp window avg
    	m.lock.Lock()
    	defer func() {
    		m.startTime = endTime
    		m.lock.Unlock()
    	}()
    
    	if m.startTime.IsZero() {
    		return
    	}
    
    	if endTime.Before(m.startTime) {
    		return
    	}
    
    	duration := endTime.Sub(m.startTime)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 03 20:41:51 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            }
          };
    
      private static final Supplier<Lock> LOCK_SUPPLER =
          new Supplier<Lock>() {
            @Override
            public Lock get() {
              return new ReentrantLock();
            }
          };
    
      private static final Supplier<Lock> FAIR_LOCK_SUPPLER =
          new Supplier<Lock>() {
            @Override
            public Lock get() {
              return new ReentrantLock(true);
            }
          };
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            }
          };
    
      private static final Supplier<Lock> LOCK_SUPPLER =
          new Supplier<Lock>() {
            @Override
            public Lock get() {
              return new ReentrantLock();
            }
          };
    
      private static final Supplier<Lock> FAIR_LOCK_SUPPLER =
          new Supplier<Lock>() {
            @Override
            public Lock get() {
              return new ReentrantLock(true);
            }
          };
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerWriter.kt

      fun write(
        name: String,
        tagClass: Int,
        tag: Long,
        block: (BufferedSink) -> Unit,
      ) {
        val constructedBit: Int
        val content = Buffer()
    
        stack.add(content)
        constructed = false // The enclosed object written in block() is not constructed.
        path += name
        try {
          block(content)
          constructedBit = if (constructed) 0b0010_0000 else 0
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  8. android/guava-tests/benchmark/com/google/common/util/concurrent/StripedBenchmark.java

    import java.util.Random;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    
    /** A benchmark comparing the various striped implementations. */
    @VmOptions({"-Xms12g", "-Xmx12g", "-d64"})
    public class StripedBenchmark {
      private static final Supplier<Lock> LOCK_SUPPLIER =
          new Supplier<Lock>() {
            @Override
            public Lock get() {
              return new ReentrantLock();
            }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4K bytes
    - Viewed (0)
  9. guava-tests/benchmark/com/google/common/util/concurrent/StripedBenchmark.java

    import java.util.Random;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    
    /** A benchmark comparing the various striped implementations. */
    @VmOptions({"-Xms12g", "-Xmx12g", "-d64"})
    public class StripedBenchmark {
      private static final Supplier<Lock> LOCK_SUPPLIER =
          new Supplier<Lock>() {
            @Override
            public Lock get() {
              return new ReentrantLock();
            }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/Striped.java

         * error-prone code like:
         *
         * Striped<Lock> stripedLock = Striped.lazyWeakXXX(...)'
         * Iterable<Lock> locks = stripedLock.bulkGet(keys);
         * for (Lock lock : locks) {
         *   lock.lock();
         * }
         * operation();
         * for (Lock lock : locks) {
         *   lock.unlock();
         * }
         *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 20.6K bytes
    - Viewed (0)
Back to top