Merge branch 'master' of https://github.com/tomochain/tomochain

docker/tomochain/entrypoint.sh

@@ -151,6 +151,7 @@ exec tomo $params \
   --identity $IDENTITY \
   --password ./password \
   --port 30303 \
+  --maxpeer 200 \
   --rpc \
   --rpccorsdomain "*" \
   --rpcaddr 0.0.0.0 \

eth/downloader/downloader.go

@@ -1326,31 +1326,28 @@ func (d *Downloader) processFullSyncContent() error {
 		if d.blockchain.Config() != nil && d.blockchain.Config().Posv != nil {
 			epoch := d.blockchain.Config().Posv.Epoch
 			gap := d.blockchain.Config().Posv.Gap
-			length := len(results)
+			inserts := []*fetchResult{}
-			start := int(results[0].Header.Number.Uint64() % epoch)
+			for i := 0; i < len(results); i++ {
-			end := int(epoch - gap - uint64(start))
+				number := results[i].Header.Number.Uint64() % epoch
-			if end < 0 {
+				if number == 0 || number == epoch-1 || number == epoch-gap {
-				end = end + int(epoch)
+					inserts = append(inserts, results[i])
-			}
-			start = 0
-			for {
-				if end >= length {
-					end = length - 1
-				}
-				inserts := make([]*fetchResult, end-start+1)
-				copy(inserts, results[start:end+1])
-				if len(inserts) > 0 {
 					if d.chainInsertHook != nil {
 						d.chainInsertHook(inserts)
 					}
 					if err := d.importBlockResults(inserts); err != nil {
 						return err
 					}
+					inserts = []*fetchResult{}
+				} else {
+					inserts = append(inserts, results[i])
 				}
-				start = end + 1
+			}
-				end = end + int(epoch)
+			if len(inserts) > 0 {
-				if start >= length {
+				if d.chainInsertHook != nil {
-					break
+					d.chainInsertHook(inserts)
+				}
+				if err := d.importBlockResults(inserts); err != nil {
+					return err
 				}
 			}
 		} else {