ok
This commit is contained in:
@@ -3,6 +3,7 @@ package main
|
||||
import (
|
||||
"fmt"
|
||||
"local/args"
|
||||
"log"
|
||||
"time"
|
||||
|
||||
"golang.org/x/time/rate"
|
||||
@@ -29,7 +30,8 @@ func NewConfig() *Config {
|
||||
|
||||
var limiter *rate.Limiter
|
||||
if kbps := as.GetInt("kbps"); kbps > 0 {
|
||||
limiter = rate.NewLimiter(rate.Limit(kbps), 100*1024)
|
||||
limiter = rate.NewLimiter(rate.Limit(kbps*1024), 100*1024)
|
||||
log.Printf("created limiter with (%v, %v)", limiter.Limit(), limiter.Burst())
|
||||
}
|
||||
|
||||
return &Config{
|
||||
|
||||
Reference in New Issue
Block a user