coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-02-26 12:57:26 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

parallelize commit path

Browse Source
This commit is contained in:
Cassandra Heart 2025-02-10 03:13:39 -06:00
parent 7afe704a2f
commit 058ecc5cf4
No known key found for this signature in database
GPG Key ID: 6352152859385958
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
node/execution/intrinsics/token/token_execution_engine.go
View File

@ -447,7 +447,7 @@ var _ execution.ExecutionEngine = (*TokenExecutionEngine)(nil)
func (e *TokenExecutionEngine) addBatchToHypergraph(batchKey [][]byte, batchValue [][]byte) {
var wg sync.WaitGroup
throttle := make(chan struct{}, runtime.NumCPU())
batchCompressed := make([][]hypergraph.Encrypted, len(batchKey))
batchCompressed := make([]hypergraph.Vertex, len(batchKey))
for i, chunk := range batchValue {
throttle <- struct{}{}
wg.Add(1)
@ -470,18 +470,19 @@ func (e *TokenExecutionEngine) addBatchToHypergraph(batchKey [][]byte, batchValu
"encrypted coin",
zap.String("address", hex.EncodeToString(batchKey[i])),
)
batchCompressed[i] = compressed
batchCompressed[i] = hypergraph.NewVertex(
[32]byte(application.TOKEN_ADDRESS),
[32]byte(batchKey[i]),
compressed,
)
batchCompressed[i].Commit()
}(chunk, i)
}
wg.Wait()
for i := range batchKey {
if err := e.hypergraph.AddVertex(
hypergraph.NewVertex(
[32]byte(application.TOKEN_ADDRESS),
[32]byte(batchKey[i]),
batchCompressed[i],
),
batchCompressed[i],
); err != nil {
panic(err)
}