Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for writeLocks (0.15 sec)

  1. internal/dsync/drwmutex.go

    		// Check if minimally a single bool is set in the writeLocks array
    		lockFound := false
    		for _, uid := range dm.writeLocks {
    			if isLocked(uid) {
    				lockFound = true
    				break
    			}
    		}
    		if !lockFound {
    			panic("Trying to Unlock() while no Lock() is active")
    		}
    
    		// Copy write locks to stack array
    		copy(locks, dm.writeLocks)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        // Establish an ordering from writeLockA -> writeLockB.
        writeLockA.lock();
        writeLockB.lock();
        writeLockB.unlock();
        writeLockA.unlock();
    
        // Establish an ordering from writeLockB -> writeLockC.
        writeLockB.lock();
        writeLockC.lock();
        writeLockB.unlock();
    
        // writeLockC -> writeLockA should fail.
        PotentialDeadlockException expected =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        // Establish an ordering from writeLockA -> writeLockB.
        writeLockA.lock();
        writeLockB.lock();
        writeLockB.unlock();
        writeLockA.unlock();
    
        // Establish an ordering from writeLockB -> writeLockC.
        writeLockB.lock();
        writeLockC.lock();
        writeLockB.unlock();
    
        // writeLockC -> writeLockA should fail.
        PotentialDeadlockException expected =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  4. internal/disk/stat_test.go

    				ReadIOs:        1432553,
    				ReadMerges:     420084,
    				ReadSectors:    66247626,
    				ReadTicks:      2398227,
    				WriteIOs:       7077314,
    				WriteMerges:    8720147,
    				WriteSectors:   157049224,
    				WriteTicks:     7469810,
    				CurrentIOs:     0,
    				TotalTicks:     7580552,
    				ReqTicks:       9869354,
    				DiscardIOs:     46037,
    				DiscardMerges:  0,
    				DiscardSectors: 41695120,
    				DiscardTicks:   1315,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

        Lock readLock = striped.get(key).readLock();
        WeakReference<Object> garbage = new WeakReference<>(new Object());
        GcFinalization.awaitClear(garbage);
        Lock writeLock = striped.get(key).writeLock();
        readLock.lock();
        assertFalse(writeLock.tryLock());
        readLock.unlock();
      }
    
      @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts.
      public void testStrongImplementations() {
    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

        Lock readLock = striped.get(key).readLock();
        WeakReference<Object> garbage = new WeakReference<>(new Object());
        GcFinalization.awaitClear(garbage);
        Lock writeLock = striped.get(key).writeLock();
        readLock.lock();
        assertFalse(writeLock.tryLock());
        readLock.unlock();
      }
    
      @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts.
      public void testStrongImplementations() {
    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. cmd/metrics-realtime.go

    				ReadSectors:    st.ReadSectors,
    				ReadTicks:      st.ReadTicks,
    				WriteIOs:       st.WriteIOs,
    				WriteMerges:    st.WriteMerges,
    				WriteSectors:   st.WriteSectors,
    				WriteTicks:     st.WriteTicks,
    				CurrentIOs:     st.CurrentIOs,
    				TotalTicks:     st.TotalTicks,
    				ReqTicks:       st.ReqTicks,
    				DiscardIOs:     st.DiscardIOs,
    				DiscardMerges:  st.DiscardMerges,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  8. .teamcity/src/main/kotlin/promotion/BasePromotionBuildType.kt

                // we only allow 1 promotion job running at the same time to avoid website xml conflicts
                feature {
                    type = "JetBrains.SharedResources"
                    param("locks-param", "WebsiteReleasesXml writeLock")
                }
            }
        }
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Jul 03 00:43:38 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/Striped.java

        }
    
        @Override
        public Lock readLock() {
          return new WeakSafeLock(delegate.readLock(), this);
        }
    
        @Override
        public Lock writeLock() {
          return new WeakSafeLock(delegate.writeLock(), this);
        }
      }
    
      /** Lock object that ensures a strong reference is retained to a specified object. */
      private static final class WeakSafeLock extends ForwardingLock {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  10. cmd/metrics-resource.go

    	}
    	updateResourceMetrics(driveSubsystem, readsAwait, rdAwait, labels, false)
    
    	wrAwait := 0.0
    	if diffStats.WriteIOs > 0 {
    		wrAwait = float64(diffStats.WriteTicks) / float64(diffStats.WriteIOs)
    	}
    	updateResourceMetrics(driveSubsystem, writesAwait, wrAwait, labels, false)
    	updateResourceMetrics(driveSubsystem, percUtil, float64(diffStats.TotalTicks)/(diffInSeconds*10), labels, false)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
Back to top