| server/clienter.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| server/server.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
server/clienter.go
@@ -37,7 +37,7 @@ // 实现OnRegister func (c *Clients) OnRegister(cli *client.Client, msg *aiot.Protocol) error { Srv.RegisterDevice(msg, cli) Srv.RegisterDevice(cli, msg) go Srv.serverCallBack.OnRegister(cli, msg) msgFeedBack := &aiot.Protocol{ Receiver: aiot.RECEIVER_TO_MASTER, server/server.go
@@ -265,7 +265,7 @@ } // 处理设备注册 func (s *Server) RegisterDevice(msg *aiot.Protocol, cli *client.Client) { func (s *Server) RegisterDevice(cli *client.Client, msg *aiot.Protocol) { // 设置节点ID cli.SetDeviceId(msg.SenderId) // 添加集群ID
