- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 805 for goroutineID (0.19 sec)
-
src/internal/trace/testtrace/validation.go
case trace.ResourceGoroutine: // Basic state transition validation. id := tr.Resource.Goroutine() old, new := tr.Goroutine() if new == trace.GoUndetermined { e.Errorf("transition to undetermined state for goroutine %d", id) } if v.seenSync && old == trace.GoUndetermined { e.Errorf("undetermined goroutine %d after first global sync", id) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.9K bytes - Viewed (0) -
src/runtime/sema.go
// Charge contention that this (delayed) unlock caused. // If there are N more goroutines waiting beyond the // one that's waking up, charge their delay as well, so that // contention holding up many goroutines shows up as // more costly than contention holding up a single goroutine. // It would take O(N) time to calculate how long each goroutine // has been waiting, so instead we charge avg(head-wait, tail-wait)*N.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 19K bytes - Viewed (0) -
src/runtime/mgc.go
// N.B. we intentionally wait on each goroutine individually // rather than starting all in a batch and then waiting once // afterwards. By running one goroutine at a time, we can take // advantage of runnext to bounce back and forth between // workers and this goroutine. In an overloaded application, // this can reduce GC start latency by prioritizing these // goroutines rather than waiting on the end of the run queue.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K bytes - Viewed (0) -
internal/http/server.go
if atomic.LoadInt32(&srv.requestCount) <= 0 { return nil } // Write all running goroutines. tmp, err := os.CreateTemp("", "minio-goroutines-*.txt") if err == nil { _ = pprof.Lookup("goroutine").WriteTo(tmp, 1) tmp.Close() return errors.New("timed out. some connections are still active. goroutines written to " + tmp.Name()) } return errors.New("timed out. some connections are still active")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Feb 09 21:25:16 UTC 2024 - 7.7K bytes - Viewed (0) -
src/runtime/HACKING.md
blocking the G directly since it consumes an M. To interact directly with the goroutine scheduler, use `gopark` and `goready`. `gopark` parks the current goroutine—putting it in the "waiting" state and removing it from the scheduler's run queue—and schedules another goroutine on the current M/P. `goready` puts a parked goroutine back in the "runnable" state and adds it to the run queue. In summary, <table>
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 13.9K bytes - Viewed (0) -
src/runtime/internal/wasitest/nonblock_test.go
// checks that the output order matches the write order. The test binary opens // the FIFOs in their original order and spawns a goroutine for each that reads // from the FIFO and writes the result to stderr. If I/O was blocking, all // goroutines would be blocked waiting for one read call to return, and the // output order wouldn't match. type fifo struct { file *os.File path string }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 29 15:35:27 UTC 2023 - 2.4K bytes - Viewed (0) -
src/runtime/netpoll_kqueue.go
// is closed the write end will not get a // _EVFILT_WRITE event, but will get a // _EVFILT_READ event with EV_EOF set. // Note that setting 'w' here just means that we // will wake up a goroutine waiting to write; // that goroutine will try the write again, // and the appropriate thing will happen based // on what that write returns (success, EPIPE, EAGAIN). if ev.flags&_EV_EOF != 0 { mode += 'w' }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 12 21:17:22 UTC 2024 - 4.6K bytes - Viewed (0) -
src/runtime/stack.go
// this goroutine has to wait for the GC to finish before continuing. // If the GC is in some way dependent on this goroutine (for example, // it needs a lock held by the goroutine), that small preemption turns // into a real deadlock. preempt := stackguard0 == stackPreempt if preempt { if !canPreemptM(thisg.m) { // Let the goroutine keep running for now.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 41.1K bytes - Viewed (0) -
src/runtime/pprof/pprof.go
// or network connections. // // A Profile's methods can be called from multiple goroutines simultaneously. // // Each Profile has a unique name. A few profiles are predefined: // // goroutine - stack traces of all current goroutines // heap - a sampling of memory allocations of live objects // allocs - a sampling of all past memory allocations
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:52:17 UTC 2024 - 30.6K bytes - Viewed (0) -
src/runtime/stubs.go
// //go:linkname procyield func procyield(cycles uint32) type neverCallThisFunction struct{} // goexit is the return stub at the top of every goroutine call stack. // Each goroutine stack is constructed as if goexit called the // goroutine's entry point function, so that when the entry point // function returns, it will return to goexit, which will call goexit1 // to perform the actual exit. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 20.2K bytes - Viewed (0)