Use perIPConn pool

1 files changed, 24 insertions, 0 deletions

diff --git a/peripconn.go b/peripconn.go
index cf8e986..2ebe0d4 100644
--- a/peripconn.go
+++ b/peripconn.go
@@ -42,11 +42,35 @@ type perIPConn struct {
 
 	ip               uint32
 	perIPConnCounter *perIPConnCounter
+
+	v interface{}
+}
+
+func acquirePerIPConn(conn net.Conn, ip uint32, counter *perIPConnCounter) *perIPConn {
+	v := perIPConnPool.Get()
+	if v == nil {
+		v = &perIPConn{}
+	}
+	c := v.(*perIPConn)
+	c.Conn = conn
+	c.ip = ip
+	c.perIPConnCounter = counter
+	c.v = v
+	return c
 }
 
+func releasePerIPConn(c *perIPConn) {
+	c.Conn = nil
+	c.perIPConnCounter = nil
+	perIPConnPool.Put(c.v)
+}
+
+var perIPConnPool sync.Pool
+
 func (c *perIPConn) Close() error {
 	err := c.Conn.Close()
 	c.perIPConnCounter.Unregister(c.ip)
+	releasePerIPConn(c)
 	return err
 }