- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 48 for unblocksig (0.24 sec)
-
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) -
staging/src/k8s.io/apiserver/pkg/server/lifecycle_signals.go
type lifecycleSignal interface { // Signal signals the event, indicating that the event has occurred. // Signal is idempotent, once signaled the event stays signaled and // it immediately unblocks any goroutine waiting for this event. Signal() // Signaled returns a channel that is closed when the underlying event // has been signaled. Successive calls to Signaled return the same value. Signaled() <-chan struct{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:30 UTC 2023 - 7.8K bytes - Viewed (0) -
pkg/util/iptables/monitor_test.go
mfe.blockIPTables(true) ipt.DeleteChain(TableNAT, canary) if err := waitForBlocked(mfe); err != nil { t.Errorf("failed waiting for monitor to be blocked from monitoring: %v", err) } // After unblocking the monitor, it should now reload mfe.blockIPTables(false) if err := waitForReloads(&reloads, 2); err != nil { t.Errorf("got unexpected number of reloads after slow flush: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 08 15:21:59 UTC 2023 - 9.3K 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) -
src/net/net_test.go
go func() { // TODO: find a better way to wait // until we're blocked in the cs.Read // call below. Sleep is lame. time.Sleep(100 * time.Millisecond) // Interrupt the upcoming Read, unblocking it: cs.SetReadDeadline(time.Unix(123, 0)) // time in the past }() var buf [1]byte n, err := cs.Read(buf[:1]) if n != 0 || err == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 22 21:04:44 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/kubelet/container/testing/fake_runtime.go
f.Unlock() select { case <-ctx.Done(): case <-f.imagePullTokenBucket: } return image.Image, retErr } // UnblockImagePulls unblocks a certain number of image pulls, if BlockImagePulls is true. func (f *FakeRuntime) UnblockImagePulls(count int) { if f.imagePullTokenBucket != nil { for i := 0; i < count; i++ { select {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 14 00:23:50 UTC 2024 - 13.9K bytes - Viewed (0) -
src/cmd/trace/gstate.go
name := gs.baseName if gs.label != "" { name += " (" + gs.label + ")" } return name } // setStartCause sets the reason a goroutine will be allowed to start soon. // For example, via unblocking or exiting a blocked syscall. func (gs *gState[R]) setStartCause(ts trace.Time, name string, resource uint64, stack trace.Stack) { gs.startCause.time = ts gs.startCause.name = name gs.startCause.resource = resource
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.9K bytes - Viewed (0)