Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for writeLocks (0.09 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. internal/dsync/dsync-server_test.go

    		subrouter.Methods(http.MethodPost).Path("/v1/force-unlock").HandlerFunc(lockServer.ForceUnlockHandler)
    
    		nodes[i] = httptest.NewServer(router)
    	}
    }
    
    const WriteLock = -1
    
    type lockServer struct {
    	mutex sync.Mutex
    	// Map of locks, with negative value indicating (exclusive) write lock
    	// and positive values indicating number of read locks
    	lockMap map[string]int64
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 23 16:46:37 UTC 2023
    - 8.3K bytes
    - Viewed (0)
  6. cmd/metrics-v3-cache.go

    		WriteSectors: currentStats.WriteSectors - initialStats.WriteSectors,
    		ReadTicks:    currentStats.ReadTicks - initialStats.ReadTicks,
    		WriteTicks:   currentStats.WriteTicks - initialStats.WriteTicks,
    		TotalTicks:   currentStats.TotalTicks - initialStats.TotalTicks,
    	}
    }
    
    func getDriveIOStatMetrics(ioStats madmin.DiskIOStats, duration time.Duration) (m driveIOStatMetrics) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

          this.writeLock = new CycleDetectingReentrantWriteLock(this);
          this.lockGraphNode = Preconditions.checkNotNull(lockGraphNode);
        }
    
        ///// Overridden ReentrantReadWriteLock methods. /////
    
        @Override
        public ReadLock readLock() {
          return readLock;
        }
    
        @Override
        public WriteLock writeLock() {
          return writeLock;
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 35.9K bytes
    - Viewed (0)
  10. 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)
Back to top