Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 255 for Sleeping (0.17 sec)

  1. tests/integration/security/filebased_tls_origination/egress_gateway_origination_test.go

    }
    
    // Wait for the server to NOT be callable by the client. This allows us to simulate external traffic.
    // This essentially just waits for the Sidecar to be applied, without sleeping.
    func WaitUntilNotCallable(c echo.Instance, dest echo.Instance) error {
    	accept := func(cfg *admin.ConfigDump) (bool, error) {
    		validator := structpath.ForProto(cfg)
    		for _, port := range dest.Config().Ports {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  2. src/time/sleep_test.go

    //
    //go:linkname haveHighResSleep runtime.haveHighResSleep
    var haveHighResSleep bool
    
    // adjustDelay returns an adjusted delay based on the system sleep resolution.
    // Go runtime uses different Windows timers for time.Now and sleeping.
    // These can tick at different frequencies and can arrive out of sync.
    // The effect can be seen, for example, as time.Sleep(100ms) is actually
    // shorter then 100ms when measured as difference between time.Now before and
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 22 16:33:57 UTC 2024
    - 22.5K bytes
    - Viewed (0)
  3. src/runtime/os_darwin.go

    	// Leave the read end of the pipe blocking so that we will block
    	// in sigNoteSleep.
    	setNonblock(sigNoteWrite)
    }
    
    // sigNoteWakeup wakes up a thread sleeping on a note created by sigNoteSetup.
    func sigNoteWakeup(*note) {
    	var b byte
    	write(uintptr(sigNoteWrite), unsafe.Pointer(&b), 1)
    }
    
    // sigNoteSleep waits for a note created by sigNoteSetup to be woken.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Dec 05 20:34:30 UTC 2023
    - 11.9K bytes
    - Viewed (0)
  4. src/runtime/netpoll_solaris.go

    	if !netpollWakeSig.CompareAndSwap(0, 1) {
    		return
    	}
    
    	// Use port_alert to put portfd into alert mode.
    	// This will wake up all threads sleeping in port_getn on portfd,
    	// and cause their calls to port_getn to return immediately.
    	// Further, until portfd is taken out of alert mode,
    	// all calls to port_getn will return immediately.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  5. src/runtime/os_linux.go

    // Linux futex.
    //
    //	futexsleep(uint32 *addr, uint32 val)
    //	futexwakeup(uint32 *addr)
    //
    // Futexsleep atomically checks if *addr == val and if so, sleeps on addr.
    // Futexwakeup wakes up threads sleeping on addr.
    // Futexsleep is allowed to wake up spuriously.
    
    const (
    	_FUTEX_PRIVATE_FLAG = 128
    	_FUTEX_WAIT_PRIVATE = 0 | _FUTEX_PRIVATE_FLAG
    	_FUTEX_WAKE_PRIVATE = 1 | _FUTEX_PRIVATE_FLAG
    )
    
    // Atomically,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  6. src/runtime/mgcscavenge.go

    	printControllerReset bool
    
    	// targetCPUFraction is the target CPU overhead for the scavenger.
    	targetCPUFraction float64
    
    	// sleepRatio is the ratio of time spent doing scavenging work to
    	// time spent sleeping. This is used to decide how long the scavenger
    	// should sleep for in between batches of work. It is set by
    	// critSleepController in order to maintain a CPU overhead of
    	// targetCPUFraction.
    	//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:48:45 UTC 2024
    - 52.3K bytes
    - Viewed (0)
  7. src/os/exec/exec_test.go

    	probe := fs.Duration("probe", 0, "if nonzero, the 'hang' helper should write to stderr at this interval, and exit nonzero if a write fails")
    	read := fs.Bool("read", false, "if true, the 'hang' helper should read stdin to completion before sleeping")
    	fs.Parse(args[1:])
    
    	pid := os.Getpid()
    
    	if *subsleep != 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 20:13:53 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  8. src/runtime/signal_unix.go

    		return
    	}
    
    	raise(sig)
    
    	// Give the signal a chance to be delivered.
    	// In almost all real cases the program is about to crash,
    	// so sleeping here is not a waste of time.
    	usleep(1000)
    
    	// If the signal didn't cause the program to exit, restore the
    	// Go signal handler and carry on.
    	//
    	// We may receive another instance of the signal before we
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 10 16:04:54 UTC 2024
    - 45K bytes
    - Viewed (0)
  9. 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
    					for _, action := range fakeClientset.Actions() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 31.3K bytes
    - Viewed (0)
  10. src/runtime/stack_test.go

    				c <- true
    			}()
    		}
    		for i := 0; i < BatchSize; i++ {
    			<-c
    		}
    
    		// The goroutines have signaled via c that they are ready to exit.
    		// Give them a chance to exit by sleeping. If we don't wait, we
    		// might not reuse them on the next batch.
    		time.Sleep(10 * time.Millisecond)
    	}
    	s1 := new(MemStats)
    	ReadMemStats(s1)
    	consumed := int64(s1.StackSys - s0.StackSys)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 14 00:03:57 UTC 2023
    - 23.1K bytes
    - Viewed (0)
Back to top