groot: streamline serialization header extraction

groot/cmd/root-gen-type/testdata/rvec.txt

@@ -3,7 +3,6 @@
 package main
 
 import (
-	"fmt"
 	"reflect"
 
 	"go-hep.org/x/hep/groot/rbase"
@@ -45,13 +44,7 @@ func (o *ROOT__VecOps__RVec_float_) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(o.Class())
-	if hdr.Vers > o.RVersion() {
-		panic(fmt.Errorf(
-			"rbytes: invalid %s version=%d > %d",
-			o.Class(), hdr.Vers, o.RVersion(),
-		))
-	}
+	hdr := r.ReadHeader(o.Class(), o.RVersion())
 
 	r.ReadStdVectorF32(&o.This)
 
@@ -124,13 +117,7 @@ func (o *ROOT__VecOps__RVec_int_) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(o.Class())
-	if hdr.Vers > o.RVersion() {
-		panic(fmt.Errorf(
-			"rbytes: invalid %s version=%d > %d",
-			o.Class(), hdr.Vers, o.RVersion(),
-		))
-	}
+	hdr := r.ReadHeader(o.Class(), o.RVersion())
 
 	r.ReadStdVectorI32(&o.This)
 

groot/cmd/root-gen-type/testdata/small-evnt-tree-fullsplit.txt

@@ -3,7 +3,6 @@
 package main
 
 import (
-	"fmt"
 	"reflect"
 
 	"go-hep.org/x/hep/groot/rbase"
@@ -129,13 +128,7 @@ func (o *Event) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(o.Class())
-	if hdr.Vers > o.RVersion() {
-		panic(fmt.Errorf(
-			"rbytes: invalid %s version=%d > %d",
-			o.Class(), hdr.Vers, o.RVersion(),
-		))
-	}
+	hdr := r.ReadHeader(o.Class(), o.RVersion())
 
 	o.Beg = r.ReadString()
 	o.I16 = r.ReadI16()
@@ -760,13 +753,7 @@ func (o *P3) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(o.Class())
-	if hdr.Vers > o.RVersion() {
-		panic(fmt.Errorf(
-			"rbytes: invalid %s version=%d > %d",
-			o.Class(), hdr.Vers, o.RVersion(),
-		))
-	}
+	hdr := r.ReadHeader(o.Class(), o.RVersion())
 
 	o.Px = r.ReadI32()
 	o.Py = r.ReadF64()

groot/cmd/root-gen-type/testdata/streamers.txt

@@ -3,7 +3,6 @@
 package main
 
 import (
-	"fmt"
 	"reflect"
 
 	"go-hep.org/x/hep/groot/rbase"
@@ -147,13 +146,7 @@ func (o *Event) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(o.Class())
-	if hdr.Vers > o.RVersion() {
-		panic(fmt.Errorf(
-			"rbytes: invalid %s version=%d > %d",
-			o.Class(), hdr.Vers, o.RVersion(),
-		))
-	}
+	hdr := r.ReadHeader(o.Class(), o.RVersion())
 
 	o.Beg = r.ReadString()
 	o.I16 = r.ReadI16()
@@ -890,13 +883,7 @@ func (o *P3) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(o.Class())
-	if hdr.Vers > o.RVersion() {
-		panic(fmt.Errorf(
-			"rbytes: invalid %s version=%d > %d",
-			o.Class(), hdr.Vers, o.RVersion(),
-		))
-	}
+	hdr := r.ReadHeader(o.Class(), o.RVersion())
 
 	o.Px = r.ReadI32()
 	o.Py = r.ReadF64()

groot/cmd/root-gen-type/testdata/tbase.txt

@@ -3,7 +3,6 @@
 package main
 
 import (
-	"fmt"
 	"reflect"
 
 	"go-hep.org/x/hep/groot/rbase"
@@ -47,13 +46,7 @@ func (o *D1) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(o.Class())
-	if hdr.Vers > o.RVersion() {
-		panic(fmt.Errorf(
-			"rbytes: invalid %s version=%d > %d",
-			o.Class(), hdr.Vers, o.RVersion(),
-		))
-	}
+	hdr := r.ReadHeader(o.Class(), o.RVersion())
 
 	r.ReadObject(&o.base0)
 	o.D32 = r.ReadI32()
@@ -140,13 +133,7 @@ func (o *Base) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(o.Class())
-	if hdr.Vers > o.RVersion() {
-		panic(fmt.Errorf(
-			"rbytes: invalid %s version=%d > %d",
-			o.Class(), hdr.Vers, o.RVersion(),
-		))
-	}
+	hdr := r.ReadHeader(o.Class(), o.RVersion())
 
 	o.I32 = r.ReadI32()
 
@@ -221,13 +208,7 @@ func (o *D2) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(o.Class())
-	if hdr.Vers > o.RVersion() {
-		panic(fmt.Errorf(
-			"rbytes: invalid %s version=%d > %d",
-			o.Class(), hdr.Vers, o.RVersion(),
-		))
-	}
+	hdr := r.ReadHeader(o.Class(), o.RVersion())
 
 	r.ReadObject(&o.base0)
 	o.I32 = r.ReadI32()

groot/exp/rntup/rntup.go

@@ -35,7 +35,7 @@ func (*NTuple) Class() string {
 }
 
 func (*NTuple) RVersion() int16 {
-	return 0 // FIXME(sbinet): generate through gen.rboot
+	return 1 // FIXME(sbinet): generate through gen.rboot
 }
 
 func (nt *NTuple) String() string {
@@ -72,7 +72,7 @@ func (nt *NTuple) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(nt.Class())
+	hdr := r.ReadHeader(nt.Class(), nt.RVersion())
 
 	nt.rvers = r.ReadU32()
 	nt.size = r.ReadU32()

groot/gen.rbytes.go

@@ -164,7 +164,7 @@ func (r *RBuffer) ReadStdVector{{.Name}}(sli *[]{{.Type}}) {
 		return
 	}
 
-	hdr := r.ReadHeader("vector<{{.Type}}>")
+	hdr := r.ReadHeader("vector<{{.Type}}>", rvers.StreamerInfo)
 	if hdr.Vers != rvers.StreamerInfo {
 		r.err = fmt.Errorf(
 			"rbytes: invalid %s version: got=%d, want=%d",

groot/gen.rhist.go

@@ -220,10 +220,7 @@ func (h *{{.Name}}) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(h.Class())
-	if hdr.Vers > rvers.{{.Name}} {
-		panic(fmt.Errorf("rhist: invalid {{.Name}} version=%d > %d", hdr.Vers, rvers.{{.Name}}))
-	}
+	hdr := r.ReadHeader(h.Class(), h.RVersion())
 
 	r.ReadObject(&h.th1)
 	r.ReadObject(&h.arr)
@@ -777,10 +774,7 @@ func (h *{{.Name}}) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(h.Class())
-	if hdr.Vers > rvers.{{.Name}} {
-		panic(fmt.Errorf("rhist: invalid {{.Name}} version=%d > %d", hdr.Vers, rvers.{{.Name}}))
-	}
+	hdr := r.ReadHeader(h.Class(), h.RVersion())
 	if hdr.Vers < 1 {
 		return fmt.Errorf("rhist: T{{.Name}} version too old (%d<1)", hdr.Vers)
 	}

groot/gen.rtree.go

@@ -372,11 +372,7 @@ func (leaf *{{.Name}}) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(leaf.Class())
-	if hdr.Vers > rvers.{{.Name}} {
-		panic(fmt.Errorf("rtree: invalid T{{.Name}} version=%d > %d", hdr.Vers, rvers.{{.Name}}))
-	}
-
+	hdr := r.ReadHeader(leaf.Class(), leaf.RVersion())
 	leaf.rvers = hdr.Vers
 
 	r.ReadObject(&leaf.tleaf)

groot/rbase/attaxis.go

@@ -5,7 +5,6 @@
 package rbase
 
 import (
-	"fmt"
 	"reflect"
 
 	"go-hep.org/x/hep/groot/rbytes"
@@ -78,11 +77,7 @@ func (a *AttAxis) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(a.Class())
-	if hdr.Vers < 4 {
-		return fmt.Errorf("rbase: TAttAxis version too old (%d < 4)", hdr.Vers)
-	}
-
+	hdr := r.ReadHeader(a.Class(), a.RVersion())
 	a.Ndivs = r.ReadI32()
 	a.AxisColor = r.ReadI16()
 	a.LabelColor = r.ReadI16()

groot/rbase/attfill.go

@@ -49,7 +49,7 @@ func (a *AttFill) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(a.Class())
+	hdr := r.ReadHeader(a.Class(), a.RVersion())
 
 	a.Color = r.ReadI16()
 	a.Style = r.ReadI16()

groot/rbase/attline.go

@@ -5,7 +5,6 @@
 package rbase
 
 import (
-	"fmt"
 	"reflect"
 
 	"go-hep.org/x/hep/groot/rbytes"
@@ -54,10 +53,7 @@ func (a *AttLine) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(a.Class())
-	if hdr.Vers > rvers.AttLine {
-		panic(fmt.Errorf("rbase: invalid attline version=%d > %d", hdr.Vers, rvers.AttLine))
-	}
+	hdr := r.ReadHeader(a.Class(), a.RVersion())
 
 	a.Color = r.ReadI16()
 	a.Style = r.ReadI16()

groot/rbase/attmarker.go

@@ -5,7 +5,6 @@
 package rbase
 
 import (
-	"fmt"
 	"reflect"
 
 	"go-hep.org/x/hep/groot/rbytes"
@@ -53,10 +52,7 @@ func (a *AttMarker) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(a.Class())
-	if hdr.Vers > rvers.AttMarker {
-		panic(fmt.Errorf("rbase: invalid attmarker version=%d > %d", hdr.Vers, rvers.AttMarker))
-	}
+	hdr := r.ReadHeader(a.Class(), a.RVersion())
 
 	a.Color = r.ReadI16()
 	a.Style = r.ReadI16()

groot/rbase/attpad.go

@@ -74,7 +74,7 @@ func (a *AttPad) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(a.Class())
+	hdr := r.ReadHeader(a.Class(), a.RVersion())
 	a.fLeftMargin = r.ReadF32()
 	a.fRightMargin = r.ReadF32()
 	a.fBottomMargin = r.ReadF32()

groot/rbase/named.go

@@ -5,7 +5,6 @@
 package rbase
 
 import (
-	"fmt"
 	"reflect"
 
 	"go-hep.org/x/hep/groot/rbytes"
@@ -76,10 +75,7 @@ func (n *Named) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(n.Class())
-	if hdr.Vers > rvers.Named {
-		panic(fmt.Errorf("rbase: invalid named version=%d > %d", hdr.Vers, rvers.Named))
-	}
+	hdr := r.ReadHeader(n.Class(), n.RVersion())
 
 	r.ReadObject(&n.obj)
 

groot/rbase/objstring.go

@@ -5,7 +5,6 @@
 package rbase
 
 import (
-	"fmt"
 	"reflect"
 
 	"go-hep.org/x/hep/groot/rbytes"
@@ -54,13 +53,7 @@ func (obj *ObjString) String() string {
 // ROOTUnmarshaler is the interface implemented by an object that can
 // unmarshal itself from a ROOT buffer
 func (obj *ObjString) UnmarshalROOT(r *rbytes.RBuffer) error {
-	hdr := r.ReadHeader(obj.Class())
-	if hdr.Vers > rvers.ObjString {
-		panic(fmt.Errorf(
-			"rbase: invalid %s version=%d > %d",
-			obj.Class(), hdr.Vers, rvers.ObjString,
-		))
-	}
+	hdr := r.ReadHeader(obj.Class(), obj.RVersion())
 	r.ReadObject(&obj.obj)
 	obj.str = r.ReadString()
 

groot/rbase/processid.go

@@ -55,10 +55,7 @@ func (pid *ProcessID) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(pid.Class())
-	if hdr.Vers > rvers.ProcessID {
-		panic(fmt.Errorf("rbase: invalid %s version=%d > %d", pid.Class(), hdr.Vers, rvers.ProcessID))
-	}
+	hdr := r.ReadHeader(pid.Class(), pid.RVersion())
 
 	r.ReadObject(&pid.named)
 

groot/rbase/vpad.go

@@ -5,7 +5,6 @@
 package rbase
 
 import (
-	"fmt"
 	"reflect"
 
 	"go-hep.org/x/hep/groot/rbytes"
@@ -35,10 +34,7 @@ func (vpad *VirtualPad) UnmarshalROOT(r *rbytes.RBuffer) error {
 		return r.Err()
 	}
 
-	hdr := r.ReadHeader(vpad.Class())
-	if hdr.Vers > rvers.VirtualPad {
-		panic(fmt.Errorf("rbase: invalid virtualpad version=%d > %d", hdr.Vers, rvers.VirtualPad))
-	}
+	hdr := r.ReadHeader(vpad.Class(), vpad.RVersion())
 
 	r.ReadObject(&vpad.obj)
 	r.ReadObject(&vpad.attline)