You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@plc4x.apache.org by sr...@apache.org on 2023/06/16 22:00:05 UTC
[plc4x] 01/02: feat(plc4go/spi): refined logging of Default Connection
This is an automated email from the ASF dual-hosted git repository.
sruehl pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git
commit e6c897c97a59060cc7074f58ee58198e73b7ab52
Author: Sebastian Rühl <sr...@apache.org>
AuthorDate: Fri Jun 16 23:59:10 2023 +0200
feat(plc4go/spi): refined logging of Default Connection
---
plc4go/spi/default/DefaultConnection.go | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/plc4go/spi/default/DefaultConnection.go b/plc4go/spi/default/DefaultConnection.go
index 3ff36e787f..3334de849b 100644
--- a/plc4go/spi/default/DefaultConnection.go
+++ b/plc4go/spi/default/DefaultConnection.go
@@ -288,8 +288,11 @@ func (d *defaultConnection) Close() <-chan plc4go.PlcConnectionCloseResult {
var err error
if transportInstance := d.GetTransportInstance(); transportInstance != nil {
d.log.Trace().Msg("closing transport instance")
- err = transportInstance.Close()
- d.log.Trace().Err(err).Msg("transport instance closed")
+ if err = transportInstance.Close(); err != nil {
+ d.log.Warn().Err(err).Msg("Error disconnecting transport instance")
+ } else {
+ d.log.Trace().Msg("transport instance closed")
+ }
}
d.SetConnected(false)
ch := make(chan plc4go.PlcConnectionCloseResult, 1)