Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 138 for timerC (0.23 sec)

  1. pilot/pkg/bootstrap/istio_ca.go

    func (s *Server) handleCACertsFileWatch() {
    	var timerC <-chan time.Time
    	for {
    		select {
    		case <-timerC:
    			timerC = nil
    			handleEvent(s)
    
    		case event, ok := <-s.cacertsWatcher.Events:
    			if !ok {
    				log.Debug("plugin cacerts watch stopped")
    				return
    			}
    			if event.Has(fsnotify.Write) || event.Has(fsnotify.Create) {
    				if timerC == nil {
    					timerC = time.After(100 * time.Millisecond)
    				}
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  2. doc/next/6-stdlib/1-time.md

    ### Timer changes
    
    Go 1.23 makes two significant changes to the implementation of
    [time.Timer] and [time.Ticker].
    
    <!-- go.dev/issue/61542 -->
    First, `Timer`s and `Ticker`s that are no longer referred to by the program
    become eligible for garbage collection immediately, even if their
    `Stop` methods have not been called.
    Earlier versions of Go did not collect unstopped `Timer`s until after
    they had fired and never collected unstopped `Ticker`s.
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 20:49:22 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  3. src/time/internal_test.go

    	// bad when on update), or other timers will hang (if the timer in a
    	// heap is in a bad state). There is no reliable way to test this, but
    	// we wait on a short timer here as a smoke test (alternatively, timers
    	// in later tests may hang).
    	<-After(25 * Millisecond)
    }
    
    var (
    	MinMonoTime = Time{wall: 1 << 63, ext: -1 << 63, loc: UTC}
    	MaxMonoTime = Time{wall: 1 << 63, ext: 1<<63 - 1, loc: UTC}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 03 14:56:37 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  4. src/internal/poll/fd_plan9.go

    		// Interrupt I/O operation once timer has expired
    		if mode == 'r' || mode == 'r'+'w' {
    			var timer *time.Timer
    			timer = time.AfterFunc(d, func() {
    				fd.rmu.Lock()
    				defer fd.rmu.Unlock()
    				if fd.rtimer != timer {
    					// deadline was changed
    					return
    				}
    				fd.rtimedout = true
    				if fd.raio != nil {
    					fd.raio.Cancel()
    				}
    			})
    			fd.rtimer = timer
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 06 14:00:54 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  5. src/time/tick_test.go

    	// from the timer/ticker channel after Reset.
    	// When using Go 1.23 sync timers/tickers, draining is never needed
    	// (that's the whole point of the sync timer/ticker change).
    	drain1 := func() {
    		for range drainTries {
    			select {
    			case <-C:
    				return
    			default:
    			}
    			Sleep(sched)
    		}
    	}
    
    	// drainAsync removes potential stale time values after Stop/Reset.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 17:10:37 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  6. src/time/time.go

    //
    // Programs using times should typically store and pass them as values,
    // not pointers. That is, time variables and struct fields should be of
    // type [time.Time], not *time.Time.
    //
    // A Time value can be used by multiple goroutines simultaneously except
    // that the methods [Time.GobDecode], [Time.UnmarshalBinary], [Time.UnmarshalJSON] and
    // [Time.UnmarshalText] are not concurrency-safe.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 50.7K bytes
    - Viewed (0)
  7. src/runtime/mklockrank.go

    < allocmR,
      execR;
    allocmR, execR, hchan < sched;
    sched < allg, allp;
    
    # Channels
    NONE < notifyList;
    hchan, notifyList < sudog;
    
    hchan, pollDesc, wakeableSleep < timers;
    timers, timerSend < timer < netpollInit;
    
    # Semaphores
    NONE < root;
    
    # Itabs
    NONE
    < itab
    < reflectOffs;
    
    # User arena state
    NONE < userArenaState;
    
    # Tracing without a P uses a global trace buffer.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:47:01 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  8. src/internal/trace/parser.go

    package trace
    
    // Frame is a frame in stack traces.
    type Frame struct {
    	PC   uint64
    	Fn   string
    	File string
    	Line int
    }
    
    const (
    	// Special P identifiers:
    	FakeP    = 1000000 + iota
    	TimerP   // depicts timer unblocks
    	NetpollP // depicts network unblocks
    	SyscallP // depicts returns from syscalls
    	GCP      // depicts GC state
    	ProfileP // depicts recording of CPU profile samples
    )
    
    // Event types in the trace.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:31:04 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  9. src/runtime/netpoll.go

    	user    uint32    // user settable cookie
    	rseq    uintptr   // protects from stale read timers
    	rt      timer     // read deadline timer
    	rd      int64     // read deadline (a nanotime in the future, -1 when expired)
    	wseq    uintptr   // protects from stale write timers
    	wt      timer     // write deadline timer
    	wd      int64     // write deadline (a nanotime in the future, -1 when expired)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  10. src/runtime/runtime2.go

    	// running P (returned by pidleget) may add a timer at any time, so its mask
    	// must be set. An idle P (passed to pidleput) cannot add new timers while
    	// idle, so if it has no timers at that time, its mask may be cleared.
    	//
    	// Thus, we get the following effects on timer-stealing in findrunnable:
    	//
    	//   - Idle Ps with no timers when they go idle are never checked in findrunnable
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
Back to top