src: Add DMA localagent

[barometer.git] / src / dma / vendor / github.com / go-redis / redis / internal / pool / conn.go

diff --git a/src/dma/vendor/github.com/go-redis/redis/internal/pool/conn.go b/src/dma/vendor/github.com/go-redis/redis/internal/pool/conn.go
new file mode 100644 (file)
index 0000000..acaf366
--- /dev/null
+++ b/src/dma/vendor/github.com/go-redis/redis/internal/pool/conn.go
@@ -0,0 +1,80 @@
+package pool
+
+import (
+       "net"
+       "sync/atomic"
+       "time"
+
+       "github.com/go-redis/redis/internal/proto"
+)
+
+var noDeadline = time.Time{}
+
+type Conn struct {
+       netConn net.Conn
+
+       Rd *proto.Reader
+       Wb *proto.WriteBuffer
+
+       Inited bool
+       usedAt atomic.Value
+}
+
+func NewConn(netConn net.Conn) *Conn {
+       cn := &Conn{
+               netConn: netConn,
+               Wb:      proto.NewWriteBuffer(),
+       }
+       cn.Rd = proto.NewReader(cn.netConn)
+       cn.SetUsedAt(time.Now())
+       return cn
+}
+
+func (cn *Conn) UsedAt() time.Time {
+       return cn.usedAt.Load().(time.Time)
+}
+
+func (cn *Conn) SetUsedAt(tm time.Time) {
+       cn.usedAt.Store(tm)
+}
+
+func (cn *Conn) SetNetConn(netConn net.Conn) {
+       cn.netConn = netConn
+       cn.Rd.Reset(netConn)
+}
+
+func (cn *Conn) IsStale(timeout time.Duration) bool {
+       return timeout > 0 && time.Since(cn.UsedAt()) > timeout
+}
+
+func (cn *Conn) SetReadTimeout(timeout time.Duration) {
+       now := time.Now()
+       cn.SetUsedAt(now)
+       if timeout > 0 {
+               cn.netConn.SetReadDeadline(now.Add(timeout))
+       } else {
+               cn.netConn.SetReadDeadline(noDeadline)
+       }
+}
+
+func (cn *Conn) SetWriteTimeout(timeout time.Duration) {
+       now := time.Now()
+       cn.SetUsedAt(now)
+       if timeout > 0 {
+               cn.netConn.SetWriteDeadline(now.Add(timeout))
+       } else {
+               cn.netConn.SetWriteDeadline(noDeadline)
+       }
+}
+
+func (cn *Conn) Write(b []byte) (int, error) {
+       return cn.netConn.Write(b)
+}
+
+func (cn *Conn) RemoteAddr() net.Addr {
+       return cn.netConn.RemoteAddr()
+}
+
+func (cn *Conn) Close() error {
+       return cn.netConn.Close()
+}