set write timeout in session.go:(Session)WritePkg

README.md

@@ -15,7 +15,9 @@
     >
     > 2 delete session.go:(Session)handlePackage Last clause
     >
-    > 3 version: 0.3.07
+    > 3 set write timeout in session.go:(Session)WritePkg
+    >
+    > 4 version: 0.3.07
     
 - 2016/09/08
 	> 1 rewrite session.go:(Session)handlePackage() error handle logic

session.go

@@ -311,7 +311,8 @@ func (this *Session) WritePkg(pkg interface{}) error {
 	case this.wQ <- pkg:
 		break // for possible gen a new pkg
 
-	default:
+	// default:
+	case time.After(this.wDeadline):
 		log.Warn("%s, [session.WritePkg] wQ{len:%d, cap:%d}", this.Stat(), len(this.wQ), cap(this.wQ))
 		return ErrSessionBlocked
 	}