Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 301 - 310 of 507 for selects (0.09 seconds)

  1. cmd/metacache-manager.go

    		objAPI := newObjectLayerFn()
    		for objAPI == nil {
    			time.Sleep(time.Second)
    			objAPI = newObjectLayerFn()
    		}
    
    		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()
    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)
  2. cmd/prepare-storage.go

    		case errors.Is(err, errErasureV3ThisEmpty):
    			// need to wait for this error to be healed, so continue.
    		default:
    			// For all other unhandled errors we exit and fail.
    			return nil, nil, err
    		}
    
    		select {
    		case <-ticker.C:
    		case <-globalOSSignalCh:
    			return nil, nil, fmt.Errorf("Initializing data volumes gracefully stopped")
    		}
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jul 12 20:51:54 GMT 2024
    - 11.1K bytes
    - Click Count (1)
  3. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/goals/ModelVersionUtils.java

     * and simplified API while maintaining the same external interface.
     */
    public final class ModelVersionUtils {
    
        private ModelVersionUtils() {
            // Utility class
        }
    
        /**
         * Detects the model version from a POM document.
         * Uses both the modelVersion element and namespace URI for detection.
         *
         * @param pomDocument the POM document (domtrip Document)
         * @return the detected model version
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Nov 18 18:03:26 GMT 2025
    - 9.5K bytes
    - Click Count (0)
  4. compat/maven-compat/src/test/java/org/apache/maven/artifact/AbstractArtifactComponentTestCase.java

    import org.eclipse.aether.repository.LocalRepository;
    import org.eclipse.aether.util.graph.manager.ClassicDependencyManager;
    import org.eclipse.aether.util.graph.selector.AndDependencySelector;
    import org.eclipse.aether.util.graph.selector.ExclusionDependencySelector;
    import org.eclipse.aether.util.graph.transformer.ChainedDependencyGraphTransformer;
    import org.eclipse.aether.util.graph.transformer.ConfigurableVersionSelector;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 10 09:40:15 GMT 2025
    - 13.8K bytes
    - Click Count (0)
  5. samples/guide/src/main/java/okhttp3/recipes/CustomCipherSuites.java

      public CustomCipherSuites() throws GeneralSecurityException {
        // Configure cipher suites to demonstrate how to customize which cipher suites will be used for
        // an OkHttp request. In order to be selected a cipher suite must be included in both OkHttp's
        // connection spec and in the SSLSocket's enabled cipher suites array. Most applications should
        // not customize the cipher suites list.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Mar 14 21:57:42 GMT 2019
    - 6.5K bytes
    - Click Count (0)
  6. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DebugResolutionListener.java

        public void endProcessChildren(Artifact artifact) {
            indent = indent.substring(2);
        }
    
        @Override
        public void includeArtifact(Artifact artifact) {
            logger.debug(indent + artifact + " (selected for " + artifact.getScope() + ")");
        }
    
        @Override
        public void omitForNearer(Artifact omitted, Artifact kept) {
            String omittedVersion = omitted.getVersion();
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  7. compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/DefaultGraphConflictResolver.java

     *
     */
    @Named
    @Singleton
    @Deprecated
    public class DefaultGraphConflictResolver implements GraphConflictResolver {
        /**
         * artifact, closer to the entry point, is selected
         */
        @Inject
        protected GraphConflictResolutionPolicy policy;
    
        // -------------------------------------------------------------------------------------
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Jul 23 17:27:08 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  8. impl/maven-core/src/main/java/org/apache/maven/exception/DefaultExceptionHandler.java

    - plugin execution error due to something that is not expected to go wrong (the compiler executable missing)
    - asking to use a plugin for which you do not have a version defined - tools to easily select versions
    - goal not found in a plugin (probably could list the ones that are)
    
     */
    
    // PluginNotFoundException, PluginResolutionException, PluginDescriptorParsingException,
    // CycleDetectedInPluginGraphException;
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sat Apr 05 11:52:05 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  9. cmd/site-replication-metrics.go

    	s := SRStats{
    		M:               make(map[string]*SRStatus),
    		movingAvgTicker: time.NewTicker(time.Second * 2),
    	}
    	go s.trackEWMA()
    	return &s
    }
    
    func (sr *SRStats) trackEWMA() {
    	for {
    		select {
    		case <-sr.movingAvgTicker.C:
    			sr.updateMovingAvg()
    		case <-GlobalContext.Done():
    			return
    		}
    	}
    }
    
    func (sr *SRStats) updateMovingAvg() {
    	sr.lock.Lock()
    	defer sr.lock.Unlock()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  10. cmd/metacache.go

    func (m metacache) keepAlive(ctx context.Context, rpc *peerRESTClient) {
    	// we intentionally operate on a copy of m, so we can update without locks.
    	t := time.NewTicker(metacacheMaxClientWait / 10)
    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			// Request is done, stop updating.
    			return
    		case <-t.C:
    			m.lastHandout = time.Now()
    
    			if m2, err := rpc.UpdateMetacacheListing(ctx, m); err == nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jul 12 16:23:16 GMT 2024
    - 6K bytes
    - Click Count (0)
Back to Top