Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 261 for sheep (0.03 sec)

  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.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  2. cmd/object-handlers.go

    		objInfo.ETag = origETag
    		enqueueTransitionImmediate(objInfo, lcEventSrc_s3CopyObject)
    		// Remove the transitioned object whose object version is being overwritten.
    		os.Sweep()
    	}
    }
    
    // PutObjectHandler - PUT Object
    // ----------
    // This implementation of the PUT operation adds an object to a bucket.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  3. 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)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  4. cmd/utils.go

    		startedAt := time.Now()
    		prof.stopFn = func() ([]byte, error) {
    			if elapsed := time.Since(startedAt); elapsed < 100*time.Millisecond {
    				// Light hack around https://github.com/felixge/fgprof/pull/34
    				time.Sleep(100*time.Millisecond - elapsed)
    			}
    			err := stop()
    			if err != nil {
    				return nil, err
    			}
    			err = f.Close()
    			if err != nil {
    				return nil, err
    			}
    			defer RemoveAll(dirPath)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33K bytes
    - Viewed (0)
  5. guava/src/com/google/common/net/MediaType.java

              APPLICATION_TYPE, "vnd.openxmlformats-officedocument.presentationml.presentation");
      public static final MediaType OOXML_SHEET =
          createConstant(APPLICATION_TYPE, "vnd.openxmlformats-officedocument.spreadsheetml.sheet");
      public static final MediaType OPENDOCUMENT_GRAPHICS =
          createConstant(APPLICATION_TYPE, "vnd.oasis.opendocument.graphics");
      public static final MediaType OPENDOCUMENT_PRESENTATION =
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 48K bytes
    - Viewed (0)
  6. cmd/xl-storage-disk-id-check.go

    				p.health.waiting.Add(1)
    				go p.monitorDiskStatus(spent, fn)
    			}
    		}
    
    		// Offset checks a bit.
    		time.Sleep(time.Duration(rng.Int63n(int64(1 * time.Second))))
    
    		dctx, dcancel := context.WithCancel(ctx)
    		started := time.Now()
    		go func() {
    			timeout := time.NewTimer(globalDriveConfig.GetMaxTimeout())
    			select {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  7. cmd/object-multipart-handlers.go

    	if !globalTierConfigMgr.Empty() {
    		// Schedule object for immediate transition if eligible.
    		enqueueTransitionImmediate(objInfo, lcEventSrc_s3CompleteMultipartUpload)
    		os.Sweep()
    	}
    }
    
    // AbortMultipartUploadHandler - Abort multipart upload
    func (api objectAPIHandlers) AbortMultipartUploadHandler(w http.ResponseWriter, r *http.Request) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  8. cmd/data-usage-cache.go

    		if !retry {
    			break
    		}
    		retry, err = load(name+".bkp", 30*time.Second)
    		if err == nil && !retry {
    			// Only return when we have valid data from the backup
    			break
    		}
    		retries++
    		time.Sleep(time.Duration(rand.Int63n(int64(time.Second))))
    	}
    
    	if retries == 5 {
    		scannerLogOnceIf(ctx, fmt.Errorf("maximum retry reached to load the data usage cache `%s`", name), "retry-loading-data-usage-cache")
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  9. cmd/storage-rest-server.go

    				return true
    			}
    
    			if createStorage(endpoint) {
    				continue
    			}
    
    			// Start async goroutine to create storage.
    			go func(endpoint Endpoint) {
    				for {
    					time.Sleep(3 * time.Second)
    					if createStorage(endpoint) {
    						return
    					}
    				}
    			}(endpoint)
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/net/MediaType.java

              APPLICATION_TYPE, "vnd.openxmlformats-officedocument.presentationml.presentation");
      public static final MediaType OOXML_SHEET =
          createConstant(APPLICATION_TYPE, "vnd.openxmlformats-officedocument.spreadsheetml.sheet");
      public static final MediaType OPENDOCUMENT_GRAPHICS =
          createConstant(APPLICATION_TYPE, "vnd.oasis.opendocument.graphics");
      public static final MediaType OPENDOCUMENT_PRESENTATION =
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 48K bytes
    - Viewed (0)
Back to top