Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 391 - 400 of 409 for Sleep (0.03 seconds)

  1. CHANGELOG/CHANGELOG-1.29.md

      is removed in `v1.29`. Migrated `kube-scheduler` configuration files to `kubescheduler.config.k8s.io/v1`.' ([#119994](https://github.com/kubernetes/kubernetes/pull/119994), [@SataQiu](https://github.com/SataQiu))
    - A new sleep action for the `PreStop` lifecycle hook was added, allowing containers to pause for a specified duration before termination. ([#119026](https://github.com/kubernetes/kubernetes/pull/119026), [@AxeZhan](https://github.com/AxeZhan))
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Wed Mar 12 00:36:01 GMT 2025
    - 429.6K bytes
    - Click Count (1)
  2. CHANGELOG/CHANGELOG-1.32.md

    - Allows PreStop lifecycle handler's sleep action to have a zero value ([#127094](https://github.com/kubernetes/kubernetes/pull/127094), [@sreeram-venkitesh](https://github.com/sreeram-venkitesh)) [SIG Apps, Node and Testing]
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Feb 26 23:58:21 GMT 2026
    - 470.5K bytes
    - Click Count (0)
  3. cmd/notification.go

    					peersLogOnceIf(ctx, err, addr.String())
    				}
    
    				// Wait for a minimum of 100ms and dynamically increase this based on number of attempts.
    				if i < retryCount-1 {
    					time.Sleep(100*time.Millisecond + time.Duration(r.Float64()*float64(time.Second)))
    					continue
    				}
    			}
    			break
    		}
    	}()
    }
    
    // DeletePolicy - deletes policy across all peers.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
  4. cmd/peer-rest-server.go

    		if err != nil {
    			logger.LogIf(GlobalContext, "signalservice", err)
    			execAt = time.Now().Add(restartUpdateDelay)
    		}
    		if d := time.Until(execAt); d > 0 {
    			time.Sleep(d)
    		}
    	}
    	signal := serviceSignal(si)
    	switch signal {
    	case serviceRestart, serviceStop:
    		dryRun := vars.Get("dry-run") == "true" // This is only supported for `restart/stop`
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  5. 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)
    		}
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 45.7K bytes
    - Click Count (0)
  6. CHANGELOG/CHANGELOG-1.16.md

    - Fixes a bug that when there is a "connection refused" error, the reflector's ListAndWatch func will return directly but what expected is that sleep 1 second and rewatch since the specified resourceVersion.
      ([#81634](https://github.com/kubernetes/kubernetes/pull/81634), [@likakuli](https://github.com/likakuli))
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Wed Oct 23 20:13:20 GMT 2024
    - 345.2K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

                } else if (logger.isDebugEnabled()) {
                    logger.debug("[{}] Failed to access to Fesen ({})", i, SystemUtil.getSearchEngineHttpAddress(), cause);
                }
                ThreadUtil.sleep(1000L);
            }
            final String message =
                    "Fesen (" + SystemUtil.getSearchEngineHttpAddress() + ") is not available. Check the state of your Fesen cluster ("
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 14:36:23 GMT 2026
    - 138.6K bytes
    - Click Count (1)
  8. src/test/java/org/codelibs/fess/crawler/transformer/FessXpathTransformerTest.java

            System.gc();
            for (int i = 0; i < 300; i++) {
                if (MemoryUtil.getUsedMemory() < current + margin) {
                    break;
                }
                System.gc();
                Thread.sleep(100L);
            }
            final long usedMemory = MemoryUtil.getUsedMemory();
            assertTrue(usedMemory + " < " + current + " + " + margin + ", " + MemoryUtil.getMemoryUsageLog(), usedMemory < current + margin);
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 62.9K bytes
    - Click Count (0)
  9. cmd/test-utils_test.go

    	t := time.Now()
    	for _, pool := range pools.serverPools {
    		for _, sets := range pool.erasureDisks {
    			for _, s := range sets {
    				if !s.IsLocal() {
    					for !s.IsOnline() {
    						time.Sleep(100 * time.Millisecond)
    						if time.Since(t) > 10*time.Second {
    							return nil, nil, errors.New("timeout waiting for disk to come online")
    						}
    					}
    				}
    			}
    		}
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        assertThat(connection.isHealthy(System.nanoTime())).isTrue()
    
        // But if the ping doesn't arrive, the connection goes unhealthy.
        Thread.sleep(TimeUnit.NANOSECONDS.toMillis(Http2Connection.DEGRADED_PONG_TIMEOUT_NS.toLong()))
        assertThat(connection.isHealthy(System.nanoTime())).isFalse()
    
        // When a pong does arrive, the connection becomes healthy again.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 75.5K bytes
    - Click Count (0)
Back to Top