Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 111 for wakep (0.38 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. test/chanlinear.go

    				for j := 0; j < messages; j++ {
    					// queue ourselves on the global channel
    					select {
    					case <-c:
    					case <-d:
    					}
    				}
    			}()
    		}
    		for i := 0; i < messages; i++ {
    			// wake each goroutine up, forcing it to dequeue and then enqueue
    			// on the global channel.
    			for _, d := range a {
    				d <- true
    			}
    		}
    	})
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:25 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top