Commit 9c800f8d authored by 李伟@五瓣科技's avatar 李伟@五瓣科技

rm time limit and max tx limit

parent 2db7e343
...@@ -207,9 +207,9 @@ func (t *Transactor) sendLoop() { ...@@ -207,9 +207,9 @@ func (t *Transactor) sendLoop() {
t.setStop(err) t.setStop(err)
} }
case <-timeLimitTicker.C: // case <-timeLimitTicker.C:
t.logger.Info("Time limit reached for load testing") // t.logger.Info("Time limit reached for load testing")
t.setStop(nil) // t.setStop(nil)
} }
if t.mustStop() { if t.mustStop() {
t.close() t.close()
...@@ -242,10 +242,10 @@ func (t *Transactor) sendTransactions() error { ...@@ -242,10 +242,10 @@ func (t *Transactor) sendTransactions() error {
// send as many transactions as we can, up to the send rate // send as many transactions as we can, up to the send rate
totalSent := t.GetTxCount() totalSent := t.GetTxCount()
toSend := t.config.Rate toSend := t.config.Rate
if (t.config.Count > 0) && ((totalSent + toSend) > t.config.Count) { // if (t.config.Count > 0) && ((totalSent + toSend) > t.config.Count) {
toSend = t.config.Count - totalSent // toSend = t.config.Count - totalSent
t.logger.Debug("Nearing max transaction count", "totalSent", totalSent, "maxTxCount", t.config.Count, "toSend", toSend) // t.logger.Debug("Nearing max transaction count", "totalSent", totalSent, "maxTxCount", t.config.Count, "toSend", toSend)
} // }
if totalSent == 0 { if totalSent == 0 {
t.trackStartTime() t.trackStartTime()
} }
......
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