Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 470 for gStates (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
  4. src/internal/trace/traceviewer/emitter.go

    func (e *Emitter) GoroutineTransition(ts time.Duration, from, to GState) {
    	e.gstates[from]--
    	e.gstates[to]++
    	if e.prevGstates == e.gstates {
    		return
    	}
    	if e.tsWithinRange(ts) {
    		e.OptionalEvent(&format.Event{
    			Name:  "Goroutines",
    			Phase: "C",
    			Time:  viewerTime(ts),
    			PID:   1,
    			Arg: &format.GoroutineCountersArg{
    				Running:   uint64(e.gstates[GRunning]),
    				Runnable:  uint64(e.gstates[GRunnable]),
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 21 21:29:58 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  5. src/internal/trace/order.go

    // add completed events to the ordering. Next is used to pick
    // off events in the ordering.
    type ordering struct {
    	gStates     map[GoID]*gState
    	pStates     map[ProcID]*pState // TODO: The keys are dense, so this can be a slice.
    	mStates     map[ThreadID]*mState
    	activeTasks map[TaskID]taskState
    	gcSeq       uint64
    	gcState     gcState
    	initialGen  uint64
    	queue       queue[Event]
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 03 14:56:25 UTC 2024
    - 52.4K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. src/internal/trace/internal/oldtrace/order.go

    		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}
    		return
    	default:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 4K bytes
    - Viewed (0)
  9. test/escape_mutations.go

    package p
    
    import "fmt"
    
    type B struct {
    	x  int
    	px *int
    	pb *B
    }
    
    func F1(b *B) { // ERROR "mutates param: b derefs=0"
    	b.x = 1
    }
    
    func F2(b *B) { // ERROR "mutates param: b derefs=1"
    	*b.px = 1
    }
    
    func F2a(b *B) { // ERROR "mutates param: b derefs=0"
    	b.px = nil
    }
    
    func F3(b *B) { // ERROR "leaking param: b"
    	fmt.Println(b) // ERROR "\.\.\. argument does not escape"
    }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Aug 18 11:58:37 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  10. pilot/pkg/request/command_test.go

    			if err := util.Compare(body, p.States[0].wantBody); err == nil {
    				w.WriteHeader(p.States[0].StatusCode)
    				w.Write([]byte(p.States[0].Response))
    			} else {
    				w.WriteHeader(http.StatusBadRequest)
    				w.Write([]byte(fmt.Sprintf("wanted body %q got %q", string(p.States[0].wantBody), string(body))))
    			}
    		} else {
    			w.WriteHeader(http.StatusBadRequest)
    			w.Write([]byte(fmt.Sprintf("wanted path %q got %q", p.States[0].wantPath, r.URL.Path)))
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Dec 11 19:11:01 UTC 2023
    - 4.1K bytes
    - Viewed (0)
Back to top