Skip to content

Commit

Permalink
Merge pull request #571 from pythonberg1997/develop
Browse files Browse the repository at this point in the history
chore: merge master branch into develop
  • Loading branch information
unclezoro authored Jul 16, 2024
2 parents adc614d + 2338697 commit 0fa2e80
Show file tree
Hide file tree
Showing 10 changed files with 1,103 additions and 871 deletions.
5 changes: 5 additions & 0 deletions abi/slashindicator.abi
Original file line number Diff line number Diff line change
Expand Up @@ -461,6 +461,11 @@
"name": "count",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "shouldRevert",
"type": "bool",
"internalType": "bool"
}
],
"outputs": [],
Expand Down
21 changes: 12 additions & 9 deletions contracts/BSCValidatorSet.sol
Original file line number Diff line number Diff line change
Expand Up @@ -680,7 +680,7 @@ contract BSCValidatorSet is IBSCValidatorSet, System, IParamSubscriber, IApplica
// jailed validators are allowed to exit maintenance
require(validatorExtraSet[index].isMaintaining, "not in maintenance");
uint256 miningValidatorCount = getWorkingValidatorCount();
_exitMaintenance(msg.sender, index, miningValidatorCount);
_exitMaintenance(msg.sender, index, miningValidatorCount, true);
}

/*----------------- Param update -----------------*/
Expand Down Expand Up @@ -1202,7 +1202,7 @@ contract BSCValidatorSet is IBSCValidatorSet, System, IParamSubscriber, IApplica
validator = currentValidatorSet[i].consensusAddress;

// exit maintenance
isFelony = _exitMaintenance(validator, i, miningValidatorCount);
isFelony = _exitMaintenance(validator, i, miningValidatorCount, false);
if (!isFelony) {
continue;
}
Expand Down Expand Up @@ -1267,25 +1267,32 @@ contract BSCValidatorSet is IBSCValidatorSet, System, IParamSubscriber, IApplica
function _exitMaintenance(
address validator,
uint256 index,
uint256 miningValidatorCount
uint256 miningValidatorCount,
bool shouldRevert
) private returns (bool isFelony) {
if (maintainSlashScale == 0 || miningValidatorCount == 0 || numOfMaintaining == 0) {
// should not happen, still protect
return false;
}

// step 0: modify numOfMaintaining
--numOfMaintaining;

// step 1: calculate slashCount
uint256 slashCount = block.number.sub(validatorExtraSet[index].enterMaintenanceHeight).div(miningValidatorCount)
.div(maintainSlashScale);

// step2: slash the validator
// step 2: clear isMaintaining info
validatorExtraSet[index].isMaintaining = false;

// step 3: slash the validator
(uint256 misdemeanorThreshold, uint256 felonyThreshold) =
ISlashIndicator(SLASH_CONTRACT_ADDR).getSlashThresholds();
isFelony = false;
if (slashCount >= felonyThreshold) {
_felony(validator, index);
if (IStakeHub(STAKE_HUB_ADDR).consensusToOperator(validator) != address(0)) {
ISlashIndicator(SLASH_CONTRACT_ADDR).downtimeSlash(validator, slashCount);
ISlashIndicator(SLASH_CONTRACT_ADDR).downtimeSlash(validator, slashCount, shouldRevert);
} else {
ISlashIndicator(SLASH_CONTRACT_ADDR).sendFelonyPackage(validator);
}
Expand All @@ -1294,10 +1301,6 @@ contract BSCValidatorSet is IBSCValidatorSet, System, IParamSubscriber, IApplica
_misdemeanor(validator);
}

// step 3: modify global storage
--numOfMaintaining;
validatorExtraSet[index].isMaintaining = false;

emit validatorExitMaintenance(validator);
}

Expand Down
26 changes: 17 additions & 9 deletions contracts/SlashIndicator.sol
Original file line number Diff line number Diff line change
Expand Up @@ -135,7 +135,7 @@ contract SlashIndicator is ISlashIndicator, System, IParamSubscriber, IApplicati
indicator.count = 0;
IBSCValidatorSet(VALIDATOR_CONTRACT_ADDR).felony(validator);
if (IStakeHub(STAKE_HUB_ADDR).consensusToOperator(validator) != address(0)) {
_downtimeSlash(validator, indicator.count);
_downtimeSlash(validator, indicator.count, false);
} else {
// send slash msg to bc if validator is not migrated
try ICrossChain(CROSS_CHAIN_CONTRACT_ADDR).sendSynPackage(
Expand Down Expand Up @@ -205,16 +205,24 @@ contract SlashIndicator is ISlashIndicator, System, IParamSubscriber, IApplicati
emit indicatorCleaned();
}

function downtimeSlash(address validator, uint256 count) external override onlyValidatorContract {
_downtimeSlash(validator, count);
function downtimeSlash(
address validator,
uint256 count,
bool shouldRevert
) external override onlyValidatorContract {
_downtimeSlash(validator, count, shouldRevert);
}

function _downtimeSlash(address validator, uint256 count) internal {
try IStakeHub(STAKE_HUB_ADDR).downtimeSlash(validator) { }
catch Error(string memory reason) {
emit failedFelony(validator, count, bytes(reason));
} catch (bytes memory lowLevelData) {
emit failedFelony(validator, count, lowLevelData);
function _downtimeSlash(address validator, uint256 count, bool shouldRevert) internal {
if (shouldRevert) {
IStakeHub(STAKE_HUB_ADDR).downtimeSlash(validator);
} else {
try IStakeHub(STAKE_HUB_ADDR).downtimeSlash(validator) { }
catch Error(string memory reason) {
emit failedFelony(validator, count, bytes(reason));
} catch (bytes memory lowLevelData) {
emit failedFelony(validator, count, lowLevelData);
}
}
}

Expand Down
2 changes: 1 addition & 1 deletion contracts/interface/ISlashIndicator.sol
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ pragma solidity 0.6.4;

interface ISlashIndicator {
function clean() external;
function downtimeSlash(address validator, uint256 count) external;
function downtimeSlash(address validator, uint256 count, bool shouldRevert) external;
function sendFelonyPackage(address validator) external;
function getSlashThresholds() external view returns (uint256, uint256);
}
Loading

0 comments on commit 0fa2e80

Please sign in to comment.