log idle connection closing

aldas · Jul 27, 2023 · 1e0c40a · 1e0c40a
1 parent b9c1f75
commit 1e0c40a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/server/server.go b/server/server.go
@@ -22,7 +22,8 @@ const (
 
 var (
 	// ErrServerClosed is returned when server context is ended (by shutdown)
-	ErrServerClosed = errors.New("modbus server closed")
+	ErrServerClosed      = errors.New("modbus server closed")
+	ErrServerIdleTimeout = errors.New("modbus server closed idle connection")
 )
 
 // PacketAssembler is called when server reads data from client connection. Is responsible for assembling data read
@@ -253,6 +254,7 @@ func (c *connection) handle(ctx context.Context) {
 		if n > 0 {
 			lastReceived = time.Now()
 		} else if time.Now().Sub(lastReceived) > idleTimeout {
+			c.onErrorFunc(ErrServerIdleTimeout)
 			return // close idle connection
 		} else {
 			continue // nothing read and not idle yet