mirror/prysm-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/prysm-pulse.git synced 2025-01-03 00:27:38 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

sharding: Cleaning up (#92)

Browse Source 
Former-commit-id: be930e31eea223934f0fa9aea28e306817746bc1 [formerly e8988d068f485c08bd3b30b6c53a39ce60864ac6]
Former-commit-id: 6d2dbb09d7fb965ee202c9834526f28a0be58ae8
This commit is contained in:
nisdas 2018-05-16 01:12:58 +08:00
parent 48977ba2f4
commit 97785d2322
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
sharding/collation.go
View File

@ -94,9 +94,9 @@ func (c *Collation) Body() []byte { return c.body }
// Transactions returns an array of tx's in the collation.
var (
collationsizelimit = int64(math.Pow(float64(2), float64(20)))
collationSizelimit = int64(math.Pow(float64(2), float64(20)))
chunkSize = int64(32)
numberOfChunks = collationsizelimit / chunkSize
numberOfChunks = collationSizelimit / chunkSize
)
// Transactions returns an array of tx's in the collation.
@ -159,30 +159,31 @@ func (c *Collation) Serialize() ([]byte, error) {
return nil, fmt.Errorf("%v", err)
}
serializedtx, err := utils.Serialize(blobs)
serializedTx, err := utils.Serialize(blobs)
if err != nil {
return nil, fmt.Errorf("%v", err)
}
if int64(len(serializedtx)) > collationsizelimit {
serializedtx = serializedtx[0:collationsizelimit]
if int64(len(serializedTx)) > collationSizelimit {
return nil, fmt.Errorf("The serialized body exceeded the collation size limit", serializedTx)
}
return serializedtx, nil
return serializedTx, nil
}
// Deserialize takes a byte array and converts its back to its original transactions.
func (c *Collation) Deserialize(serialisedblob []byte) error {
func (c *Collation) Deserialize(serialisedBlob []byte) error {
deserializedblobs, err := utils.Deserialize(serialisedblob)
deserializedBlobs, err := utils.Deserialize(serialisedBlob)
if err != nil {
return fmt.Errorf("%v", err)
}
err = c.ConvertBacktoTx(deserializedblobs)
err = c.ConvertBacktoTx(deserializedBlobs)
if err != nil {
return fmt.Errorf("%v", err)