Merge pull request #25 from divebomb/master

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

Merge pull request #25 from divebomb/master
Fix: inc write package number when err == nil in WritePkg
34d2a349 · 望哥 · GitHub · 6de78d9d · 2282528a · 34d2a349
Unverified Commit 34d2a349 authored Sep 05, 2019 by 望哥 Committed by GitHub Sep 05, 2019
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: