- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for Inblock (0.17 sec)
-
src/runtime/mfinal.go
finptrmask[i] = finalizer1[i%len(finalizer1)] } } } block := finc finc = block.next block.next = finq finq = block } f := &finq.fin[finq.cnt] atomic.Xadd(&finq.cnt, +1) // Sync with markroots f.fn = fn f.nret = nret f.fint = fint f.ot = ot f.arg = p unlock(&finlock) fingStatus.Or(fingWake) } //go:nowritebarrier
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 01:56:56 UTC 2024 - 19K bytes - Viewed (0) -
src/cmd/compile/internal/ssagen/ssa.go
base.Fatalf("in %s, badly placed LoweredGetClosurePtr: %v %v", v.Block.Func.Name, v.Block, v) } } } // CheckArgReg ensures that v is in the function's entry block. func CheckArgReg(v *ssa.Value) { entry := v.Block.Func.Entry if entry != v.Block { base.Fatalf("in %s, badly placed ArgIReg or ArgFReg: %v %v", v.Block.Func.Name, v.Block, v) } } func AddrAuto(a *obj.Addr, v *ssa.Value) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 284.9K bytes - Viewed (0) -
samples/bookinfo/src/productpage/templates/productpage.html
{% block metas %} <meta charset="utf-8"> <meta http-equiv="X-UA-Compatible" content="IE=edge"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> {% endblock %} <title>Simple Bookstore App</title> {% block scripts %} <script src="static/tailwind/tailwind.css"></script> <script type="text/javascript"> window.addEventListener("DOMContentLoaded", (event) => { const dialog = document.querySelector("dialog");
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 19:54:05 UTC 2024 - 10.9K bytes - Viewed (0) -
src/sync/rwmutex.go
rw.w.Unlock() if race.Enabled { race.Enable() } return false } if race.Enabled { race.Enable() race.Acquire(unsafe.Pointer(&rw.readerSem)) race.Acquire(unsafe.Pointer(&rw.writerSem)) } return true } // Unlock unlocks rw for writing. It is a run-time error if rw is // not locked for writing on entry to Unlock. //
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/internal/trace/order.go
// N.B. No context to validate. Basically anything can unblock // a goroutine (e.g. sysmon). o.queue.push(Event{table: evt, ctx: curCtx, base: *ev}) return curCtx, true, nil } func (o *ordering) advanceGoSwitch(ev *baseEvent, evt *evTable, m ThreadID, gen uint64, curCtx schedCtx) (schedCtx, bool, error) { // GoSwitch and GoSwitchDestroy represent a trio of events: // - Unblock of the goroutine to switch to.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
src/os/signal/doc.go
itself, those threads may set the signal mask as they please. If the non-Go code starts a new thread, changes the signal mask, and then invokes a Go function in that thread, the Go runtime will automatically unblock certain signals: the synchronous signals, SIGILL, SIGTRAP, SIGSTKFLT, SIGCHLD, SIGPROF, SIGCANCEL, and SIGSETXID. When the Go function returns, the non-Go signal mask will be restored.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:11:00 UTC 2024 - 11K bytes - Viewed (0) -
internal/grid/muxserver.go
} else { m.send(message{Op: OpDisconnectClientMux, MuxID: m.ID}) } // Unlock, since we are calling deleteMux, which will call close - which will lock recvMu. if locked { m.recvMu.Unlock() defer m.recvMu.Lock() } m.parent.deleteMux(true, m.ID) } func (m *muxServer) send(msg message) { m.sendMu.Lock() defer m.sendMu.Unlock() msg.MuxID = m.ID msg.Seq = m.SendSeq m.SendSeq++ if debugPrint {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
internal/grid/connection.go
if !ok || mid == nil { resp(true) return } mid.respMu.Lock() resp(mid.closed) mid.respMu.Unlock() case debugBlockInboundMessages: c.connMu.Lock() block := (<-chan struct{})(args[0].(chan struct{})) c.blockMessages.Store(&block) c.connMu.Unlock() } } // wsWriter writes websocket messages. type wsWriter struct { tmp [ws.MaxHeaderSize]byte }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
internal/grid/muxclient.go
return nil, errors.New("RequestStream: responses channel is nil") } m.init = true m.respMu.Lock() if m.closed { m.respMu.Unlock() return nil, ErrDisconnected } m.respWait = responses // Route directly to output. m.respMu.Unlock() // Try to grab an initial block. m.singleResp = false m.RecvSeq = m.SendSeq // Sync if cap(requests) > 0 { m.outBlock = make(chan struct{}, cap(requests)) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/debug.go
OptDcl []*ir.Name // Filled in by the user. Translates Block and Value ID to PC. // // NOTE: block is only used if value is BlockStart.ID or BlockEnd.ID. // Otherwise, it is ignored. GetPC func(block, value ID) int64 } type BlockDebug struct { // State at the start and end of the block. These are initialized, // and updated from new information that flows on back edges.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 58.4K bytes - Viewed (0)