Merge pull request #3162 from TianTianBigWang/release-1.8-modbus-slaveid

cherry pick of #3117: fix modbus slaveID cannot be 0

cloud/pkg/apis/devices/v1alpha2/device_instance_types.go

@@ -92,7 +92,7 @@ type ProtocolConfigOpcUA struct {
 // Only one of its members may be specified.
 type ProtocolConfigModbus struct {
 	// Required. 0-255
-	SlaveID int64 `json:"slaveID,omitempty"`
+	SlaveID *int64 `json:"slaveID,omitempty"`
 }
 
 // Only one of COM or TCP may be specified.

cloud/pkg/apis/devices/v1alpha2/zz_generated.deepcopy.go

@@ -501,7 +501,7 @@ func (in *ProtocolConfig) DeepCopyInto(out *ProtocolConfig) {
 	if in.Modbus != nil {
 		in, out := &in.Modbus, &out.Modbus
 		*out = new(ProtocolConfigModbus)
-		**out = **in
+		(*in).DeepCopyInto(*out)
 	}
 	if in.Bluetooth != nil {
 		in, out := &in.Bluetooth, &out.Bluetooth
@@ -616,6 +616,11 @@ func (in *ProtocolConfigCustomized) DeepCopy() *ProtocolConfigCustomized {
 // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
 func (in *ProtocolConfigModbus) DeepCopyInto(out *ProtocolConfigModbus) {
 	*out = *in
+	if in.SlaveID != nil {
+		in, out := &in.SlaveID, &out.SlaveID
+		*out = new(int64)
+		**out = **in
+	}
 	return
 }
 

cloud/test/integration/fixtures/device.go

@@ -19,6 +19,7 @@ package fixtures
 import (
 	v1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/utils/pointer"
 
 	"github.com/kubeedge/kubeedge/cloud/pkg/apis/devices/v1alpha2"
 )
@@ -76,7 +77,7 @@ func withProtocolConfig(protocol deviceProtocol) DeviceOption {
 		case deviceProtocolModbusRTU:
 			op.device.Spec.Protocol = v1alpha2.ProtocolConfig{
 				Modbus: &v1alpha2.ProtocolConfigModbus{
-					SlaveID: 1,
+					SlaveID: pointer.Int64Ptr(1),
 				},
 				Common: &v1alpha2.ProtocolConfigCommon{
 					COM: &v1alpha2.ProtocolConfigCOM{},
@@ -85,7 +86,7 @@ func withProtocolConfig(protocol deviceProtocol) DeviceOption {
 		case deviceProtocolModbusTCP:
 			op.device.Spec.Protocol = v1alpha2.ProtocolConfig{
 				Modbus: &v1alpha2.ProtocolConfigModbus{
-					SlaveID: 1,
+					SlaveID: pointer.Int64Ptr(1),
 				},
 				Common: &v1alpha2.ProtocolConfigCommon{
 					TCP: &v1alpha2.ProtocolConfigTCP{},
@@ -140,7 +141,7 @@ func withStopBits(stopBits int64) DeviceOption {
 
 func withSlaveID(slaveID int64) DeviceOption {
 	return func(op *DeviceOp) {
-		op.device.Spec.Protocol.Modbus.SlaveID = slaveID
+		op.device.Spec.Protocol.Modbus.SlaveID = &slaveID
 	}
 }
 
@@ -152,7 +153,7 @@ func withTCPPort(port int64) DeviceOption {
 
 func withTCPSlaveID(tcpSlaveID int64) DeviceOption {
 	return func(op *DeviceOp) {
-		op.device.Spec.Protocol.Modbus.SlaveID = tcpSlaveID
+		op.device.Spec.Protocol.Modbus.SlaveID = &tcpSlaveID
 	}
 }
 

docs/proposals/device-management-enhance.md

@@ -118,7 +118,7 @@ type ProtocolConfig struct {
 
 type ProtocolConfigModbus struct {
 	// Required. 0-255
-	SlaveID int64 `json:"slaveID,omitempty"`
+	SlaveID *int64 `json:"slaveID,omitempty"`
 }
 
 // Only one of COM or TCP may be specified.

tests/e2e/utils/device.go

@@ -862,7 +862,7 @@ func UpdatedModbusDeviceInstance(nodeSelector string) v1alpha2.Device {
 			},
 			Protocol: v1alpha2.ProtocolConfig{
 				Modbus: &v1alpha2.ProtocolConfigModbus{
-					SlaveID: 1,
+					SlaveID: pointer.Int64Ptr(1),
 				},
 				Common: &v1alpha2.ProtocolConfigCommon{
 					COM: &v1alpha2.ProtocolConfigCOM{
@@ -1591,7 +1591,7 @@ func UpdatedConfigMapModbusForDataAndTwins(nodeSelector string) v12.ConfigMap {
 			Name:     "modbus-sensor-tag-instance-02",
 			Protocol: "modbus",
 			ProtocolConfig: &v1alpha2.ProtocolConfigModbus{
-				SlaveID: 1,
+				SlaveID: pointer.Int64Ptr(1),
 			},
 			ProtocolCommonConfig: &v1alpha2.ProtocolConfigCommon{
 				COM: &v1alpha2.ProtocolConfigCOM{