remove comment

gateway/rpc/server.go

@@ -51,7 +51,6 @@ func (svr *Server) handleRequest(req *Request) {
 		val interface{}
 		ctx *Context
 	)
-	log.Debugf("rcp handle request %s@%d", req.Method, req.Sequence)
 	if val, ok = svr.serviceMap.Load(req.Method); ok {
 		cb = val.(HandleFunc)
 		ctx = svr.getContext()
@@ -62,9 +61,7 @@ func (svr *Server) handleRequest(req *Request) {
 				Sequence: req.Sequence,
 				Data:     ctx.Response().Bytes(),
 			}); err != nil {
-				log.Warnf("rcp write %d response error: %s", req.Sequence, err.Error())
-			} else {
-				log.Debugf("rcp write %d response success", req.Sequence)
+				log.Warnf("RPC: write sequence(%d) response failed cause by: %s", req.Sequence, err.Error())
 			}
 		}
 	} else {
@@ -78,9 +75,7 @@ func (svr *Server) handleRequest(req *Request) {
 			Sequence: req.Sequence,
 			Data:     ctx.Response().Bytes(),
 		}); err != nil {
-			log.Warnf("rcp write %d response error: %s", req.Sequence, err.Error())
-		} else {
-			log.Debugf("rcp write %d response success", req.Sequence)
+			log.Warnf("RPC: write sequence(%d) response failed cause by: %s", req.Sequence, err.Error())
 		}
 	}
 }
@@ -100,19 +95,18 @@ func (svr *Server) process(conn net.Conn) {
 		switch frame.Func {
 		case FuncPing:
 			if err = writeFrame(conn, &Frame{Func: FuncPing}); err != nil {
-				log.Warnf("rcp write ping frame error: %s", err.Error())
+				log.Warnf("RPC: write ping frame error: %s", err.Error())
 			}
 		case FuncRequest:
 			//读取一个请求
 			if req, err2 := ReadRequest(frame.Data); err2 == nil {
 				req.reset(frame.Sequence, conn)
-				log.Debugf("rcp read request %s@%d from %s", req.Method, req.Sequence, req.RemoteAddr().String())
 				select {
 				case svr.ch <- req:
 				default:
 				}
 			} else {
-				log.Warnf("read rpc request error: %s", err2.Error())
+				log.Warnf("RPC: read request error: %s", err2.Error())
 			}
 		}
 	}