Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for unblocksig (0.32 sec)

  1. 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)
  2. 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)
  3. 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)
  4. src/sync/cond.go

    //
    // A Cond must not be copied after first use.
    //
    // In the terminology of [the Go memory model], Cond arranges that
    // a call to [Cond.Broadcast] or [Cond.Signal] “synchronizes before” any Wait call
    // that it unblocks.
    //
    // For many simple use cases, users will be better off using channels than a
    // Cond (Broadcast corresponds to closing a channel, and Signal corresponds to
    // sending on a channel).
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  5. src/sync/waitgroup.go

    //
    // A WaitGroup must not be copied after first use.
    //
    // In the terminology of [the Go memory model], a call to [WaitGroup.Done]
    // “synchronizes before” the return of any Wait call that it unblocks.
    //
    // [the Go memory model]: https://go.dev/ref/mem
    type WaitGroup struct {
    	noCopy noCopy
    
    	state atomic.Uint64 // high 32 bits are counter, low 32 bits are waiter count.
    	sema  uint32
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 4K bytes
    - Viewed (0)
  6. internal/grid/muxserver.go

    	if msg.DeadlineMS == 0 || msg.DeadlineMS > uint32(4*c.clientPingInterval/time.Millisecond) {
    		go func() {
    			wg.Wait()
    			m.checkRemoteAlive()
    		}()
    	}
    	return &m
    }
    
    // handleInbound sends unblocks when we have delivered the message to the handler.
    func (m *muxServer) handleInbound(c *Connection, inbound <-chan []byte, handlerIn chan<- []byte) {
    	for {
    		select {
    		case <-m.ctx.Done():
    			return
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  7. src/sync/rwmutex.go

    	if r+1 == 0 || r+1 == -rwmutexMaxReaders {
    		race.Enable()
    		fatal("sync: RUnlock of unlocked RWMutex")
    	}
    	// A writer is pending.
    	if rw.readerWait.Add(-1) == 0 {
    		// The last reader unblocks the writer.
    		runtime_Semrelease(&rw.writerSem, false, 1)
    	}
    }
    
    // Lock locks rw for writing.
    // If the lock is already locked for reading or writing,
    // Lock blocks until the lock is available.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 7.2K bytes
    - Viewed (0)
Back to top