Fix: inc write package number when err == nil in WritePkg

96ceb767 · AlexStocks · watermelo · a5defb42 · 96ceb767
Commit 96ceb767 authored Sep 05, 2019 by AlexStocks Committed by watermelo Jul 18, 2020
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 3 deletions

session.go session.go +2 -3

No files found.
--- a/session.go
+++ b/session.go
@@ -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: