- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 111 for wakep (0.04 sec)
-
src/sync/runtime.go
func runtime_SemacquireRWMutex(s *uint32, lifo bool, skipframes int) // Semrelease atomically increments *s and notifies a waiting goroutine // if one is blocked in Semacquire. // It is intended as a simple wakeup primitive for use by the synchronization // library and should not be used directly. // If handoff is true, pass count directly to the first waiter. // skipframes is the number of frames to omit during tracing, counting from
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 16 16:32:27 UTC 2022 - 2.3K bytes - Viewed (0) -
src/sync/waitgroup_test.go
}() // spawn goroutine 2 wg.Add(1) go func() { atomic.AddInt32(n, 1) wg.Done() }() // Wait for goroutine 1 and 2 wg.Wait() if atomic.LoadInt32(n) != 2 { t.Fatal("Spurious wakeup from Wait") } } } func TestWaitGroupAlign(t *testing.T) { type X struct { x byte wg WaitGroup } var x X x.wg.Add(1) go func(x *X) { x.wg.Done() }(&x) x.wg.Wait() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 14 17:38:39 UTC 2021 - 3K bytes - Viewed (0) -
src/runtime/abi_test.go
// cause a crash, but because we're running in a separate process // it's extremely unlikely. runtime.GC() runtime.GC() // fing will only pick the new IntRegArgs up if it's currently // sleeping and wakes up, so wait for it to go to sleep. success := false for i := 0; i < 100; i++ { if runtime.FinalizerGAsleep() { success = true break } time.Sleep(20 * time.Millisecond) } if !success {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 3.1K 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) -
test/chanlinear.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:25 UTC 2023 - 2.1K bytes - Viewed (0) -
src/runtime/runtime2.go
// previous notesleep has returned, e.g. it's disallowed // to call noteclear straight after notewakeup. // // notetsleep is like notesleep but wakes up after // a given number of nanoseconds even if the event // has not yet happened. if a goroutine uses notetsleep to // wake up early, it must wait to call noteclear until it // can be sure that no other goroutine is calling // notewakeup. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 47.9K bytes - Viewed (0) -
src/internal/trace/trace_test.go
t.Logf("%d: %q", samples, stack) } t.Logf("CPU profile:\n%s", stderr) } }) } func TestTraceFutileWakeup(t *testing.T) { testTraceProg(t, "futile-wakeup.go", func(t *testing.T, tb, _ []byte, _ bool) { // Check to make sure that no goroutine in the "special" trace region // ends up blocking, unblocking, then immediately blocking again. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 18.5K bytes - Viewed (0) -
src/runtime/select.go
} else { c.recvq.dequeueSudoG(sglist) } } sgnext = sglist.waitlink sglist.waitlink = nil releaseSudog(sglist) sglist = sgnext } if cas == nil { throw("selectgo: bad wakeup") } c = cas.c if debugSelect { print("wait-return: cas0=", cas0, " c=", c, " cas=", cas, " send=", casi < nsends, "\n") } if casi < nsends { if !caseSuccess { goto sclose
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 13 21:36:04 UTC 2024 - 15K bytes - Viewed (0) -
src/runtime/netpoll_epoll.go
} func netpollarm(pd *pollDesc, mode int) { throw("runtime: unused") } // netpollBreak interrupts an epollwait. func netpollBreak() { // Failing to cas indicates there is an in-flight wakeup, so we're done here. if !netpollWakeSig.CompareAndSwap(0, 1) { return } var one uint64 = 1 oneSize := int32(unsafe.Sizeof(one)) for { n := write(netpollEventFd, noescape(unsafe.Pointer(&one)), oneSize)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 4.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
// never hit the w.cond.Wait(). // As a result - we can optimize the code by not firing the wakeup // function (and avoid starting a gorotuine), especially given that // resourceVersion=0 is the most common case. if resourceVersion > 0 { go func() { // Wake us up when the time limit has expired. The docs // promise that time.After (well, NewTimer, which it calls)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0)