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

sharding/client: Fixing deserializeblobs(#92)

Browse Source 
Former-commit-id: 956c46610107382fbf8d6447f10d47290afbeb79 [formerly 3387c9666b09f695bcde26cc236df3db03c453fa]
Former-commit-id: 4cc2bc2ac8ab198eb7fb99c773fa34d09b8b9acf
This commit is contained in:
nisdas 2018-05-02 15:46:46 +08:00
parent e88c1343d4
commit 256078b48e
1 changed files with 18 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
sharding/client/utils.go
View File

@ -15,7 +15,7 @@ var (
totalDatasize = numberOfChunks * chunkDataSize
)
type collationbody []byte
type txblob []byte
type body interface {
length() int64
@ -23,7 +23,7 @@ type body interface {
serializeBlob() []byte
}
func (cb collationbody) length() int64 {
func (cb txblob) length() int64 {
return int64(len(cb))
}
@ -32,7 +32,7 @@ func (cb collationbody) length() int64 {
the size of the body is below the limit it is simply appended
till it reaches the required limit */
func (cb collationbody) validateBody() error {
func (cb txblob) validateBody() error {
if cb.length() == 0 {
return fmt.Errorf("Collation Body has to be a non-zero value")
@ -45,27 +45,36 @@ func (cb collationbody) validateBody() error {
return nil
}
func deserializeBlob(blob body) []byte {
deserializedblob := blob.(collationbody)
length := deserializedblob.length()
func deserializebody(collationbody []byte) []body {
length := int64(len(collationbody))
chunksNumber := chunkSize / length
indicatorByte := make([]byte, 1)
indicatorByte[0] = 0
tempbody := []byte{0}
txblobs := []body{}
var tempbody txblob
for i := int64(1); i <= chunksNumber; i++ {
if reflect.TypeOf(deserializedblob[:(i-1)*chunksNumber]) == reflect.TypeOf(indicatorByte) {
if reflect.TypeOf(collationbody[(i-1)*chunkSize]) == reflect.TypeOf(indicatorByte) {
tempbody = append(tempbody, collationbody[((i-1)*chunkSize+1):(i)*chunkSize]...)
} else {
terminalIndex := int64(collationbody[(i-1)*chunkSize])
tempbody = append(tempbody, collationbody[((i-1)*chunkSize+1):((i-1)*chunkSize+2+terminalIndex)]...)
txblobs = append(txblobs, tempbody)
tempbody = txblob{}
}
}
return txblobs
}
// Parse Collation body and modify it accordingly
func (cb collationbody) serializeBlob() []byte {
func (cb txblob) serializeBlob() []byte {
terminalLength := cb.length() % chunkDataSize
chunksNumber := cb.length() / chunkDataSize