Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for ReadEvent (0.19 sec)

  1. src/internal/trace/testdata/cmd/gotraceraw/main.go

    		if err != nil {
    			log.Fatal(err)
    		}
    	}
    	for {
    		ev, err := tr.ReadEvent()
    		if err == io.EOF {
    			break
    		}
    		if err != nil {
    			log.Fatal(err)
    		}
    		if err := tw.WriteEvent(ev); err != nil {
    			log.Fatal(err)
    		}
    	}
    }
    
    type traceReader interface {
    	Version() version.Version
    	ReadEvent() (raw.Event, error)
    }
    
    type traceWriter interface {
    	WriteEvent(raw.Event) error
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 20:31:29 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  2. src/internal/trace/reader_test.go

    	// reject invalid traces.
    	const testGetters = false
    
    	f.Fuzz(func(t *testing.T, b []byte) {
    		r, err := trace.NewReader(bytes.NewReader(b))
    		if err != nil {
    			return
    		}
    		for {
    			ev, err := r.ReadEvent()
    			if err != nil {
    				break
    			}
    
    			if !testGetters {
    				continue
    			}
    			// Make sure getters don't do anything that panics
    			switch ev.Kind() {
    			case trace.EventLabel:
    				ev.Label()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. src/internal/trace/raw/reader.go

    }
    
    // Version returns the version of the trace that we're reading.
    func (r *Reader) Version() version.Version {
    	return r.v
    }
    
    // ReadEvent reads and returns the next trace event in the byte stream.
    func (r *Reader) ReadEvent() (Event, error) {
    	evb, err := r.r.ReadByte()
    	if err == io.EOF {
    		return Event{}, io.EOF
    	}
    	if err != nil {
    		return Event{}, err
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  4. src/internal/trace/testdata/cmd/gotracevalidate/main.go

    func main() {
    	flag.Parse()
    
    	r, err := trace.NewReader(os.Stdin)
    	if err != nil {
    		log.Fatal(err)
    	}
    	v := testtrace.NewValidator()
    	for {
    		ev, err := r.ReadEvent()
    		if err == io.EOF {
    			break
    		}
    		if err != nil {
    			log.Fatal(err)
    		}
    		if *logEvents {
    			log.Println(ev.String())
    		}
    		if err := v.Event(ev); err != nil {
    			log.Fatal(err)
    		}
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 20:31:29 UTC 2024
    - 984 bytes
    - Viewed (0)
  5. src/cmd/trace/testdata/mktests.go

    	defer f.Close()
    
    	// Write out the trace.
    	r, err := raw.NewReader(&trace)
    	if err != nil {
    		log.Fatalf("reading trace: %v", err)
    	}
    	w, err := raw.NewTextWriter(f, version.Current)
    	for {
    		ev, err := r.ReadEvent()
    		if err == io.EOF {
    			break
    		}
    		if err != nil {
    			log.Fatalf("reading trace: %v", err)
    		}
    		if err := w.WriteEvent(ev); err != nil {
    			log.Fatalf("writing trace: %v", err)
    		}
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  6. src/internal/trace/raw/textreader.go

    		}
    	}
    	return tr, nil
    }
    
    // Version returns the version of the trace that we're reading.
    func (r *TextReader) Version() version.Version {
    	return r.v
    }
    
    // ReadEvent reads and returns the next trace event in the text stream.
    func (r *TextReader) ReadEvent() (Event, error) {
    	line, err := r.nextLine()
    	if err != nil {
    		return Event{}, err
    	}
    	evStr, line := readToken(line)
    	ev, ok := r.names[evStr]
    	if !ok {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  7. src/cmd/trace/main.go

    	if err != nil {
    		return err
    	}
    	for {
    		ev, err := tr.ReadEvent()
    		if err == io.EOF {
    			return nil
    		} else if err != nil {
    			return err
    		}
    		fmt.Println(ev.String())
    	}
    }
    
    func debugRawEvents(trc io.Reader) error {
    	rr, err := raw.NewReader(trc)
    	if err != nil {
    		return err
    	}
    	for {
    		ev, err := rr.ReadEvent()
    		if err == io.EOF {
    			return nil
    		} else if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  8. src/internal/trace/oldtrace_test.go

    			defer f.Close()
    
    			tr, err := trace.NewReader(f)
    			if err != nil {
    				t.Fatalf("failed to create reader: %s", err)
    			}
    
    			v := testtrace.NewValidator()
    			v.Go121 = true
    			for {
    				ev, err := tr.ReadEvent()
    				if err != nil {
    					if err == io.EOF {
    						break
    					}
    					t.Fatalf("couldn't read converted event: %s", err)
    				}
    				if err := v.Event(ev); err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  9. src/internal/trace/testtrace/format.go

    	}
    	var buf bytes.Buffer
    	tw, err := raw.NewWriter(&buf, tr.Version())
    	if err != nil {
    		return nil, nil, fmt.Errorf("failed to create trace byte writer: %v", err)
    	}
    	for {
    		ev, err := tr.ReadEvent()
    		if err == io.EOF {
    			break
    		}
    		if err != nil {
    			return nil, nil, fmt.Errorf("malformed test %s: bad trace file: %v", testPath, err)
    		}
    		if err := tw.WriteEvent(ev); err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  10. src/internal/trace/testdata/cmd/gotraceeventstats/main.go

    	type eventStats struct {
    		typ   event.Type
    		count int
    		bytes int
    	}
    	var stats [256]eventStats
    	for i := range stats {
    		stats[i].typ = event.Type(i)
    	}
    	eventsRead := 0
    	for {
    		e, err := tr.ReadEvent()
    		if err == io.EOF {
    			break
    		}
    		if err != nil {
    			return err
    		}
    		s := &stats[e.Ev]
    		s.count++
    		s.bytes += encodedSize(&e)
    		eventsRead++
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 20:31:29 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top