Skip to content

G
getty
Commit 3e33cb58 authored by pantianying's avatar pantianying Committed by watermelo
Browse files
Options

change log

parent 5f47c4d9
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 4 deletions
session.go
View file @ 3e33cb58
...@@ -569,8 +569,6 @@ func (s *session) handlePackage() { ...@@ -569,8 +569,6 @@ func (s *session) handlePackage() {
) )
defer func() { defer func() {
var grNum int32
if r := recover(); r != nil { if r := recover(); r != nil {
const size = 64 << 10 const size = 64 << 10
rBuf := make([]byte, size) rBuf := make([]byte, size)
...@@ -579,7 +577,7 @@ func (s *session) handlePackage() { ...@@ -579,7 +577,7 @@ func (s *session) handlePackage() {
} }
close(s.handlePackageDone) close(s.handlePackageDone)
log.Infof("%s, [session.handlePackage] gr will exit now, left gr num %d", s.sessionToken(), grNum) log.Infof("%s, [session.handlePackage] gr will exit now", s.sessionToken())
s.stop() s.stop()
if err != nil { if err != nil {
log.Errorf("%s, [session.handlePackage] error:%+v", s.sessionToken(), err) log.Errorf("%s, [session.handlePackage] error:%+v", s.sessionToken(), err)
...@@ -856,6 +854,6 @@ func (s *session) gc() { ...@@ -856,6 +854,6 @@ func (s *session) gc() {
// or (session)handleLoop automatically. It's thread safe. // or (session)handleLoop automatically. It's thread safe.
func (s *session) Close() { func (s *session) Close() {
s.stop() s.stop()
log.Info("%s closed now. its current gr num is %d", log.Info("%s closed now.",
s.sessionToken()) s.sessionToken())
} }
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