Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 61 for Timer (0.05 sec)

  1. internal/ioutil/ioutil.go

    	timeout time.Duration
    	err     error
    }
    
    // NewDeadlineWriter wraps a writer to make it respect given deadline
    // value per Write(). If there is a blocking write, the returned Writer
    // will return whenever the timer hits (the return values are n=0
    // and err=context.DeadlineExceeded.)
    func NewDeadlineWriter(w io.WriteCloser, timeout time.Duration) io.WriteCloser {
    	return &DeadlineWriter{WriteCloser: w, timeout: timeout}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. cmd/erasure.go

    				w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    				return w.Run(func() error {
    					wait := deleteCleanupSleeper.Timer(ctx)
    					removeAll(pathJoin(drivePath, minioMetaTmpDeletedBucket, ddir))
    					wait()
    					return nil
    				})
    			})
    		}(disk)
    	}
    	wg.Wait()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  3. src/archive/zip/writer_test.go

    			w, _ := zw.CreateHeader(&FileHeader{
    				Name:   "foo",
    				Method: Deflate,
    			})
    			w.Write(bigBuf)
    		}
    		zw.Close()
    	}
    
    	b.ReportAllocs()
    	// Run once and then reset the timer.
    	// This effectively discards the very large initial flate setup cost,
    	// as well as the initialization of bigBuf.
    	runOnce(&bytes.Buffer{})
    	b.ResetTimer()
    
    	b.RunParallel(func(pb *testing.PB) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  4. cmd/bucket-metadata-sys.go

    			diskBuckets := set.CreateStringSet()
    			for _, bucket := range buckets {
    				diskBuckets.Add(bucket.Name)
    			}
    			sys.RemoveStaleBuckets(diskBuckets)
    
    			for i := range buckets {
    				wait := sleeper.Timer(ctx)
    
    				bucket := buckets[i].Name
    				updated := false
    
    				meta, err := loadBucketMetadata(ctx, sys.objAPI, bucket)
    				if err != nil {
    					internalLogIf(ctx, err, logger.WarningKind)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    	go z.cleanupStaleMPCache(ctx)
    
    	return z, nil
    }
    
    func (z *erasureServerPools) cleanupStaleMPCache(ctx context.Context) {
    	timer := time.NewTimer(globalAPIConfig.getStaleUploadsCleanupInterval())
    	defer timer.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-timer.C:
    			z.mpCache.Range(func(id string, info MultipartInfo) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

        RateLimiter rateLimiter = new SmoothWarmingUp(stopwatch, warmupPeriod, unit, coldFactor);
        rateLimiter.setRate(permitsPerSecond);
        return rateLimiter;
      }
    
      /**
       * The underlying timer; used both to measure elapsed time and sleep as necessary. A separate
       * object to facilitate testing.
       */
      private final SleepingStopwatch stopwatch;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  7. cmd/admin-handlers.go

    		// Start profiling locally as well.
    		prof, err := startProfiler(profiler)
    		if err == nil {
    			globalProfiler[profiler] = prof
    		}
    	}
    	globalProfilerMu.Unlock()
    
    	timer := time.NewTimer(duration)
    	defer timer.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			// Stop remote profiles
    			go globalNotificationSys.DownloadProfilingData(GlobalContext, io.Discard)
    
    			// Stop local
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/RateLimiter.java

        RateLimiter rateLimiter = new SmoothWarmingUp(stopwatch, warmupPeriod, unit, coldFactor);
        rateLimiter.setRate(permitsPerSecond);
        return rateLimiter;
      }
    
      /**
       * The underlying timer; used both to measure elapsed time and sleep as necessary. A separate
       * object to facilitate testing.
       */
      private final SleepingStopwatch stopwatch;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  9. cmd/admin-heal-ops.go

    // sequence automatically resumes. The return value indicates if the
    // operation succeeded.
    func (h *healSequence) pushHealResultItem(r madmin.HealResultItem) error {
    	// start a timer to keep an upper time limit to find an empty
    	// slot to add the given heal result - if no slot is found it
    	// means that the server is holding the maximum amount of
    	// heal-results in memory and the client has not consumed it
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/ldap/LdapManager.java

    import javax.naming.directory.SearchResult;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.timer.TimeoutManager;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.entity.FessUser;
    import org.codelibs.fess.es.user.exentity.Group;
    import org.codelibs.fess.es.user.exentity.Role;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 65.9K bytes
    - Viewed (0)
Back to top