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: Finish changing Deserializebody(#92)

Browse Source 
Former-commit-id: f4afd07be086b843f857febbe127396eadfa0406 [formerly 5c8f51b8bc4d0d21e6a44bcbe5f946d051a2c9b6]
Former-commit-id: 122da75bb554d464975c13172be8d84f6a693ec0
This commit is contained in:
nisdas 2018-05-03 21:28:44 +08:00
parent 2cf1bfc2b7
commit 1f341bee87
1 changed files with 17 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
sharding/client/utils.go
View File

@ -81,22 +81,26 @@ func serializeBlob(cb interface{}) ([]byte, error) {
}
// Serialize takes a set of transactions and converts them to a single byte array
func Serialize(rawtx []interface{}) ([]byte, error) {
length := int64(len(rawtx))
if length == 0 {
return nil, fmt.Errorf("Validation failed: Collation Body has to be a non-zero value")
}
serialisedData := []byte{0, 2}
serialisedData := []byte{}
for i := int64(0); i < length; i++ {
blobLength := length(serialisedData)
data := rawtx[i].(txblob)
refinedData := data.serializeBlob()
blobLength := int64(len(serialisedData))
data := rawtx[i]
refinedData, err := serializeBlob(data)
if err != nil {
return nil, fmt.Errorf("Error: %v", err)
}
serialisedData = append(serialisedData, refinedData...)
if txblob(serialisedData).length() > collationsizelimit {
if int64(len(serialisedData)) > collationsizelimit {
log.Info(fmt.Sprintf("The total number of interfaces added to the collation body are: %d", i))
serialisedData = serialisedData[:blobLength]
return serialisedData, nil
@ -107,32 +111,32 @@ func Serialize(rawtx []interface{}) ([]byte, error) {
return serialisedData, nil
}
// Collation body deserialised and separated into its respective interfaces
func Deserializebody(collationbody []byte) []blob {
// Deserializebody results in the Collation body being deserialised and separated into its respective interfaces
func Deserializebody(collationbody []byte, rawtx []interface{}) error {
length := int64(len(collationbody))
chunksNumber := chunkSize / length
indicatorByte := make([]byte, 1)
indicatorByte[0] = 0
txblobs := []blob{}
var tempbody txblob
var txblobs []interface{}
tempbody := []byte{}
for i := int64(1); i <= chunksNumber; i++ {
if reflect.TypeOf(collationbody[(i-1)*chunkSize]) == reflect.TypeOf(indicatorByte) {
if reflect.ValueOf(collationbody[(i-1)*chunkSize]) == reflect.ValueOf(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{}
tempbody = []byte{}
}
}
rawtx = txblobs
return txblobs
return nil
}