986f240d91
Also explicitly limit how many bytes we're willing to read in one go such that we're capable of reading a worst-case tipset (like, really, never going to happen worst-case). Previously, this wasn't an issue. However, we've bumped the max number of messages from 8,192 to 150,000 and need to limit allocations somewhere else.
139 lines
3.0 KiB
Go
139 lines
3.0 KiB
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
|
|
gen "github.com/whyrusleeping/cbor-gen"
|
|
|
|
"github.com/filecoin-project/lotus/api"
|
|
"github.com/filecoin-project/lotus/blockstore"
|
|
"github.com/filecoin-project/lotus/chain/exchange"
|
|
"github.com/filecoin-project/lotus/chain/market"
|
|
"github.com/filecoin-project/lotus/chain/types"
|
|
"github.com/filecoin-project/lotus/cmd/lotus-shed/shedgen"
|
|
"github.com/filecoin-project/lotus/node/hello"
|
|
"github.com/filecoin-project/lotus/paychmgr"
|
|
sectorstorage "github.com/filecoin-project/lotus/storage/sealer"
|
|
"github.com/filecoin-project/lotus/storage/sealer/storiface"
|
|
)
|
|
|
|
func main() {
|
|
err := gen.WriteTupleEncodersToFile("./chain/types/cbor_gen.go", "types",
|
|
types.BlockHeader{},
|
|
types.Ticket{},
|
|
types.ElectionProof{},
|
|
types.Message{},
|
|
types.SignedMessage{},
|
|
types.MsgMeta{},
|
|
types.ActorV4{},
|
|
types.ActorV5{},
|
|
// types.MessageReceipt{}, // Custom serde to deal with versioning.
|
|
types.BlockMsg{},
|
|
types.ExpTipSet{},
|
|
types.BeaconEntry{},
|
|
types.StateRoot{},
|
|
types.StateInfo0{},
|
|
types.Event{},
|
|
types.EventEntry{},
|
|
// Tracing
|
|
types.GasTrace{},
|
|
types.MessageTrace{},
|
|
types.ReturnTrace{},
|
|
types.ExecutionTrace{},
|
|
)
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
os.Exit(1)
|
|
}
|
|
|
|
err = gen.WriteMapEncodersToFile("./paychmgr/cbor_gen.go", "paychmgr",
|
|
paychmgr.VoucherInfo{},
|
|
paychmgr.ChannelInfo{},
|
|
paychmgr.MsgInfo{},
|
|
)
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
os.Exit(1)
|
|
}
|
|
|
|
err = gen.WriteMapEncodersToFile("./api/cbor_gen.go", "api",
|
|
api.PaymentInfo{},
|
|
api.SealedRef{},
|
|
api.SealedRefs{},
|
|
api.SealTicket{},
|
|
api.SealSeed{},
|
|
api.PieceDealInfo{},
|
|
api.SectorPiece{},
|
|
api.DealSchedule{},
|
|
)
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
os.Exit(1)
|
|
}
|
|
|
|
err = gen.WriteTupleEncodersToFile("./node/hello/cbor_gen.go", "hello",
|
|
hello.HelloMessage{},
|
|
hello.LatencyMessage{},
|
|
)
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
os.Exit(1)
|
|
}
|
|
|
|
err = gen.WriteTupleEncodersToFile("./chain/market/cbor_gen.go", "market",
|
|
market.FundedAddressState{},
|
|
)
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
os.Exit(1)
|
|
}
|
|
|
|
err = gen.WriteTupleEncodersToFile("./chain/exchange/cbor_gen.go", "exchange",
|
|
exchange.Request{},
|
|
exchange.Response{},
|
|
exchange.CompactedMessagesCBOR{},
|
|
exchange.BSTipSet{},
|
|
)
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
os.Exit(1)
|
|
}
|
|
|
|
err = gen.WriteMapEncodersToFile("./storage/sealer/storiface/cbor_gen.go", "storiface",
|
|
storiface.CallID{},
|
|
storiface.SecDataHttpHeader{},
|
|
storiface.SectorLocation{},
|
|
)
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
os.Exit(1)
|
|
}
|
|
|
|
err = gen.WriteMapEncodersToFile("./storage/sealer/cbor_gen.go", "sealer",
|
|
sectorstorage.Call{},
|
|
sectorstorage.WorkState{},
|
|
sectorstorage.WorkID{},
|
|
)
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
os.Exit(1)
|
|
}
|
|
err = gen.WriteMapEncodersToFile("./cmd/lotus-shed/shedgen/cbor_gen.go", "shedgen",
|
|
shedgen.CarbNode{},
|
|
)
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
os.Exit(1)
|
|
}
|
|
err = gen.WriteTupleEncodersToFile("./blockstore/cbor_gen.go", "blockstore",
|
|
blockstore.NetRpcReq{},
|
|
blockstore.NetRpcResp{},
|
|
blockstore.NetRpcErr{},
|
|
)
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
os.Exit(1)
|
|
}
|
|
}
|