execute sleep only if we have the delay value greater than zero

Signed-off-by: Jeeva Kandasamy <[email protected]>
mycontroller-org · Oct 27, 2023 · a6f8d19 · a6f8d19
1 parent 7dcaf7b
commit a6f8d19
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 3 deletions.
diff --git a/plugin/device/ethernet/device.go b/plugin/device/ethernet/device.go
@@ -91,7 +91,11 @@ func (ep *Endpoint) Write(message *types.Message) error {
 	if message == nil || len(message.Data) == 0 {
 		return nil
 	}
-	time.Sleep(ep.txPreDelay) // transmit pre delay
+
+	if ep.txPreDelay > 0 {
+		time.Sleep(ep.txPreDelay) // transmit pre delay
+	}
+
 	_, err := ep.conn.Write(append(message.Data, *ep.Config.MessageSplitter))
 	return err
 }

diff --git a/plugin/device/mqtt/device.go b/plugin/device/mqtt/device.go
@@ -135,7 +135,9 @@ func (ep *Endpoint) Write(message *model.Message) error {
 	topic := message.Others.GetString(model.KeyMqttTopic)
 	qos := byte(ep.Config.QoS)
 
-	time.Sleep(ep.txPreDelay) // transmit pre delay
+	if ep.txPreDelay > 0 {
+		time.Sleep(ep.txPreDelay) // transmit pre delay
+	}
 
 	for _, rawtopic := range strings.Split(ep.Config.Publish, ",") {
 		_topic := strings.TrimSpace(rawtopic)

diff --git a/plugin/device/serial/device.go b/plugin/device/serial/device.go
@@ -90,7 +90,10 @@ func (ep *Endpoint) Write(message *types.Message) error {
 	if message == nil && len(message.Data) > 0 {
 		return nil
 	}
-	time.Sleep(ep.txPreDelay) // transmit pre delay
+
+	if ep.txPreDelay > 0 {
+		time.Sleep(ep.txPreDelay) // transmit pre delay
+	}
 	_, err := ep.Port.Write(append(message.Data, *ep.Config.MessageSplitter))
 	if err != nil {
 		ep.statusFunc(&types.State{