diff --git a/model/cache_pool.go b/model/cache_pool.go index 0c940f3..8e5e348 100644 --- a/model/cache_pool.go +++ b/model/cache_pool.go @@ -4,8 +4,6 @@ import ( "fmt" "reflect" "unsafe" - - log "github.com/sirupsen/logrus" ) @@ -24,9 +22,9 @@ func NewSliceBufferPool(name string, bufferSize int) (sbp *sliceBufferPool) { } func (sbp *sliceBufferPool) Enqueue(buffer []byte) { - defer func() { - log.Debugf("after enqueue from %s, there is %d elements", sbp.name, len(sbp.queue)) - }() + // defer func() { + // log.Debugf("after enqueue from %s, there is %d elements", sbp.name, len(sbp.queue)) + // }() if cap(buffer) < 1 { return @@ -52,9 +50,9 @@ func (sbp *sliceBufferPool) DequeueWithInit(initSize int) (buffer []byte) { } func (sbp *sliceBufferPool) Dequeue() (buffer []byte) { - defer func() { - log.Debugf("after dequeue from %s, there is %d elements", sbp.name, len(sbp.queue)) - }() + // defer func() { + // log.Debugf("after dequeue from %s, there is %d elements", sbp.name, len(sbp.queue)) + // }() select { case buffer = <- sbp.queue: diff --git a/session-dealer/mysql/cover_range.go b/session-dealer/mysql/cover_range.go index eb405d7..7654c30 100644 --- a/session-dealer/mysql/cover_range.go +++ b/session-dealer/mysql/cover_range.go @@ -1,9 +1,5 @@ package mysql -import ( - log "github.com/sirupsen/logrus" -) - // coverageNode record tcp package begin and end seq id type coverageNode struct { begin int64 @@ -105,7 +101,7 @@ func (crp *coveragePool) NewCoverage(begin, end int64)(cn *coverageNode) { } func (crp *coveragePool) Enqueue(cn *coverageNode) { - log.Debugf("coveragePool enqueue: %d", len(crp.queue)) + // log.Debugf("coveragePool enqueue: %d", len(crp.queue)) if cn == nil { return } @@ -114,7 +110,7 @@ func (crp *coveragePool) Enqueue(cn *coverageNode) { } func (crp *coveragePool) Dequeue() (cn *coverageNode) { - log.Debugf("coveragePool dequeue: %d", len(crp.queue)) + // log.Debugf("coveragePool dequeue: %d", len(crp.queue)) defer func() { cn.begin = -1