- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 85 for wakep (0.11 sec)
-
src/runtime/export_debug_test.go
h.debugCallReturn(ctxt) case 2: // Function panicked. Copy panic out. h.debugCallPanicOut(ctxt) case 8: // Call isn't safe. Get the reason. h.debugCallUnsafe(ctxt) // Don't wake h.done. We need to transition to status 16 first. case 16: h.restoreSigContext(ctxt) // Done notewakeup(&h.done) default: h.err = plainError("unexpected debugCallV2 status") notewakeup(&h.done)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 15:41:45 UTC 2024 - 5.1K bytes - Viewed (0) -
src/runtime/profbuf.go
} b.eof.Store(1) b.wakeupExtra() } // wakeupExtra must be called after setting one of the "extra" // atomic fields b.overflow or b.eof. // It records the change in b.w and wakes up the reader if needed. func (b *profBuf) wakeupExtra() { for { old := b.w.load() new := old | profWriteExtra if !b.w.cas(old, new) { continue } if old&profReaderSleeping != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 18.2K bytes - Viewed (0) -
src/runtime/mgcscavenge.go
func (s *scavengerState) ready() { s.sysmonWake.Store(1) } // wake immediately unparks the scavenger if necessary. // // Safe to run without a P. func (s *scavengerState) wake() { lock(&s.lock) if s.parked { // Unset sysmonWake, since the scavenger is now being awoken. s.sysmonWake.Store(0) // s.parked is unset to prevent a double wake-up. s.parked = false
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:48:45 UTC 2024 - 52.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
// ||----w | // || || // We need to clear the interrupted bit prior to calling park and maintain it in case we // wake up spuriously. restoreInterruptedBit = Thread.interrupted() || restoreInterruptedBit; LockSupport.park(blocker); } } else { Thread.yield(); } state = get();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Sep 29 21:34:48 UTC 2023 - 9.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/InterruptibleTask.java
// ||----w | // || || // We need to clear the interrupted bit prior to calling park and maintain it in case we // wake up spuriously. restoreInterruptedBit = Thread.interrupted() || restoreInterruptedBit; LockSupport.park(blocker); } } else { Thread.yield(); } state = get();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Sep 29 21:34:48 UTC 2023 - 9.9K bytes - Viewed (0) -
lib/time/zoneinfo.zip
Pacific/Norfolk Pacific/Noumea Pacific/Pago_Pago Pacific/Palau Pacific/Pitcairn Pacific/Pohnpei Pacific/Ponape Pacific/Port_Moresby Pacific/Rarotonga Pacific/Saipan Pacific/Samoa Pacific/Tahiti Pacific/Tarawa Pacific/Tongatapu Pacific/Truk Pacific/Wake Pacific/Wallis Pacific/Yap Poland Portugal ROC ROK Singapore Turkey UCT US/Alaska US/Aleutian US/Arizona US/Central US/East-Indiana US/Eastern US/Hawaii US/Indiana-Starke US/Michigan US/Mountain US/Pacific US/Samoa UTC Universal W-SU WET Zulu...
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 02 18:20:41 UTC 2024 - 392.3K bytes - Viewed (1) -
src/runtime/chan.go
gp.param = nil if mysg.releasetime > 0 { blockevent(mysg.releasetime-t0, 2) } mysg.c = nil releaseSudog(mysg) if closed { if c.closed == 0 { throw("chansend: spurious wakeup") } panic(plainError("send on closed channel")) } return true } // send processes a send operation on an empty channel c. // The value ep sent by the sender is copied to the receiver sg.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
src/runtime/mgcsweep.go
c.fullUnswept(sg).reset() } // Sweeping is done, so there won't be any new memory to // scavenge for a bit. // // If the scavenger isn't already awake, wake it up. There's // definitely work for it to do at this point. scavenger.wake() nextMarkBitArenaEpoch() } func bgsweep(c chan int) { sweep.g = getg() lockInit(&sweep.lock, lockRankSweep) lock(&sweep.lock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:52:18 UTC 2024 - 32.9K bytes - Viewed (0) -
src/os/signal/signal_cgo_test.go
if err := unix.Tcsetpgrp(ptyFD, pgrp); err != nil { return fmt.Errorf("error setting tty process group: %w", err) } // Give the kernel time to potentially wake readers and have // them return EINTR (darwin does this). time.Sleep(pause) // Give TTY back. pid := int32(cmd.Process.Pid) // assume that pid_t is int32 if err := unix.Tcsetpgrp(ptyFD, pid); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 20 10:09:15 UTC 2024 - 10.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
removeWaiter(node); throw new InterruptedException(); } // Otherwise re-read and check doneness. If we loop then it must have been a spurious // wakeup localValue = value; if (localValue != null & !(localValue instanceof SetFuture)) { return getDoneValue(localValue); } // timed out?
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1)