- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 8,955 for Wake (0.06 sec)
-
src/internal/poll/fd_mutex.go
if new&mutexRefMask == 0 { panic(overflowMsg) } // Remove all read and write waiters. new &^= mutexRMask | mutexWMask if atomic.CompareAndSwapUint64(&mu.state, old, new) { // Wake all read and write waiters, // they will observe closed flag after wakeup. for old&mutexRMask != 0 { old -= mutexRWait runtime_Semrelease(&mu.rsema) } for old&mutexWMask != 0 { old -= mutexWWait
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 20 16:55:30 UTC 2018 - 6.4K bytes - Viewed (0) -
src/runtime/netpoll_kqueue_pipe.go
import "unsafe" // TODO(panjf2000): NetBSD didn't implement EVFILT_USER for user-established events // until NetBSD 10.0, check out https://www.netbsd.org/releases/formal-10/NetBSD-10.0.html // Therefore we use the pipe to wake up the kevent on NetBSD at this point. Get back here // and switch to EVFILT_USER when we bump up the minimal requirement of NetBSD to 10.0. // Alternatively, maybe we can use EVFILT_USER on the NetBSD by checking the kernel version
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 12 21:17:22 UTC 2024 - 2.1K bytes - Viewed (0) -
src/runtime/time.go
ts.lock() ts.cleanHead() t.lock() t.trace("maybeAdd") when := int64(0) wake := false if t.needsAdd() { t.state |= timerHeaped when = t.when wakeTime := ts.wakeTime() wake = wakeTime == 0 || when < wakeTime ts.addHeap(t) } t.unlock() ts.unlock() releasem(mp) if wake { wakeNetPoller(when) } } // reset resets the time when a timer should fire.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 29 14:36:24 UTC 2024 - 37.5K bytes - Viewed (0) -
src/runtime/mgcscavenge_test.go
alloc: []BitRange{{bits + 2, PallocChunkPages - (bits + 2)}}, min: 1, max: 3, // Make it so that max would have us try to break the huge page. want: BitRange{0, bits + 2}, } if 3*bits < PallocChunkPages { // We need at least 3 huge pages in a chunk for this test to make sense. tests["PreserveHugePageMiddle"] = test{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 25.2K bytes - Viewed (0) -
src/runtime/tracecpu.go
return } // We're going to conditionally write to one of two buffers based on the // generation. To make sure we write to the correct one, we need to make // sure this thread's trace seqlock is held. If it already is, then we're // in the tracer and we can just take advantage of that. If it isn't, then // we need to acquire it and read the generation. locked := false if mp.trace.seqlock.Load()%2 == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 8.7K bytes - Viewed (0) -
security/pkg/credentialfetcher/plugin/gce.go
aud: audience, jwtPath: jwtPath, identityProvider: identityProvider, closing: make(chan bool), } if rotateToken { go p.startTokenRotationJob() } return p } func (p *GCEPlugin) Stop() { close(p.closing) } func (p *GCEPlugin) startTokenRotationJob() { // Wake up once in a while and refresh GCE VM credential. p.rotationTicker = time.NewTicker(rotationInterval) for {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 4.7K bytes - Viewed (0) -
src/runtime/netpoll_windows.go
if delay > 0 && mp.waitIocpHandle != 0 { // GetQueuedCompletionStatusEx doesn't use a high resolution timer internally, // so we use a separate higher resolution timer associated with a wait completion // packet to wake up the poller. Note that the completion packet can be delivered // to another thread, and the Go scheduler expects netpoll to only block up to delay, // so we still need to use a timeout with GetQueuedCompletionStatusEx.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 9.4K bytes - Viewed (0) -
src/runtime/semasleep_test.go
if err != nil { t.Fatalf("StdoutPipe: %v", err) } beforeStart := time.Now() if err := cmd.Start(); err != nil { t.Fatalf("Failed to start command: %v", err) } waiting := false doneCh := make(chan error, 1) t.Cleanup(func() { cmd.Process.Kill() if waiting { <-doneCh } else { cmd.Wait() } }) // Wait for After1 to close its stdout so that we know the runtime's SIGIO
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 17:48:24 UTC 2023 - 3.5K bytes - Viewed (0) -
src/runtime/chan_test.go
if runtime.GOOS == "linux" && runtime.GOARCH == "ppc64le" { testenv.SkipFlaky(t, 22047) } c1 := make(chan byte, trials+1) c2 := make(chan byte, trials+1) for i := 0; i < trials+1; i++ { c1 <- 1 c2 <- 2 } c3 := make(chan byte) c4 := make(chan byte) out := make(chan byte) done := make(chan byte) var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() for { var b byte
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 31 20:47:35 UTC 2023 - 23.4K bytes - Viewed (0) -
src/net/fd_unix.go
// wakes up waitWrite). ctxDone := ctx.Done() if ctxDone != nil { // Wait for the interrupter goroutine to exit before returning // from connect. done := make(chan struct{}) interruptRes := make(chan error) defer func() { close(done) if ctxErr := <-interruptRes; ctxErr != nil && ret == nil { // The interrupter goroutine called SetWriteDeadline,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 24 20:19:46 UTC 2023 - 5.4K bytes - Viewed (0)