internal: use a sync.Pool of msgpack.Decoder

The change helps to avoid 2 allocations per a response decoding.

You could check the change with the command:

$ go test -v . -bench . -run f -benchmem

Author: oleg-jukovec

CHANGELOG.md

@@ -10,6 +10,9 @@ Versioning](http://semver.org/spec/v2.0.0.html) except to the first release.
 
 ### Added
 
+- A usage of sync.Pool of msgpack.Decoder saves 2 object allocations per
+  a response decoding.
+
 ### Changed
 
 - Connect() now retry the connection if a failure occurs and opts.Reconnect > 0.

box_error.go

@@ -278,7 +278,10 @@ func (e *BoxError) UnmarshalMsgpack(b []byte) error {
 	}
 
 	buf := bytes.NewBuffer(b)
-	dec := msgpack.NewDecoder(buf)
+	dec := getDecoder()
+	defer putDecoder(dec)
+
+	dec.Reset(buf)
 
 	if val, err := decodeBoxError(dec); err != nil {
 		return err

connection.go

@@ -803,7 +803,11 @@ func (conn *Connection) writer(w writeFlusher, c Conn) {
 func readWatchEvent(reader io.Reader) (connWatchEvent, error) {
 	keyExist := false
 	event := connWatchEvent{}
-	d := msgpack.NewDecoder(reader)
+
+	d := getDecoder()
+	defer putDecoder(d)
+
+	d.Reset(reader)
 
 	l, err := d.DecodeMapLen()
 	if err != nil {

dial.go

@@ -547,7 +547,11 @@ func readResponse(r io.Reader, req Request) (Response, error) {
 	}
 
 	buf := smallBuf{b: respBytes}
-	header, _, err := decodeHeader(msgpack.NewDecoder(&smallBuf{}), &buf)
+
+	d := getDecoder()
+	defer putDecoder(d)
+
+	header, _, err := decodeHeader(d, &buf)
 	if err != nil {
 		return nil, fmt.Errorf("decode response header error: %w", err)
 	}

pool.go

@@ -0,0 +1,29 @@
+package tarantool
+
+import (
+	"sync"
+
+	"github.com/vmihailenco/msgpack/v5"
+)
+
+func untypedMapDecoder(dec *msgpack.Decoder) (interface{}, error) {
+	return dec.DecodeUntypedMap()
+}
+
+var decPool = sync.Pool{
+	New: func() interface{} {
+		d := msgpack.NewDecoder(nil)
+		d.SetMapDecoder(untypedMapDecoder)
+
+		return d
+	},
+}
+
+func getDecoder() *msgpack.Decoder {
+	return decPool.Get().(*msgpack.Decoder)
+}
+
+func putDecoder(dec *msgpack.Decoder) {
+	decPool.Put(dec)
+}
+

response.go

@@ -329,10 +329,10 @@ func (resp *baseResponse) Decode() ([]interface{}, error) {
 		var l int
 		info := &decodeInfo{}
 
-		d := msgpack.NewDecoder(&resp.buf)
-		d.SetMapDecoder(func(dec *msgpack.Decoder) (interface{}, error) {
-			return dec.DecodeUntypedMap()
-		})
+		d := getDecoder()
+		defer putDecoder(d)
+
+		d.Reset(&resp.buf)
 
 		if l, err = d.DecodeMapLen(); err != nil {
 			resp.err = err
@@ -384,10 +384,10 @@ func (resp *SelectResponse) Decode() ([]interface{}, error) {
 		var l int
 		info := &decodeInfo{}
 
-		d := msgpack.NewDecoder(&resp.buf)
-		d.SetMapDecoder(func(dec *msgpack.Decoder) (interface{}, error) {
-			return dec.DecodeUntypedMap()
-		})
+		d := getDecoder()
+		defer putDecoder(d)
+
+		d.Reset(&resp.buf)
 
 		if l, err = d.DecodeMapLen(); err != nil {
 			resp.err = err
@@ -447,10 +447,10 @@ func (resp *ExecuteResponse) Decode() ([]interface{}, error) {
 		var l int
 		info := &decodeInfo{}
 
-		d := msgpack.NewDecoder(&resp.buf)
-		d.SetMapDecoder(func(dec *msgpack.Decoder) (interface{}, error) {
-			return dec.DecodeUntypedMap()
-		})
+		d := getDecoder()
+		defer putDecoder(d)
+
+		d.Reset(&resp.buf)
 
 		if l, err = d.DecodeMapLen(); err != nil {
 			resp.err = err
@@ -535,10 +535,10 @@ func (resp *baseResponse) DecodeTyped(res interface{}) error {
 		info := &decodeInfo{}
 		var l int
 
-		d := msgpack.NewDecoder(&resp.buf)
-		d.SetMapDecoder(func(dec *msgpack.Decoder) (interface{}, error) {
-			return dec.DecodeUntypedMap()
-		})
+		d := getDecoder()
+		defer putDecoder(d)
+
+		d.Reset(&resp.buf)
 
 		if l, err = d.DecodeMapLen(); err != nil {
 			return err
@@ -576,10 +576,10 @@ func (resp *SelectResponse) DecodeTyped(res interface{}) error {
 		info := &decodeInfo{}
 		var l int
 
-		d := msgpack.NewDecoder(&resp.buf)
-		d.SetMapDecoder(func(dec *msgpack.Decoder) (interface{}, error) {
-			return dec.DecodeUntypedMap()
-		})
+		d := getDecoder()
+		defer putDecoder(d)
+
+		d.Reset(&resp.buf)
 
 		if l, err = d.DecodeMapLen(); err != nil {
 			return err
@@ -624,10 +624,10 @@ func (resp *ExecuteResponse) DecodeTyped(res interface{}) error {
 		info := &decodeInfo{}
 		var l int
 
-		d := msgpack.NewDecoder(&resp.buf)
-		d.SetMapDecoder(func(dec *msgpack.Decoder) (interface{}, error) {
-			return dec.DecodeUntypedMap()
-		})
+		d := getDecoder()
+		defer putDecoder(d)
+
+		d.Reset(&resp.buf)
 
 		if l, err = d.DecodeMapLen(); err != nil {
 			return err