File tree Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -137,7 +137,7 @@ func (c *Client) PoolStats() PoolStats {
137
137
func (c * Client ) getConn (ctx context.Context ) (* Pipeline , error ) {
138
138
c .initPool ()
139
139
140
- if conn , ok := c .pool .tryGet (ctx ); ok {
140
+ if conn , ok := c .pool .tryGet (); ok {
141
141
return c .newResult (conn ), nil
142
142
}
143
143
Original file line number Diff line number Diff line change @@ -2,7 +2,6 @@ package redjet
2
2
3
3
import (
4
4
"bufio"
5
- "context"
6
5
"net"
7
6
"sync"
8
7
"sync/atomic"
@@ -97,7 +96,7 @@ func (p *connPool) cleanLoop() {
97
96
98
97
// tryGet tries to get a connection from the pool. If there are no free
99
98
// connections, it returns false.
100
- func (p * connPool ) tryGet (ctx context. Context ) (* conn , bool ) {
99
+ func (p * connPool ) tryGet () (* conn , bool ) {
101
100
p .cleanMu .Lock ()
102
101
defer p .cleanMu .Unlock ()
103
102
You can’t perform that action at this time.
0 commit comments