update pool settings
This commit is contained in:
@@ -408,7 +408,7 @@ func (p *SyncedPool) AddRemote(host string) {
|
|||||||
|
|
||||||
host_pool, err := netpool.New(func() (net.Conn, error) {
|
host_pool, err := netpool.New(func() (net.Conn, error) {
|
||||||
return net.Dial("tcp", fmt.Sprintf("%s:1338", host))
|
return net.Dial("tcp", fmt.Sprintf("%s:1338", host))
|
||||||
}, netpool.WithMaxPool(1024), netpool.WithMinPool(5))
|
}, netpool.WithMaxPool(128), netpool.WithMinPool(16))
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Printf("Error creating pool: %v\n", err)
|
log.Printf("Error creating pool: %v\n", err)
|
||||||
|
|||||||
@@ -17,7 +17,7 @@ func TestGenericConnection(t *testing.T) {
|
|||||||
}
|
}
|
||||||
pool, err := netpool.New(func() (net.Conn, error) {
|
pool, err := netpool.New(func() (net.Conn, error) {
|
||||||
return net.Dial("tcp", "127.0.0.1:51337")
|
return net.Dial("tcp", "127.0.0.1:51337")
|
||||||
}, netpool.WithMaxPool(512), netpool.WithMinPool(5))
|
}, netpool.WithMaxPool(128), netpool.WithMinPool(16))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Errorf("Error creating pool: %v\n", err)
|
t.Errorf("Error creating pool: %v\n", err)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user