Add locks to State; Export LoadValidators func

api/address.go

@@ -15,6 +15,9 @@ func Address(address types.Address, height int) (*AddressResponse, error) {
 		return nil, err
 	}
 
+	cState.Lock()
+	defer cState.Unlock()
+
 	response := AddressResponse{
 		Balance:          make(map[string]string),
 		TransactionCount: cState.Accounts.GetNonce(address),

api/addresses.go

@@ -16,6 +16,9 @@ func Addresses(addresses []types.Address, height int) (*[]AddressesResponse, err
 		return nil, err
 	}
 
+	cState.Lock()
+	defer cState.Unlock()
+
 	response := make([]AddressesResponse, len(addresses))
 
 	for i, address := range addresses {

api/candidate.go

@@ -56,6 +56,9 @@ func Candidate(pubkey types.Pubkey, height int) (*CandidateResponse, error) {
 		return nil, err
 	}
 
+	cState.Lock()
+	defer cState.Unlock()
+
 	if height != 0 {
 		cState.Candidates.LoadCandidates()
 		cState.Candidates.LoadStakes()

api/candidates.go

@@ -6,6 +6,9 @@ func Candidates(height int, includeStakes bool) (*[]CandidateResponse, error) {
 		return nil, err
 	}
 
+	cState.Lock()
+	defer cState.Unlock()
+
 	if height != 0 {
 		cState.Candidates.LoadCandidates()
 		if includeStakes {

api/coin_info.go

@@ -20,6 +20,9 @@ func CoinInfo(coinSymbol string, height int) (*CoinInfoResponse, error) {
 		return nil, err
 	}
 
+	cState.Lock()
+	defer cState.Unlock()
+
 	coin := cState.Coins.GetCoin(types.StrToCoinSymbol(coinSymbol))
 	if coin == nil {
 		return nil, rpctypes.RPCError{Code: 404, Message: "Coin not found"}

api/estimate_coin_buy.go

@@ -21,6 +21,9 @@ func EstimateCoinBuy(coinToSellString string, coinToBuyString string, valueToBuy
 		return nil, err
 	}
 
+	cState.Lock()
+	defer cState.Unlock()
+
 	coinToSell := types.StrToCoinSymbol(coinToSellString)
 	coinToBuy := types.StrToCoinSymbol(coinToBuyString)
 

api/estimate_coin_sell.go

@@ -23,6 +23,9 @@ func EstimateCoinSell(
 		return nil, err
 	}
 
+	cState.Lock()
+	defer cState.Unlock()
+
 	coinToSell := types.StrToCoinSymbol(coinToSellString)
 	coinToBuy := types.StrToCoinSymbol(coinToBuyString)
 

api/estimate_coin_sell_all.go

@@ -21,6 +21,9 @@ func EstimateCoinSellAll(
 		return nil, err
 	}
 
+	cState.Lock()
+	defer cState.Unlock()
+
 	if gasPrice < 1 {
 		gasPrice = 1
 	}

api/estimate_tx_commission.go

@@ -18,6 +18,9 @@ func EstimateTxCommission(tx []byte, height int) (*TxCommissionResponse, error)
 		return nil, err
 	}
 
+	cState.Lock()
+	defer cState.Unlock()
+
 	decodedTx, err := transaction.TxDecoder.DecodeFromBytes(tx)
 	if err != nil {
 		return nil, rpctypes.RPCError{Code: 400, Message: "Cannot decode transaction", Data: err.Error()}

api/maxgas.go

@@ -6,6 +6,9 @@ func MaxGas(height int) (*uint64, error) {
 		return nil, err
 	}
 
+	cState.Lock()
+	defer cState.Unlock()
+
 	maxGas := cState.App.GetMaxGas()
 	return &maxGas, nil
 }

api/missed_blocks.go

@@ -16,6 +16,11 @@ func MissedBlocks(pubkey types.Pubkey, height int) (*MissedBlocksResponse, error
 		return nil, err
 	}
 
+	cState.Lock()
+	defer cState.Unlock()
+
+	cState.Validators.LoadValidators()
+
 	vals := cState.Validators.GetValidators()
 	if vals == nil {
 		return nil, rpctypes.RPCError{Code: 404, Message: "Validators not found"}