瀏覽代碼

feat: optimize log

lijian 2 年之前
父節點
當前提交
0b72f8dc0a
共有 3 個文件被更改,包括 2 次插入4 次删除
  1. 2 2
      pkg/mqtt/connection.go
  2. 0 1
      pkg/server/tcp_server.go
  3. 0 1
      services/mqttaccess/mqtt_provider.go

+ 2 - 2
pkg/mqtt/connection.go

@@ -143,7 +143,7 @@ func (c *Connection) Close() {
 func (c *Connection) RcvMsgFromClient() {
 	conn := c.Conn
 	host := conn.RemoteAddr().String()
-	server.Log.Infof("recieve new connection from %s", host)
+	server.Log.Infof("receive new connection from %s", host)
 	for {
 		msg, err := DecodeOneMessage(conn)
 		if err != nil {
@@ -196,7 +196,7 @@ func (c *Connection) RcvMsgFromClient() {
 			}
 			err = c.ValidateToken(token)
 			if err != nil {
-				server.Log.Errorf("validate token error : %v", err)
+				server.Log.Errorf("validate device token error. deviceid : %v, token : %2X, error: %v", c.DeviceCode, token, err)
 				ret = RetCodeNotAuthorized
 				c.Close()
 				return

+ 0 - 1
pkg/server/tcp_server.go

@@ -68,7 +68,6 @@ func (ts *TCPServer) Start() error {
 				Log.Errorf(errNewConnection, err.Error())
 				continue
 			}
-			Log.Infof("accepting new connection %s", conn.RemoteAddr())
 			go ts.handler.Handle(conn)
 		}
 	}()

+ 0 - 1
services/mqttaccess/mqtt_provider.go

@@ -23,7 +23,6 @@ func (mp *MQTTProvider) ValidateDeviceToken(deviceid string, token []byte) error
 	reply := rpcs.ReplyValidateDeviceAccessToken{}
 	err := server.RPCCallByName(nil, rpcs.DeviceManagerName, "DeviceManager.ValidateDeviceAccessToken", args, &reply)
 	if err != nil {
-		server.Log.Errorf("validate device token error. deviceid : %v, token : %v, error: %v", deviceid, token, err)
 		return err
 	}
 	return nil