- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 55 for MakeOp (0.27 sec)
-
src/runtime/lock_futex.go
// One-time notifications. func noteclear(n *note) { n.key = 0 } func notewakeup(n *note) { old := atomic.Xchg(key32(&n.key), 1) if old != 0 { print("notewakeup - double wakeup (", old, ")\n") throw("notewakeup - double wakeup") } futexwakeup(key32(&n.key), 1) } func notesleep(n *note) { gp := getg() if gp != gp.m.g0 { throw("notesleep not on g0") } ns := int64(-1)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:34 UTC 2024 - 5.4K bytes - Viewed (0) -
src/runtime/trace.go
// timer *and* nothing else will call wake concurrently. func (s *wakeableSleep) close() { // Set wakeup to nil so that a late timer ends up being a no-op. lock(&s.lock) if raceenabled { raceacquire(unsafe.Pointer(&s.lock)) } wakeup := s.wakeup s.wakeup = nil // Close the channel. close(wakeup) if raceenabled { racerelease(unsafe.Pointer(&s.lock)) } unlock(&s.lock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 37.1K bytes - Viewed (0) -
src/runtime/lock_wasip1.go
} l.key = mutex_unlocked } // One-time notifications. func noteclear(n *note) { n.key = 0 } func notewakeup(n *note) { if n.key != 0 { print("notewakeup - double wakeup (", n.key, ")\n") throw("notewakeup - double wakeup") } n.key = 1 } func notesleep(n *note) { throw("notesleep not supported by wasi") } func notetsleep(n *note, ns int64) bool { throw("notetsleep not supported by wasi")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 21:02:20 UTC 2023 - 2K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient_test.go
Netns: "someNetNS", IfName: "ethBro", ContainerID: "bbb-eee-www", } var ( fakeIP = net.ParseIP("99.9.9.9") fakeGW = net.ParseIP("88.9.9.9") fakeIDX = 0 fakePrevResultIPConfig = cniv1.IPConfig{ Interface: &fakeIDX, Address: net.IPNet{ IP: fakeIP, }, Gateway: fakeGW, } ) func TestPushCNIAddEventSucceed(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 4.2K bytes - Viewed (0) -
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) -
android/guava/src/com/google/common/util/concurrent/OverflowAvoidingLockSupport.java
static void parkNanos(@CheckForNull Object blocker, long nanos) { // Even in the extremely unlikely event that a thread unblocks itself early after only 68 years, // this is indistinguishable from a spurious wakeup, which LockSupport allows. LockSupport.parkNanos(blocker, min(nanos, MAX_NANOSECONDS_THRESHOLD)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 1.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/OverflowAvoidingLockSupport.java
static void parkNanos(@CheckForNull Object blocker, long nanos) { // Even in the extremely unlikely event that a thread unblocks itself early after only 68 years, // this is indistinguishable from a spurious wakeup, which LockSupport allows. LockSupport.parkNanos(blocker, min(nanos, MAX_NANOSECONDS_THRESHOLD)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 1.6K bytes - Viewed (0) -
src/runtime/sema.go
// Intended use is provide a sleep and wakeup // primitive that can be used in the contended case // of other synchronization primitives. // Thus it targets the same goal as Linux's futex, // but it has much simpler semantics. // // That is, don't think of these as semaphores. // Think of them as a way to implement sleep and wakeup // such that every sleep is paired with a single wakeup,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 19K 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/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)