Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 192 for rlocked (0.05 seconds)

  1. cmd/admin-heal-ops.go

    func (h *healSequence) getScannedItemsCount() int64 {
    	var count int64
    	h.mutex.RLock()
    	defer h.mutex.RUnlock()
    
    	for _, v := range h.scannedItemsMap {
    		count += v
    	}
    	return count
    }
    
    // getScannedItemsMap - returns map of all scanned items against type
    func (h *healSequence) getScannedItemsMap() map[madmin.HealItemType]int64 {
    	h.mutex.RLock()
    	defer h.mutex.RUnlock()
    
    	// Make a copy before returning the value
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  2. guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

          List<LockGraphNode> acquiredLockList = requireNonNull(acquiredLocks.get());
          LockGraphNode node = lock.getLockGraphNode();
          // Iterate in reverse because locks are usually locked/unlocked in a
          // LIFO order.
          for (int i = acquiredLockList.size() - 1; i >= 0; i--) {
            if (acquiredLockList.get(i) == node) {
              acquiredLockList.remove(i);
              break;
            }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 11 17:06:34 GMT 2025
    - 35.9K bytes
    - Click Count (0)
  3. cmd/erasure-sets.go

    		Pool: set.poolIndex + 1,
    		Set:  set.setIndex + 1,
    	}
    
    	logger.GetReqInfo(ctx).AppendTags(api, op.String())
    }
    
    // NewNSLock - initialize a new namespace RWLocker instance.
    func (s *erasureSets) NewNSLock(bucket string, objects ...string) RWLocker {
    	return s.sets[0].NewNSLock(bucket, objects...)
    }
    
    // SetDriveCount returns the current drives per set.
    func (s *erasureSets) SetDriveCount() int {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  4. api/maven-api-settings/src/main/mdo/settings.mdo

                @since Maven 3.
              </description>
            </field>
            <field>
              <name>blocked</name>
              <version>1.2.0+</version>
              <type>boolean</type>
              <defaultValue>false</defaultValue>
              <description>
                <![CDATA[
                Whether this mirror should be blocked from any download request but fail the download process, explaining why.
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sun May 18 09:15:56 GMT 2025
    - 33.8K bytes
    - Click Count (0)
  5. cmd/metacache-manager.go

    		}
    
    		t := time.NewTicker(time.Minute)
    		defer t.Stop()
    
    		var exit bool
    		for !exit {
    			select {
    			case <-t.C:
    			case <-GlobalContext.Done():
    				exit = true
    			}
    			m.mu.RLock()
    			for _, v := range m.buckets {
    				if !exit {
    					v.cleanup()
    				}
    			}
    			m.mu.RUnlock()
    			m.mu.Lock()
    			for k, v := range m.trash {
    				if time.Since(v.lastUpdate) > metacacheMaxRunningAge {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 5.2K bytes
    - Click Count (0)
  6. cmd/bootstrap-peer-server.go

    				} else {
    					onlineServers++
    				}
    				mu.Unlock()
    			}(clnt)
    		}
    		wg.Wait()
    
    		select {
    		case <-ctx.Done():
    			return ctx.Err()
    		default:
    			// Sleep and stagger to avoid blocked CPU and thundering
    			// herd upon start up sequence.
    			time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond))))
    			retries++
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Oct 01 22:13:18 GMT 2024
    - 8.4K bytes
    - Click Count (0)
  7. compat/maven-model-builder/src/main/java/org/apache/maven/model/root/RootLocator.java

    import org.apache.maven.api.annotations.Nonnull;
    import org.apache.maven.api.annotations.Nullable;
    
    /**
     * Interface used to locate the root directory for a given project.
     *
     * The root locator is usually looked up from the plexus container.
     * One notable exception is the computation of the early {@code session.rootDirectory}
     * property which happens very early.  The implementation used in this case
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 2.5K bytes
    - Click Count (0)
  8. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/BuilderCommon.java

                    .map(Plugin::getArtifactId) // managed by us, groupId is always o.a.m.plugins
                    .toList();
    
            if (!unversionedPlugins.isEmpty()) {
                logger.warn("Version not locked for default bindings plugins " + unversionedPlugins
                        + ", you should define versions in pluginManagement section of your " + "pom.xml or parent");
            }
    
            return executionPlan;
        }
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jan 10 08:42:00 GMT 2025
    - 10.3K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/TestThread.java

        sendRequest(methodName, arguments);
        assertThat(getResponse(methodName).getThrowable()).isInstanceOf(expected);
      }
    
      /**
       * Causes this thread to call the named method, and asserts that this thread becomes blocked on
       * the lock-like object. The lock-like object must have a method equivalent to {@link
       * java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}.
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 21:00:51 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  10. cmd/erasure.go

    	// some may be local and some remote.
    	getEndpointStrings func() []string
    
    	// Locker mutex map.
    	nsMutex *nsLockMap
    }
    
    // NewNSLock - initialize a new namespace RWLocker instance.
    func (er erasureObjects) NewNSLock(bucket string, objects ...string) RWLocker {
    	return er.nsMutex.NewNSLock(er.getLockers, bucket, objects...)
    }
    
    // Shutdown function for object storage interface.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.1K bytes
    - Click Count (0)
Back to Top