diff --git a/eth/ethconfig/estimate/esitmated_ram.go b/eth/ethconfig/estimate/esitmated_ram.go index 2b7ad52f1..244b17f4e 100644 --- a/eth/ethconfig/estimate/esitmated_ram.go +++ b/eth/ethconfig/estimate/esitmated_ram.go @@ -23,5 +23,5 @@ func (r estimatedRamPerWorker) Workers() int { const ( IndexSnapshot = estimatedRamPerWorker(2 * datasize.GB) //elias-fano index building is single-threaded CompressSnapshot = estimatedRamPerWorker(1 * datasize.GB) //1-file-compression is multi-threaded - ReconstituteState = estimatedRamPerWorker(4 * datasize.GB) //state-reconstitution is multi-threaded + ReconstituteState = estimatedRamPerWorker(2 * datasize.GB) //state-reconstitution is multi-threaded ) diff --git a/eth/stagedsync/exec3.go b/eth/stagedsync/exec3.go index 71d1267d4..ca65e2576 100644 --- a/eth/stagedsync/exec3.go +++ b/eth/stagedsync/exec3.go @@ -57,7 +57,7 @@ func (p *Progress) Log(logPrefix string, rs *state.State22, rws state.TxTaskQueu currentTime := time.Now() interval := currentTime.Sub(p.prevTime) speedTx := float64(count-p.prevCount) / (float64(interval) / float64(time.Second)) - speedBlock := float64(outputBlockNum-p.prevOutputBlockNum) / (float64(interval) / float64(time.Second)) + //speedBlock := float64(outputBlockNum-p.prevOutputBlockNum) / (float64(interval) / float64(time.Second)) var repeatRatio float64 if count > p.prevCount { repeatRatio = 100.0 * float64(repeatCount-p.prevRepeatCount) / float64(count-p.prevCount) @@ -66,7 +66,7 @@ func (p *Progress) Log(logPrefix string, rs *state.State22, rws state.TxTaskQueu //"workers", workerCount, "at blk", outputBlockNum, "input blk", atomic.LoadUint64(&inputBlockNum), - "blk/s", fmt.Sprintf("%.1f", speedBlock), + //"blk/s", fmt.Sprintf("%.1f", speedBlock), "tx/s", fmt.Sprintf("%.1f", speedTx), "resultCh", fmt.Sprintf("%d/%d", len(resultCh), cap(resultCh)), "resultQueue", fmt.Sprintf("%d/%d", rws.Len(), queueSize),