- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for unblocksig (0.32 sec)
-
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) -
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) -
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) -
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) -
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) -
src/runtime/rwmutex.go
if r := rw.readerCount.Add(-1); r < 0 { if r+1 == 0 || r+1 == -rwmutexMaxReaders { throw("runlock of unlocked rwmutex") } // A writer is pending. if rw.readerWait.Add(-1) == 0 { // The last reader unblocks the writer. lock(&rw.rLock) w := rw.writer.ptr() if w != nil { notewakeup(&w.park) } unlock(&rw.rLock) } } releaseLockRankAndM(rw.readRank) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 5K bytes - Viewed (0) -
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) -
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)