Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for sleepTime (0.15 sec)

  1. pkg/test/echo/server/forwarder/util.go

    	var responsesMu sync.Mutex
    
    	var throttle *time.Ticker
    	qps := int(cfg.Request.Qps)
    	if qps > 0 {
    		sleepTime := time.Second / time.Duration(qps)
    		fwLog.Debugf("Sleeping %v between requests", sleepTime)
    		throttle = time.NewTicker(sleepTime)
    		defer throttle.Stop()
    	}
    
    	g := e.NewGroup()
    	for index := 0; index < cfg.count; index++ {
    		index := index
    		workFn := func() error {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Oct 08 09:39:20 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  2. testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy

            long sleepTime = toMillis(pollIntervalInSeconds)
            while(true) {
                try {
                    assertion()
                    return
                } catch (Throwable t) {
                    if (monotonicClockMillis() > expiry) {
                        throw t
                    }
                    sleepTime = Math.min(250, (long) (sleepTime * 1.2))
                    Thread.sleep(sleepTime)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 22.9K bytes
    - Viewed (0)
  3. pkg/controller/tainteviction/taint_eviction_test.go

    					}
    
    					sleepTime := item.expectedDeleteTimes[i].timestamp - time.Since(startedAt) + increment
    					if sleepTime < 0 {
    						sleepTime = 0
    					}
    					t.Logf("Sleeping for %v", sleepTime)
    					time.Sleep(sleepTime)
    				}
    
    				for delay, podName := range item.expectedDeleteTimes[i].names {
    					deleted := false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 31.3K bytes
    - Viewed (0)
  4. src/runtime/mgcscavenge.go

    	// because of the additional overheads of using scavenged memory.
    	worked *= 1 + scavengeCostRatio
    
    	// sleepTime is the amount of time we're going to sleep, based on the amount
    	// of time we worked, and the sleepRatio.
    	sleepTime := int64(worked / s.sleepRatio)
    
    	var slept int64
    	if s.sleepStub == nil {
    		// Set the timer.
    		//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:48:45 UTC 2024
    - 52.3K bytes
    - Viewed (0)
  5. cluster/gce/windows/k8s-node-setup.psm1

              -DestinationPrefix ${GCE_METADATA_SERVER}/32 | Out-Null
        } Catch [Microsoft.PowerShell.Cmdletization.Cim.CimJobException] {
          break
        }
        $sleeptime = 2
        Start-Sleep ${sleeptime}
        ${elapsed} += ${sleeptime}
      }
    }
    
    # Adds a route to the GCE metadata server to every network interface.
    function Add_GceMetadataServerRoute {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 21:13:22 UTC 2024
    - 88.3K bytes
    - Viewed (0)
  6. docs_src/sql_databases_peewee/sql_app/main.py

    
    @app.get(
        "/slowusers/", response_model=List[schemas.User], dependencies=[Depends(get_db)]
    )
    def read_slow_users(skip: int = 0, limit: int = 100):
        global sleep_time
        sleep_time = max(0, sleep_time - 1)
        time.sleep(sleep_time)  # Fake long processing request
        users = crud.get_users(skip=skip, limit=limit)
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Thu Mar 26 19:09:53 UTC 2020
    - 2.2K bytes
    - Viewed (0)
  7. bin/update_proxy.sh

    ISTIO_ENVOY_ARM_RELEASE_URL=${ISTIO_ENVOY_ARM_RELEASE_URL:-${ISTIO_ENVOY_BASE_URL}/envoy-alpha-${ISTIO_ENVOY_LINUX_VERSION}-arm64.tar.gz}
    SLEEP_TIME=60
    
    printf "Verifying %s is available\n" "$ISTIO_ENVOY_RELEASE_URL"
    until curl --output /dev/null --silent --head --fail "$ISTIO_ENVOY_RELEASE_URL"; do
        printf '.'
        sleep $SLEEP_TIME
    done
    printf '\n'
    
    printf "Verifying %s is available\n" "$ISTIO_ENVOY_ARM_RELEASE_URL"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 28 07:59:44 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  8. src/cmd/compile/internal/ssa/testdata/scopes.gdb-opt.nexts

    46:				f5(b)
    48:			f6(a)
    33:		for x := 0; x <= 1; x++ { // From delve scopetest.go
    53:				j = id(1)
    54:				f = id(2)
    56:			for i := 0; i <= 5; i++ {
    58:				if i == f {
    62:				sleepytime()
    56:			for i := 0; i <= 5; i++ {
    58:				if i == f {
    62:				sleepytime()
    56:			for i := 0; i <= 5; i++ {
    58:				if i == f {
    59:					fmt.Println("foo")
    64:			helloworld()
    66:	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 02 22:18:10 UTC 2019
    - 1.1K bytes
    - Viewed (0)
  9. src/cmd/compile/internal/ssa/testdata/scopes.dlv-opt.nexts

    46:				f5(b)
    48:			f6(a)
    33:		for x := 0; x <= 1; x++ { // From delve scopetest.go
    53:				j = id(1)
    54:				f = id(2)
    56:			for i := 0; i <= 5; i++ {
    58:				if i == f {
    62:				sleepytime()
    56:			for i := 0; i <= 5; i++ {
    58:				if i == f {
    62:				sleepytime()
    56:			for i := 0; i <= 5; i++ {
    58:				if i == f {
    59:					fmt.Println("foo")
    64:			helloworld()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 02 22:18:10 UTC 2019
    - 1.1K bytes
    - Viewed (0)
  10. src/cmd/compile/internal/ssa/testdata/scopes.go

    		var (
    			j = id(1)
    			f = id(2)
    		)
    		for i := 0; i <= 5; i++ {
    			j += j * (j ^ 3) / 100
    			if i == f {
    				fmt.Println("foo")
    				break
    			}
    			sleepytime()
    		}
    		helloworld()
    	}
    }
    
    func sleepytime() {
    	time.Sleep(5 * time.Millisecond)
    }
    
    func helloworld() {
    	fmt.Println("Hello, World!")
    }
    
    //go:noinline
    func f1(x int) {}
    
    //go:noinline
    func f2(x int) {}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 23 18:05:07 UTC 2018
    - 1.4K bytes
    - Viewed (0)
Back to top