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/client: Adding deserialize blobs(#92)

Browse Source 
Former-commit-id: f11427ff5b305c1f9ebb30b2436e75b5ff9a9dc9 [formerly 3def7d93a525e3bb8348de8fb24ad9d828580860]
Former-commit-id: 6dc530e57dc5a35ee50564ecc082d035f6ceead1
This commit is contained in:
nisdas 2018-05-02 13:00:37 +08:00
parent 92c44d455f
commit e88c1343d4
1 changed files with 22 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
sharding/client/utils.go
View File

@ -3,6 +3,7 @@ package client
import (
"fmt"
"math"
"reflect"
)
var (
@ -18,8 +19,8 @@ type collationbody []byte
type body interface {
length() int64
validateblob() error
ParseBlob()
validateBody() error
serializeBlob() []byte
}
func (cb collationbody) length() int64 {
@ -44,6 +45,24 @@ func (cb collationbody) validateBody() error {
return nil
}
func deserializeBlob(blob body) []byte {
deserializedblob := blob.(collationbody)
length := deserializedblob.length()
chunksNumber := chunkSize / length
indicatorByte := make([]byte, 1)
indicatorByte[0] = 0
tempbody := []byte{0}
for i := int64(1); i <= chunksNumber; i++ {
if reflect.TypeOf(deserializedblob[:(i-1)*chunksNumber]) == reflect.TypeOf(indicatorByte) {
}
}
}
// Parse Collation body and modify it accordingly
func (cb collationbody) serializeBlob() []byte {
@ -52,7 +71,7 @@ func (cb collationbody) serializeBlob() []byte {
chunksNumber := cb.length() / chunkDataSize
indicatorByte := make([]byte, 1)
indicatorByte[0] = 0
var tempbody []byte
tempbody := []byte{}
// if blob is less than 31 bytes, it adds the indicator chunk and pads the remaining empty bytes to the right