Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 301 - 310 of 360 for Sleeps (0.22 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/bucket-replication.go

    			<-ctx.Done()
    			return
    		}
    		duration := max(time.Duration(r.Float64()*float64(time.Minute)),
    			// Make sure to sleep at least a second to avoid high CPU ticks.
    			time.Second)
    		time.Sleep(duration)
    	}
    }
    
    // Loads bucket replication resync statuses into memory.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        // Service b startup takes at least 353 millis, but starting the timer is delayed by at least
        // 150 milliseconds. so in a perfect world the timing would be 353-150=203ms, but since either
        // of our sleep calls can be arbitrarily delayed we should just assert that there is a time
        // recorded.
        assertThat(startupTimes.get(b)).isNotNull();
      }
    
      public void testServiceStartStop() {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 17:49:12 GMT 2025
    - 25.5K bytes
    - Click Count (0)
  3. cmd/erasure-server-pool-decom.go

    						}
    						return
    					}
    					if configRetriableErrors(err) {
    						decomLogIf(ctx, fmt.Errorf("Unable to resume decommission of pools %v: %w: retrying..", pools, err))
    						time.Sleep(time.Second + time.Duration(r.Float64()*float64(5*time.Second)))
    						continue
    					}
    					decomLogIf(ctx, fmt.Errorf("Unable to resume decommission of pool %v: %w", pools, err))
    					return
    				}
    			}
    		}()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

                    }
    
                    final long minSleep = retryInterval + retryCount * 1000L;
                    final long maxSleep = retryInterval + retryCount * 2000L;
                    ThreadUtil.sleep(RandomUtils.nextLong(minSleep, maxSleep));
                    retryCount++;
                }
            }
        }
    
        /**
         * Destroys the client and closes connections.
         */
        @PreDestroy
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sun Nov 23 02:01:26 GMT 2025
    - 26.2K bytes
    - Click Count (0)
  5. cmd/iam.go

    				logger.Info("Waiting for AuthN to be initialized.. (retrying in %s)", retryInterval)
    			}
    			if !authZInit {
    				logger.Info("Waiting for AuthZ to be initialized.. (retrying in %s)", retryInterval)
    			}
    			time.Sleep(retryInterval)
    			continue
    		}
    
    		break
    	}
    
    	// Initialize IAM store
    	sys.Lock()
    
    	sys.initStore(objAPI, etcdClient)
    
    	// Initialize RoleARNs
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 76.5K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

                        } else {
                            final long interval = fessConfig.getThumbnailGeneratorIntervalAsInteger().longValue();
                            if (interval > 0) {
                                ThreadUtil.sleep(interval);
                            }
                        }
                    } else {
                        logger.warn("Thumbnail generator is not available: name={}", generatorName);
                    }
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 27K bytes
    - Click Count (0)
  7. docs/en/docs/help-fastapi.md

    Those two tasks are what **consume time the most**. That's the main work of maintaining FastAPI.
    
    If you can help me with that, **you are helping me maintain FastAPI** and making sure it keeps **advancing faster and better**. 🚀
    
    ## Join the chat { #join-the-chat }
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 10:49:48 GMT 2025
    - 14K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java

                } else if (behavior == 1) { // return null
                  computeNullCount.incrementAndGet();
                  return null;
                } else if (behavior == 2) { // slight delay before returning
                  Thread.sleep(5);
                  computeCount.incrementAndGet();
                  return key;
                } else {
                  computeCount.incrementAndGet();
                  return key;
                }
              }
            };
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 30 22:03:28 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  9. guava/src/com/google/common/collect/CompactHashSet.java

       * elements.length) are all {@code null}.
       */
      @VisibleForTesting transient @Nullable Object @Nullable [] elements;
    
      /**
       * Keeps track of metadata like the number of hash table bits and modifications of this data
       * structure (to make it possible to throw ConcurrentModificationException in the iterator). Note
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 24.7K bytes
    - Click Count (0)
  10. cmd/admin-heal-ops.go

    		}
    
    		hsp = madmin.HealStopSuccess{
    			ClientToken:   clientToken,
    			ClientAddress: he.clientAddress,
    			StartTime:     he.startTime,
    		}
    
    		he.stop()
    		for !he.hasEnded() {
    			time.Sleep(1 * time.Second)
    		}
    		ahs.Lock()
    		defer ahs.Unlock()
    		// Heal sequence explicitly stopped, remove it.
    		delete(ahs.healSeqMap, path)
    	}
    
    	b, err := json.Marshal(&hsp)
    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)
Back to Top