Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 24 of 24 for EventBatch (0.3 sec)

  1. src/internal/trace/batchcursor.go

    // but it does validate that the event is a regular
    // event with a timestamp (vs. a structural event).
    //
    // It requires that the event its reading be timed, which must
    // be the case for every event in a plain EventBatch.
    func readTimedBaseEvent(b []byte, e *baseEvent) (int, timestamp, error) {
    	// Get the event type.
    	typ := event.Type(b[0])
    	specs := go122.Specs()
    	if int(typ) >= len(specs) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  2. src/cmd/trace/testdata/go122.test

    Trace Go1.22
    EventBatch gen=1 m=18446744073709551615 time=7689672466239 size=5
    Frequency freq=15625000
    EventBatch gen=1 m=1709048 time=7689670869319 size=423
    ProcStart dt=409 p=7 p_seq=1
    GoStart dt=31 g=34 g_seq=1
    GoStop dt=291990 reason_string=16 stack=50
    GoStart dt=21 g=34 g_seq=2
    GoStop dt=315853 reason_string=16 stack=50
    GoStart dt=30 g=34 g_seq=3
    GoUnblock dt=173432 g=1 g_seq=73 stack=52
    GoDestroy dt=96
    GoStart dt=22 g=1 g_seq=74
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 17:15:58 UTC 2024
    - 166K bytes
    - Viewed (0)
  3. src/internal/trace/event/go122/event.go

    	}
    	return fmt.Sprintf("Invalid(%d)", typ)
    }
    
    func Specs() []event.Spec {
    	return specs[:]
    }
    
    var specs = [...]event.Spec{
    	// "Structural" Events.
    	EvEventBatch: event.Spec{
    		Name: "EventBatch",
    		Args: []string{"gen", "m", "time", "size"},
    	},
    	EvStacks: event.Spec{
    		Name: "Stacks",
    	},
    	EvStack: event.Spec{
    		Name:    "Stack",
    		Args:    []string{"id", "nframes"},
    		IsStack: true,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  4. pkg/volume/util/recyclerclient/recycler_client.go

    	var wg sync.WaitGroup
    	wg.Add(2)
    
    	go func() {
    		defer close(eventCh)
    		wg.Wait()
    	}()
    
    	go func() {
    		defer eventWatch.Stop()
    		defer wg.Done()
    		for {
    			select {
    			case <-stopChannel:
    				return
    			case eventEvent, ok := <-eventWatch.ResultChan():
    				if !ok {
    					return
    				}
    				eventCh <- eventEvent
    			}
    		}
    	}()
    
    	go func() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 8.5K bytes
    - Viewed (1)
Back to top