1 sec feature

Author: Frozen

consensus/consensus_service.go

@@ -364,6 +364,9 @@ func (consensus *Consensus) updateConsensusInformation(reason string) Mode {
 	if consensus.Blockchain().Config().IsTwoSeconds(nextEpoch) {
 		consensus.BlockPeriod = 2 * time.Second
 	}
+	if consensus.Blockchain().Config().IsOneSecond(nextEpoch) {
+		consensus.BlockPeriod = 1 * time.Second
+	}
 
 	isFirstTimeStaking := consensus.Blockchain().Config().IsStaking(nextEpoch) &&
 		curHeader.IsLastBlockInEpoch() && !consensus.Blockchain().Config().IsStaking(curEpoch)

internal/chain/reward.go

@@ -220,9 +220,14 @@ func getDefaultStakingReward(bc engine.ChainReader, epoch *big.Int, blockNum uin
 		if bc.Config().IsTwoSeconds(epoch) {
 			defaultReward = stakingReward.TwoSecStakedBlocks
 		}
+		if bc.Config().IsOneSecond(epoch) {
+			defaultReward = stakingReward.OneSecStakedBlock
+		}
 	} else {
 		// Mainnet (other nets):
-		if bc.Config().IsHIP30(epoch) {
+		if bc.Config().IsOneSecond(epoch) {
+			defaultReward = stakingReward.OneSecStakedBlock
+		} else if bc.Config().IsHIP30(epoch) {
 			defaultReward = stakingReward.HIP30StakedBlocks
 		} else if bc.Config().IsTwoSeconds(epoch) {
 			defaultReward = stakingReward.TwoSecStakedBlocks

internal/configs/sharding/localnet.go

@@ -51,6 +51,8 @@ const (
 
 func (ls localnetSchedule) InstanceForEpoch(epoch *big.Int) Instance {
 	switch {
+	case params.LocalnetChainConfig.IsOneSecond(epoch):
+		return localnetV4
 	case params.LocalnetChainConfig.IsHIP30(epoch):
 		return localnetV4
 	case params.LocalnetChainConfig.IsFeeCollectEpoch(epoch):

internal/params/config.go

@@ -323,6 +323,7 @@ var (
 		MaxRateEpoch:                          EpochTBD,
 		DevnetExternalEpoch:                   EpochTBD,
 		TestnetExternalEpoch:                  EpochTBD,
+		IsOneSecondEpoch:                      big.NewInt(4),
 	}
 
 	// AllProtocolChanges ...
@@ -374,6 +375,7 @@ var (
 		big.NewInt(0),
 		big.NewInt(0),
 		big.NewInt(0),
+		big.NewInt(0),
 	}
 
 	// TestChainConfig ...
@@ -425,6 +427,7 @@ var (
 		big.NewInt(0),        // MaxRateEpoch
 		big.NewInt(0),
 		big.NewInt(0),
+		big.NewInt(0),
 	}
 
 	// TestRules ...
@@ -606,6 +609,8 @@ type ChainConfig struct {
 	// vote power feature  https://github.com/harmony-one/harmony/pull/4683
 	// if crosslink are not sent for an entire epoch signed and toSign will be 0 and 0. when that happen, next epoch there will no shard 1 validator elected in the committee.
 	HIP32Epoch *big.Int `json:"hip32-epoch,omitempty"`
+
+	IsOneSecondEpoch *big.Int `json:"is-one-second-epoch,omitempty"`
 }
 
 // String implements the fmt.Stringer interface.
@@ -731,6 +736,10 @@ func (c *ChainConfig) IsTwoSeconds(epoch *big.Int) bool {
 	return isForked(c.TwoSecondsEpoch, epoch)
 }
 
+func (c *ChainConfig) IsOneSecond(epoch *big.Int) bool {
+	return isForked(c.IsOneSecondEpoch, epoch)
+}
+
 // IsSixtyPercent determines whether it is the epoch to reduce internal voting power to 60%
 func (c *ChainConfig) IsSixtyPercent(epoch *big.Int) bool {
 	return isForked(c.SixtyPercentEpoch, epoch)

node/harmony/node_syncing.go

@@ -206,10 +206,29 @@ func (p *LocalSyncingPeerProvider) SyncingPeers(shardID uint32) (peers []p2p.Pee
 		return nil, errors.Errorf(
 			"shard ID %d out of range 0..%d", shardID, p.numShards-1)
 	}
-	shards := [][]string{
-		{"6000", "6004", "6008", "6012", "6016", "6020", "6100", "6104", "6108", "6112", "6116", "6120"},
-		{"6002", "6006", "6010", "6014", "6018", "6022", "6102", "6106", "6110", "6114", "6118", "6122"},
+	shards := [][]string{}
+	if true {
+		shards = [][]string{
+			{
+				"6000",
+				"6004",
+				"6008",
+				"6120",
+			},
+			{
+				"6002",
+				"6006",
+				"6010",
+				"6122",
+			},
+		}
+	} else {
+		shards = [][]string{
+			{"6000", "6004", "6008", "6012", "6016", "6020", "6100", "6104", "6108", "6112", "6116", "6120"},
+			{"6002", "6006", "6010", "6014", "6018", "6022", "6102", "6106", "6110", "6114", "6118", "6122"},
+		}
 	}
+
 	selfport := fmt.Sprint(p.selfPort)
 	for _, port := range shards[shardID] {
 		if port == selfport {
@@ -317,6 +336,9 @@ func (node *Node) doSync(syncInstance ISync, syncingPeerProvider SyncingPeerProv
 	}
 	// TODO: treat fake maximum height
 	if isSynchronized, _, _ := syncInstance.GetParsedSyncStatusDoubleChecked(); !isSynchronized {
+		if consensus.IsLeader() {
+			return
+		}
 		node.IsSynchronized.UnSet()
 		if willJoinConsensus {
 			consensus.BlocksNotSynchronized("node.doSync")

staking/reward/values.go

@@ -39,6 +39,11 @@ var (
 		big.NewInt(14*denominations.Nano), big.NewInt(denominations.Nano),
 	))
 
+	// OneSecStakedBlock is half of HIP30
+	OneSecStakedBlock = numeric.NewDecFromBigInt(new(big.Int).Mul(
+		big.NewInt(7*denominations.Nano), big.NewInt(denominations.Nano),
+	))
+
 	// TotalInitialTokens is the total amount of tokens (in ONE) at block 0 of the network.
 	// This should be set/change on the node's init according to the core.GenesisSpec.
 	TotalInitialTokens = numeric.Dec{Int: big.NewInt(0)}