diff --git a/node/config/version.go b/node/config/version.go index 892ac27..1e59131 100644 --- a/node/config/version.go +++ b/node/config/version.go @@ -36,5 +36,5 @@ func FormatVersion(version []byte) string { } func GetPatchNumber() byte { - return 0x05 + return 0x06 } diff --git a/node/rpc/data_worker_ipc_server.go b/node/rpc/data_worker_ipc_server.go index a43147f..f997f63 100644 --- a/node/rpc/data_worker_ipc_server.go +++ b/node/rpc/data_worker_ipc_server.go @@ -202,13 +202,15 @@ func NewDataWorkerIPCServer( panic(err) } + indices := p2p.GetOnesIndices(p2p.GetBloomFilter(digest, 1024, 64)) + return &DataWorkerIPCServer{ listenAddrGRPC: listenAddrGRPC, logger: logger, coreId: coreId, prover: prover, indices: []int{ - p2p.GetOnesIndices(p2p.GetBloomFilter(digest, 1024, 64))[coreId%64], + indices[int(coreId)%len(indices)], }, parentProcessId: parentProcessId, }, nil