Commit 3c810609 authored by 李伟@五瓣科技's avatar 李伟@五瓣科技

fix request amount

parent b3d5dad9
......@@ -452,7 +452,7 @@ func (web *WebServicer) TxsHandler(w http.ResponseWriter, r *http.Request) {
SetSendRecord(id, SendRecord{TotalConsTx: int64(consTxNum)})
go func() {
if err := web.ProduceTxs(params.From, params.ToAddrs, int(params.TxCount), params.EveryTxAmount, id); err != nil {
if err := web.ProduceTxs(params.From, params.ToAddrs, int(params.TxCount), params.EveryTxAmount, id, params.RequestAmount); err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
......@@ -492,7 +492,7 @@ type WebResp struct {
AllTxs []ConsTxHashs `json:"all_txs"`
}
func (web *WebServicer) ProduceTxs(fromAddr string, toAddrs []string, txCount int, amount int64, id uuid.UUID) error {
func (web *WebServicer) ProduceTxs(fromAddr string, toAddrs []string, txCount int, amount int64, id uuid.UUID, requestAmount int64) error {
addrsL := len(toAddrs)
first := true
......@@ -518,7 +518,7 @@ func (web *WebServicer) ProduceTxs(fromAddr string, toAddrs []string, txCount in
if fromAddr != systemFromAddr && first {
txCount++
tx, err = buildOriginalTx(originalTxParam.Nonce, common.HexToAddress(fromAddr), amount*int64(txCount), big.NewInt(256), nil)
tx, err = buildOriginalTx(originalTxParam.Nonce, common.HexToAddress(fromAddr), requestAmount, big.NewInt(256), nil)
} else {
tx, err = buildOriginalTx(originalTxParam.Nonce, common.HexToAddress(toAddrs[i%addrsL]), amount, big.NewInt(256), nil)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment