Commit 34138bb0 authored by Raúl Kripalani's avatar Raúl Kripalani

make FD limits configurable by env prop.

parent 65dbfb6a
......@@ -2,6 +2,8 @@ package swarm
import (
"context"
"os"
"strconv"
"sync"
"time"
......@@ -59,7 +61,13 @@ type dialLimiter struct {
type dialfunc func(context.Context, peer.ID, ma.Multiaddr) (transport.Conn, error)
func newDialLimiter(df dialfunc) *dialLimiter {
return newDialLimiterWithParams(df, ConcurrentFdDials, DefaultPerPeerRateLimit)
fd := ConcurrentFdDials
if env := os.Getenv("LIBP2P_SWARM_FD_LIMIT"); env != "" {
if n, err := strconv.ParseInt(env, 10, 32); err == nil {
fd = int(n)
}
}
return newDialLimiterWithParams(df, fd, DefaultPerPeerRateLimit)
}
func newDialLimiterWithParams(df dialfunc, fdLimit, perPeerLimit int) *dialLimiter {
......
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