|
@@ -28,6 +28,7 @@ func (mp *MQTTProvider) ValidateDeviceToken(deviceid string, token []byte) error
|
|
|
return nil
|
|
|
}
|
|
|
func (mp *MQTTProvider) OnDeviceOnline(args rpcs.ArgsGetOnline, VendorId string) error {
|
|
|
+ deviceOnlineCount.Inc()
|
|
|
reply := rpcs.ReplyGetOnline{}
|
|
|
err := server.RPCCallByName(nil, rpcs.DeviceManagerName, "DeviceManager.GetOnline", args, &reply)
|
|
|
if err != nil {
|
|
@@ -40,10 +41,11 @@ func (mp *MQTTProvider) OnDeviceOnline(args rpcs.ArgsGetOnline, VendorId string)
|
|
|
if err = server.RPCCallByName(nil, rpcs.ControllerName, "Controller.Online", &cArgs, &cReply); err != nil {
|
|
|
return err
|
|
|
}
|
|
|
- deviceOnlineCount.Inc()
|
|
|
+
|
|
|
return err
|
|
|
}
|
|
|
func (mp *MQTTProvider) OnDeviceOffline(deviceid string, vendorId string) error {
|
|
|
+ deviceOnlineCount.Dec()
|
|
|
args := rpcs.ArgsGetOffline{
|
|
|
Id: deviceid,
|
|
|
VendorId: vendorId,
|
|
@@ -60,7 +62,7 @@ func (mp *MQTTProvider) OnDeviceOffline(deviceid string, vendorId string) error
|
|
|
if err = server.RPCCallByName(nil, rpcs.ControllerName, "Controller.Offline", &cArgs, &cReply); err != nil {
|
|
|
return err
|
|
|
}
|
|
|
- deviceOnlineCount.Dec()
|
|
|
+
|
|
|
return err
|
|
|
}
|
|
|
func (mp *MQTTProvider) OnDeviceHeartBeat(deviceid string) error {
|