Skip to content
Permalink
Browse files
Fix: inc write package number when err == nil in WritePkg
  • Loading branch information
AlexStocks authored and watermelo committed Jul 18, 2020
1 parent a5defb4 commit 96ceb76710641fc5e2ddb43d5c60d202f1635063
Showing 1 changed file with 2 additions and 3 deletions.
@@ -371,10 +371,9 @@ func (s *session) WritePkg(pkg interface{}, timeout time.Duration) error {
var err error
if timeout <= 0 {
if err = s.writer.Write(s, pkg); err != nil {
s.incWritePkgNum()
// gxlog.CError("after incWritePkgNum, ss:%s", s.Stat())
return perrors.WithStack(err)
}
return perrors.WithStack(err)
s.incWritePkgNum()
}
select {
case s.wQ <- pkg:

0 comments on commit 96ceb76

Please sign in to comment.