Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for Widmer (0.18 sec)

  1. 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()
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  2. cmd/data-scanner.go

    		}
    		if maxWait > 0 && wantSleep > maxWait {
    			wantSleep = maxWait
    		}
    		timer := time.NewTimer(wantSleep)
    		select {
    		case <-ctx.Done():
    			if !timer.Stop() {
    				<-timer.C
    				if d.isScanner {
    					globalScannerMetrics.incTime(scannerMetricYield, wantSleep)
    				}
    			}
    			return
    		case <-timer.C:
    			if d.isScanner {
    				globalScannerMetrics.incTime(scannerMetricYield, wantSleep)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 47.4K bytes
    - Viewed (0)
  3. cmd/erasure-sets.go

    			wg.Wait()
    
    			// Reset for the next interval
    			timer.Reset(globalAPIConfig.getDeleteCleanupInterval())
    		}
    	}
    }
    
    func (s *erasureSets) cleanupStaleUploads(ctx context.Context) {
    	timer := time.NewTimer(globalAPIConfig.getStaleUploadsCleanupInterval())
    	defer timer.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-timer.C:
    			var wg sync.WaitGroup
    			for _, set := range s.sets {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 37.5K bytes
    - Viewed (5)
  4. docs/de/docs/advanced/generate-clients.md

    ### Vorab-Modifikation der OpenAPI-Spezifikation für den Client-Generator
    
    Der generierte Code enthält immer noch etwas **verdoppelte Information**.
    
    Wir wissen bereits, dass diese Methode mit den **Items** zusammenhängt, da sich dieses Wort in `ItemsService` befindet (vom Tag übernommen), aber wir haben auch immer noch den Tagnamen im Methodennamen vorangestellt. 😕
    
    Plain Text
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Wed Apr 03 03:42:11 GMT 2024
    - 12K bytes
    - Viewed (0)
  5. internal/kms/kes.go

    		cacheDuration = defaultCacheDuration
    	}
    	timer := time.NewTimer(cacheDuration)
    	defer timer.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-timer.C:
    			c.RefreshKey(ctx, logger)
    
    			// Reset for the next interval
    			timer.Reset(cacheDuration)
    		}
    	}
    }
    
    type kesClient struct {
    	lock         sync.RWMutex
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Apr 16 15:43:39 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  6. doc/godebug.md

    ### Go 1.23
    
    Go 1.23 changed the channels created by package time to be unbuffered
    (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop)
    and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
    The [`asynctimerchan` setting](/pkg/time/#NewTimer) disables this change.
    There are no runtime metrics for this change,
    Plain Text
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Apr 16 17:29:58 GMT 2024
    - 13.5K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-rebalance.go

    		// time.
    		r := rand.New(rand.NewSource(time.Now().UnixNano()))
    		randSleepFor := func() time.Duration {
    			return 5*time.Second + time.Duration(float64(5*time.Second)*r.Float64())
    		}
    
    		timer := time.NewTimer(randSleepFor())
    		defer timer.Stop()
    
    		var (
    			quit     bool
    			traceMsg string
    		)
    
    		for {
    			select {
    			case rebalErr := <-doneCh:
    				quit = true
    				now := time.Now()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  8. cmd/erasure-multipart.go

    			if err != nil {
    				return nil
    			}
    			w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    			return w.Run(func() error {
    				wait := deleteMultipartCleanupSleeper.Timer(ctx)
    				if time.Since(fi.ModTime) > expiry {
    					pathUUID := mustGetUUID()
    					targetPath := pathJoin(drivePath, minioMetaTmpDeletedBucket, pathUUID)
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  9. internal/ioutil/ioutil.go

    		return context.DeadlineExceeded
    	}
    }
    
    // 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}
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 10.3K bytes
    - Viewed (0)
  10. docs/fr/docs/features.md

    Tout le framework **FastAPI** a été conçu avec cela en tête. L'autocomplétion fonctionne partout.
    
    Vous devrez rarement revenir à la documentation.
    
    Voici comment votre éditeur peut vous aider:
    
    * dans <a href="https://code.visualstudio.com/" class="external-link" target="_blank">Visual Studio Code</a>:
    
    ![editor support](https://fastapi.tiangolo.com/img/vscode-completion.png)
    
    Plain Text
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 11.1K bytes
    - Viewed (0)
Back to top