Commit f0b4eda9 authored by AlexStocks's avatar AlexStocks

Rem: delete fk log and check error

parent 73f345dd
......@@ -176,7 +176,7 @@
END OF TERMS AND CONDITIONS
Copyright 2016 ~ 2017 Alex Stocks.
Copyright 2016 ~ 2018 Alex Stocks.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
......
......@@ -320,13 +320,12 @@ 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 {
if err = s.writer.Write(s, pkg); err != nil {
s.incWritePkgNum()
gxlog.CError("after incWritePkgNum, ss:%s", s.Stat())
}
return err
}
gxlog.CError("fk")
select {
case s.wQ <- pkg:
break // for possible gen a new pkg
......
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