cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

Mempool: reduce size of sigValCache

Browse Source
This commit is contained in:
Aayush Rajasekaran 2021-09-08 12:21:36 -04:00
parent d1d8845ab2
commit aef741ae19
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
chain/messagepool/messagepool.go
View File

@ -11,6 +11,10 @@ import (
"sync" "sync"
"time" "time"
ffi "github.com/filecoin-project/filecoin-ffi"
"github.com/minio/blake2b-simd"
"github.com/filecoin-project/go-state-types/abi" "github.com/filecoin-project/go-state-types/abi"
"github.com/filecoin-project/go-state-types/big" "github.com/filecoin-project/go-state-types/big"
"github.com/filecoin-project/go-state-types/crypto" "github.com/filecoin-project/go-state-types/crypto"
@ -751,11 +755,13 @@ func (mp *MessagePool) Add(ctx context.Context, m *types.SignedMessage) error {
func sigCacheKey(m *types.SignedMessage) (string, error) { func sigCacheKey(m *types.SignedMessage) (string, error) {
switch m.Signature.Type { switch m.Signature.Type {
case crypto.SigTypeBLS: case crypto.SigTypeBLS:
if len(m.Signature.Data) < 90 { if len(m.Signature.Data) != ffi.SignatureBytes {
return "", fmt.Errorf("bls signature too short") return "", fmt.Errorf("bls signature incorrectly sized")
} }
return string(m.Cid().Bytes()) + string(m.Signature.Data[64:]), nil hashCache := blake2b.Sum256(append(m.Cid().Bytes(), m.Signature.Data...))
return string(hashCache[:]), nil
case crypto.SigTypeSecp256k1: case crypto.SigTypeSecp256k1:
return string(m.Cid().Bytes()), nil return string(m.Cid().Bytes()), nil
default: default: