- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 210 for gstates (0.21 sec)
-
src/cmd/trace/goroutinegen.go
gs := g.gStates[r.Scope.Goroutine()] gs.rangeEnd(ev.Time(), r.Name, ev.Stack(), ctx) } } func (g *goroutineGenerator) GoroutineTransition(ctx *traceContext, ev *trace.Event) { st := ev.StateTransition() goID := st.Resource.Goroutine() // If we haven't seen this goroutine before, create a new // gState for it. gs, ok := g.gStates[goID] if !ok { gs = newGState[trace.GoID](goID) g.gStates[goID] = gs }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 4.6K bytes - Viewed (0) -
src/cmd/trace/procgen.go
logEventGenerator[trace.ProcID] gStates map[trace.GoID]*gState[trace.ProcID] inSyscall map[trace.ProcID]*gState[trace.ProcID] maxProc trace.ProcID } func newProcGenerator() *procGenerator { pg := new(procGenerator) rg := func(ev *trace.Event) trace.ProcID { return ev.Proc() } pg.stackSampleGenerator.getResource = rg pg.logEventGenerator.getResource = rg pg.gStates = make(map[trace.GoID]*gState[trace.ProcID])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 6.1K bytes - Viewed (0) -
src/cmd/trace/threadgen.go
logEventGenerator[trace.ThreadID] gStates map[trace.GoID]*gState[trace.ThreadID] threads map[trace.ThreadID]struct{} } func newThreadGenerator() *threadGenerator { tg := new(threadGenerator) rg := func(ev *trace.Event) trace.ThreadID { return ev.Thread() } tg.stackSampleGenerator.getResource = rg tg.logEventGenerator.getResource = rg tg.gStates = make(map[trace.GoID]*gState[trace.ThreadID])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 5.7K bytes - Viewed (0) -
src/internal/trace/order.go
} oldState := go122GoStatus2GoState[status] if s, ok := o.gStates[gid]; ok { if s.status != status { return curCtx, false, fmt.Errorf("inconsistent status for goroutine %d: old %v vs. new %v", gid, s.status, status) } s.seq = makeSeq(gen, 0) // Reset seq. } else if gen == o.initialGen { // Set the state.
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/internal/trace/reader.go
return &Reader{ go121Events: convertOldFormat(tr), }, nil case version.Go122, version.Go123: return &Reader{ r: br, order: ordering{ mStates: make(map[ThreadID]*mState), pStates: make(map[ProcID]*pState), gStates: make(map[GoID]*gState), activeTasks: make(map[TaskID]taskState), }, // Don't emit a sync event when we first go to emit events. emittedSync: true, }, nil default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 6.7K bytes - Viewed (0) -
src/cmd/trace/gstate.go
// further events will be processed. This method may leave the gState in // an inconsistent state. func (gs *gState[R]) finish(ctx *traceContext) { if gs.executing != R(noResource) { gs.syscallEnd(ctx.endTime, false, ctx) gs.stop(ctx.endTime, trace.NoStack, ctx) } } // rangeBegin indicates the start of a special range of time. func (gs *gState[R]) rangeBegin(ts trace.Time, name string, stack trace.Stack) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.9K bytes - Viewed (0) -
src/internal/trace/internal/oldtrace/order.go
next = gState{noseq, gRunnable} return case EvGoUnblock, EvGoSysExit: g = ev.Args[0] init = gState{ev.Args[1], gWaiting} next = gState{ev.Args[1] + 1, gRunnable} return case EvGoUnblockLocal, EvGoSysExitLocal: g = ev.Args[0] init = gState{noseq, gWaiting} next = gState{seqinc, gRunnable} return case EvGCStart: g = garbage init = gState{ev.Args[0], gDead} next = gState{ev.Args[0] + 1, gDead}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 4K bytes - Viewed (0) -
src/internal/trace/resources.go
func (d StateTransition) Goroutine() (from, to GoState) { if d.Resource.Kind != ResourceGoroutine { panic("Goroutine called on non-Goroutine state transition") } return GoState(d.oldState), GoState(d.newState) } // Proc returns the state transition for a proc. // // Transitions to and from states that are Executing are special in that
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 8K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/DaemonLogFileStateProbe.groovy
return context } State getCurrentState() { getStates().last() } List<State> getStates() { def states = new LinkedList<State>() states << Idle log.lines().withCloseable { stream -> stream.forEach { if (it.contains(startBuildMessage)) { states << Busy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 15:22:16 UTC 2024 - 2.6K bytes - Viewed (0) -
src/internal/trace/testdata/tests/go122-syscall-steal-proc-reacquire-new-proc.test
SUCCESS -- trace -- Trace Go1.22 EventBatch gen=1 m=0 time=0 size=23 ProcStatus dt=1 p=1 pstatus=2 ProcStatus dt=1 p=0 pstatus=1 GoStatus dt=1 g=1 m=0 gstatus=2 GoSyscallBegin dt=1 p_seq=1 stack=0 ProcStart dt=1 p=1 p_seq=1 GoSyscallEndBlocked dt=1 EventBatch gen=1 m=1 time=0 size=14 ProcStatus dt=1 p=2 pstatus=1 GoStatus dt=1 g=2 m=1 gstatus=2 ProcSteal dt=1 p=0 p_seq=2 m=0 EventBatch gen=1 m=18446744073709551615 time=0 size=5
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 592 bytes - Viewed (0)