.

go/internal/xtesting/xtesting.go

@@ -177,7 +177,7 @@ func LoadDB(zurl string) (_ []Txn, err error) {
 			}
 			return nil, err
 		}
-		txn := &Txn{Header: &zodb.TxnInfo{
+		txn := Txn{Header: &zodb.TxnInfo{
 			// clone (txni stays valid only until next iteration)
 			Tid:         txni.Tid,
 			Status:      txni.Status,
@@ -203,6 +203,8 @@ func LoadDB(zurl string) (_ []Txn, err error) {
 				DataTidHint: datai.DataTidHint,
 			})
 		}
+
+		txnv = append(txnv, txn)
 	}
 
 	return txnv, nil

go/zodb/storage/zeo/zeo.go

@@ -52,6 +52,7 @@ type zeo struct {
 }
 
 
+// Sync implements zodb.IStorageDriver.
 func (z *zeo) Sync(ctx context.Context) (head zodb.Tid, err error) {
 	defer func() {
 		if err != nil {
@@ -73,6 +74,7 @@ func (z *zeo) Sync(ctx context.Context) (head zodb.Tid, err error) {
 	return head, nil
 }
 
+// Load implements zodb.IStorageDriver.
 func (z *zeo) Load(ctx context.Context, xid zodb.Xid) (*mem.Buf, zodb.Tid, error) {
 	// defer func() ...
 	buf, serial, err := z._Load(ctx, xid)
@@ -106,6 +108,7 @@ func (z *zeo) _Load(ctx context.Context, xid zodb.Xid) (*mem.Buf, zodb.Tid, erro
 	return &mem.Buf{Data: mem.Bytes(data)}, serial, nil
 }
 
+// Iterates implements zodb.IStorageDriver.
 func (z *zeo) Iterate(ctx context.Context, tidMin, tidMax zodb.Tid) zodb.ITxnIterator {
 	panic("TODO")
 }

go/zodb/storage/zeo/zrpc.go

@@ -141,7 +141,6 @@ func (zl *zLink) serveRecv() {
 
 // serveRecv1 handles 1 incoming packet.
 func (zl *zLink) serveRecv1(pkb *pktBuf) error {
-	fmt.Printf("RXgo: %q\n", pkb.Payload())
 	// decode packet
 	m, err := zl.pktDecode(pkb)
 	if err != nil {