Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for unblocksig (0.24 sec)

  1. src/runtime/export_unix_test.go

    // a non-zero byte to w, WaitForSigusr1 returns immediately with -1, -1.
    func WaitForSigusr1(r, w int32, ready func(mp *M)) (int64, int64) {
    	lockOSThread()
    	// Make sure we can receive SIGUSR1.
    	unblocksig(_SIGUSR1)
    
    	waitForSigusr1.rdpipe = r
    	waitForSigusr1.wrpipe = w
    
    	mp := getg().m
    	testSigusr1 = waitForSigusr1Callback
    	ready(mp)
    
    	// Wait for the signal. We use a pipe rather than a note
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 20 21:27:51 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        // thread because the task will block on the task latch after unblocking
        // the run latch.
        exec.execute(task);
        runLatch.await();
        assertEquals(1, listenerLatch.getCount());
        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
        // Finish the task by unblocking the task latch.  Then wait for the
        // listener to be called by blocking on the listener latch.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        // thread because the task will block on the task latch after unblocking
        // the run latch.
        exec.execute(task);
        runLatch.await();
        assertEquals(1, listenerLatch.getCount());
        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
        // Finish the task by unblocking the task latch.  Then wait for the
        // listener to be called by blocking on the listener latch.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  4. src/cmd/go/internal/lockedfile/internal/filelock/filelock_fcntl.go

    	// 	P.1 locks file A.
    	// 	Q.3 locks file B.
    	// 	Q.3 blocks on file A.
    	// 	P.2 blocks on file B. (This is erroneously reported as a deadlock.)
    	// 	P.1 unlocks file A.
    	// 	Q.3 unblocks and locks file A.
    	// 	Q.3 unlocks files A and B.
    	// 	P.2 unblocks and locks file B.
    	// 	P.2 unlocks file B.
    	//
    	// These spurious errors were observed in practice on AIX and Solaris in
    	// cmd/go: see https://golang.org/issue/32817.
    	//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 17 02:24:35 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  5. src/cmd/go/internal/lockedfile/lockedfile_test.go

    	// 	P.1 locks file A.
    	// 	Q.3 locks file B.
    	// 	Q.3 blocks on file A.
    	// 	P.2 blocks on file B. (Spurious EDEADLK occurs here.)
    	// 	P.1 unlocks file A.
    	// 	Q.3 unblocks and locks file A.
    	// 	Q.3 unlocks files A and B.
    	// 	P.2 unblocks and locks file B.
    	// 	P.2 unlocks file B.
    
    	testenv.MustHaveExec(t)
    
    	dirVar := t.Name() + "DIR"
    
    	if dir := os.Getenv(dirVar); dir != "" {
    		// Q.3 locks file B.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Sep 05 23:35:29 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  6. src/internal/trace/parser.go

    type Frame struct {
    	PC   uint64
    	Fn   string
    	File string
    	Line int
    }
    
    const (
    	// Special P identifiers:
    	FakeP    = 1000000 + iota
    	TimerP   // depicts timer unblocks
    	NetpollP // depicts network unblocks
    	SyscallP // depicts returns from syscalls
    	GCP      // depicts GC state
    	ProfileP // depicts recording of CPU profile samples
    )
    
    // Event types in the trace.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:31:04 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. src/internal/poll/fd_poll_runtime.go

    	return nil
    }
    
    func (pd *pollDesc) close() {
    	if pd.runtimeCtx == 0 {
    		return
    	}
    	runtime_pollClose(pd.runtimeCtx)
    	pd.runtimeCtx = 0
    }
    
    // Evict evicts fd from the pending list, unblocking any I/O running on fd.
    func (pd *pollDesc) evict() {
    	if pd.runtimeCtx == 0 {
    		return
    	}
    	runtime_pollUnblock(pd.runtimeCtx)
    }
    
    func (pd *pollDesc) prepare(mode int, isFile bool) error {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:18:59 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/OverflowAvoidingLockSupport.java

      private OverflowAvoidingLockSupport() {}
    
      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)
  9. guava/src/com/google/common/util/concurrent/OverflowAvoidingLockSupport.java

      private OverflowAvoidingLockSupport() {}
    
      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)
  10. src/internal/trace/testdata/testprog/futile-wakeup.go

    // license that can be found in the LICENSE file.
    
    // Tests to make sure the runtime doesn't generate futile wakeups. For example,
    // it makes sure that a block on a channel send that unblocks briefly only to
    // immediately go back to sleep (in such a way that doesn't reveal any useful
    // information, and is purely an artifact of the runtime implementation) doesn't
    // make it into the trace.
    
    //go:build ignore
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 1.8K bytes
    - Viewed (0)
Back to top