certusone
/
cosmos-sdk
mirror of https://github.com/certusone/cosmos-sdk.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

address bez comments

This commit is contained in:
rigelrozanski 2018-09-24 18:54:49 -04:00
parent df0d5825be
commit 9dfeeb0d7b
3 changed files with 0 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
x/stake/handler.go
View File

@ -87,7 +87,6 @@ func handleMsgCreateValidator(ctx sdk.Context, msg types.MsgCreateValidator, k k
return err.Result() return err.Result()
} }
// call hooks
k.OnValidatorCreated(ctx, validator.OperatorAddr) k.OnValidatorCreated(ctx, validator.OperatorAddr)
accAddr := sdk.AccAddress(validator.OperatorAddr) accAddr := sdk.AccAddress(validator.OperatorAddr)
k.OnDelegationCreated(ctx, accAddr, validator.OperatorAddr) k.OnDelegationCreated(ctx, accAddr, validator.OperatorAddr)

6
x/stake/keeper/delegation.go
View File

@ -66,10 +66,7 @@ func (k Keeper) SetDelegation(ctx sdk.Context, delegation types.Delegation) {
// remove a delegation from store // remove a delegation from store
func (k Keeper) RemoveDelegation(ctx sdk.Context, delegation types.Delegation) { func (k Keeper) RemoveDelegation(ctx sdk.Context, delegation types.Delegation) {
// call hook
k.OnDelegationRemoved(ctx, delegation.DelegatorAddr, delegation.ValidatorAddr) k.OnDelegationRemoved(ctx, delegation.DelegatorAddr, delegation.ValidatorAddr)
store := ctx.KVStore(k.storeKey) store := ctx.KVStore(k.storeKey)
store.Delete(GetDelegationKey(delegation.DelegatorAddr, delegation.ValidatorAddr)) store.Delete(GetDelegationKey(delegation.DelegatorAddr, delegation.ValidatorAddr))
} }
@ -286,7 +283,6 @@ func (k Keeper) Delegate(ctx sdk.Context, delAddr sdk.AccAddress, bondAmt sdk.Co
func (k Keeper) unbond(ctx sdk.Context, delAddr sdk.AccAddress, valAddr sdk.ValAddress, func (k Keeper) unbond(ctx sdk.Context, delAddr sdk.AccAddress, valAddr sdk.ValAddress,
shares sdk.Dec) (amount sdk.Dec, err sdk.Error) { shares sdk.Dec) (amount sdk.Dec, err sdk.Error) {
// call hook
k.OnDelegationSharesModified(ctx, delAddr, valAddr) k.OnDelegationSharesModified(ctx, delAddr, valAddr)
// check if delegation has any shares in it unbond // check if delegation has any shares in it unbond
@ -340,9 +336,7 @@ func (k Keeper) unbond(ctx sdk.Context, delAddr sdk.AccAddress, valAddr sdk.ValA
k.RemoveValidator(ctx, validator.OperatorAddr) k.RemoveValidator(ctx, validator.OperatorAddr)
} }
// call hook
k.OnDelegationSharesModified(ctx, delegation.DelegatorAddr, validator.OperatorAddr) k.OnDelegationSharesModified(ctx, delegation.DelegatorAddr, validator.OperatorAddr)
return amount, nil return amount, nil
} }

8
x/stake/keeper/validator.go
View File

@ -633,10 +633,7 @@ func (k Keeper) beginUnbondingValidator(ctx sdk.Context, validator types.Validat
// also remove from the Bonded types.Validators Store // also remove from the Bonded types.Validators Store
store.Delete(GetValidatorsBondedIndexKey(validator.OperatorAddr)) store.Delete(GetValidatorsBondedIndexKey(validator.OperatorAddr))
// call hook
k.OnValidatorBeginUnbonding(ctx, validator.ConsAddress()) k.OnValidatorBeginUnbonding(ctx, validator.ConsAddress())
// return updated validator
return validator return validator
} }
@ -666,17 +663,13 @@ func (k Keeper) bondValidator(ctx sdk.Context, validator types.Validator) types.
tstore := ctx.TransientStore(k.storeTKey) tstore := ctx.TransientStore(k.storeTKey)
tstore.Set(GetTendermintUpdatesTKey(validator.OperatorAddr), bzABCI) tstore.Set(GetTendermintUpdatesTKey(validator.OperatorAddr), bzABCI)
// call hook
k.OnValidatorBonded(ctx, validator.ConsAddress()) k.OnValidatorBonded(ctx, validator.ConsAddress())
// return updated validator
return validator return validator
} }
// remove the validator record and associated indexes // remove the validator record and associated indexes
func (k Keeper) RemoveValidator(ctx sdk.Context, address sdk.ValAddress) { func (k Keeper) RemoveValidator(ctx sdk.Context, address sdk.ValAddress) {
// call hook
k.OnValidatorRemoved(ctx, address) k.OnValidatorRemoved(ctx, address)
// first retrieve the old validator record // first retrieve the old validator record
@ -745,7 +738,6 @@ func ensureValidatorFound(found bool, ownerAddr []byte) {
// get a single validator // get a single validator
func (k Keeper) UpdateValidatorCommission(ctx sdk.Context, addr sdk.ValAddress, newCommission sdk.Dec) sdk.Error { func (k Keeper) UpdateValidatorCommission(ctx sdk.Context, addr sdk.ValAddress, newCommission sdk.Dec) sdk.Error {
// call hook
k.OnValidatorCommissionChange(ctx, addr) k.OnValidatorCommissionChange(ctx, addr)
validator, _ := k.GetValidator(ctx, addr) validator, _ := k.GetValidator(ctx, addr)