Commit 5702c16e authored by alexstocks's avatar alexstocks

add leaky package logs

parent 4a0f0138
...@@ -396,6 +396,8 @@ LOOP: ...@@ -396,6 +396,8 @@ LOOP:
if flag { if flag {
this.listener.OnMessage(this, inPkg) this.listener.OnMessage(this, inPkg)
this.incReadPkgCount() this.incReadPkgCount()
} else {
log.Info("[session.handleLoop] drop readin package{%#v}", inPkg)
} }
case outPkg = <-this.wQ: case outPkg = <-this.wQ:
...@@ -407,6 +409,8 @@ LOOP: ...@@ -407,6 +409,8 @@ LOOP:
// break LOOP // break LOOP
} }
this.incWritePkgCount() this.incWritePkgCount()
} else {
log.Info("[session.handleLoop] drop writeout package{%#v}", outPkg)
} }
case <-ticker.C: case <-ticker.C:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment