Optimizing buffer

Author: dobyte

core/buffer/bytes.go

@@ -3,8 +3,6 @@ package buffer
 import (
 	"sync"
 	"sync/atomic"
-
-	"github.com/dobyte/due/v2/log"
 )
 
 type Bytes struct {
@@ -18,9 +16,7 @@ var _ Buffer = (*Bytes)(nil)
 
 // NewBytes 以指定buf创建字节
 func NewBytes(buf []byte) *Bytes {
-	b := &Bytes{buf: buf, off: len(buf)}
-	log.Errorf("Bytes Malloc %p, acquire cap: %d, actual cap: %d\n", b, len(buf), b.Cap())
-	return b
+	return &Bytes{buf: buf, off: len(buf)}
 }
 
 // NewBytesWithCapacity 以指定容量创建字节
@@ -66,8 +62,6 @@ func (b *Bytes) Bytes() []byte {
 
 // Release 释放
 func (b *Bytes) Release() {
-	log.Errorf("Bytes Release %p, cap: %d\n", b, b.Cap())
-
 	b.off = 0
 
 	if b.pool != nil {

core/buffer/bytes_pool.go

@@ -3,8 +3,6 @@ package buffer
 import (
 	"math"
 	"sync"
-
-	"github.com/dobyte/due/v2/log"
 )
 
 var defaultBytesPool = NewBytesPool(32)
@@ -50,8 +48,6 @@ func (p *BytesPool) Get(cap int) *Bytes {
 	b.off = cap
 	b.released.Store(false)
 
-	log.Errorf("Bytes Malloc %p, acquire cap: %d, actual cap: %d\n", b, cap, b.Cap())
-
 	return b
 }
 

internal/transporter/internal/client/client.go

@@ -14,7 +14,7 @@ import (
 
 const (
 	defaultTimeout = 3 * time.Second // 调用超时时间
-	defaultConnNum = 1               // 默认连接数
+	defaultConnNum = 10              // 默认连接数
 )
 
 type chWrite struct {