Revert "Dev (#71)"

This reverts commit ee91271.

tars/adapter.go

@@ -55,6 +55,13 @@ func (c *AdapterProxy) ParsePackage(buff []byte) (int, int) {
 
 // Recv : Recover read channel when closed for timeout
 func (c *AdapterProxy) Recv(pkg []byte) {
+	defer func() {
+		// TODO readCh has a certain probability to be closed after the load, and we need to recover
+		// Maybe there is a better way
+		if err := recover(); err != nil {
+			TLOG.Error("recv pkg painc:", err)
+		}
+	}()
 	packet := requestf.ResponsePacket{}
 	err := packet.ReadFrom(codec.NewReader(pkg))
 	if err != nil {
@@ -65,11 +72,7 @@ func (c *AdapterProxy) Recv(pkg []byte) {
 	if ok {
 		ch := chIF.(chan *requestf.ResponsePacket)
 		TLOG.Debug("IN:", packet)
-		select {
-		case ch <- &packet:
-		default:
-			close(ch)
-		}
+		ch <- &packet
 	} else {
 		TLOG.Error("timeout resp,drop it:", packet.IRequestId)
 	}

tars/object.go

@@ -38,12 +38,13 @@ func (obj *ObjectProxy) Invoke(ctx context.Context, msg *Message, timeout time.D
 	}
 	msg.Adp = adp
 	atomic.AddInt32(&obj.queueLen, 1)
-	readCh := make(chan *requestf.ResponsePacket)
+	readCh := make(chan *requestf.ResponsePacket, 1)
 	adp.resp.Store(msg.Req.IRequestId, readCh)
 	defer func() {
 		checkPanic()
 		atomic.AddInt32(&obj.queueLen, -1)
 		adp.resp.Delete(msg.Req.IRequestId)
+		close(readCh)
 	}()
 	if err := adp.Send(msg.Req); err != nil {
 		return err

tars/util/rogger/logger.go

@@ -56,6 +56,8 @@ func init() {
 	currDateDay = now.Format("20060102")
 	go func() {
 		tm := time.NewTimer(time.Second)
+		if err := recover(); err != nil { // avoid timer panic
+		}
 		for {
 			now := time.Now()
 			d := time.Second - time.Duration(now.Nanosecond())