You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@plc4x.apache.org by cd...@apache.org on 2021/01/31 11:20:21 UTC
[plc4x] 09/45: - Made the Udp and Tcp transport not log an error in
GetNumReadableBytes
This is an automated email from the ASF dual-hosted git repository.
cdutz pushed a commit to branch feature/plc4c
in repository https://gitbox.apache.org/repos/asf/plc4x.git
commit 45b82def69267de99c4a020735024ef0d7110874
Author: Christofer Dutz <ch...@c-ware.de>
AuthorDate: Fri Jan 22 12:04:33 2021 +0100
- Made the Udp and Tcp transport not log an error in GetNumReadableBytes
---
plc4go/internal/plc4go/spi/transports/tcp/TcpTransport.go | 2 +-
plc4go/internal/plc4go/spi/transports/udp/UdpTransport.go | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/plc4go/internal/plc4go/spi/transports/tcp/TcpTransport.go b/plc4go/internal/plc4go/spi/transports/tcp/TcpTransport.go
index 201e9af..38ea0fb 100644
--- a/plc4go/internal/plc4go/spi/transports/tcp/TcpTransport.go
+++ b/plc4go/internal/plc4go/spi/transports/tcp/TcpTransport.go
@@ -148,7 +148,7 @@ func (m *TcpTransportInstance) GetNumReadableBytes() (uint32, error) {
_, _ = m.reader.Peek(1)
return uint32(m.reader.Buffered()), nil
}
- return 0, errors.New("error getting number of available bytes from transport. No reader available")
+ return 0, nil
}
func (m *TcpTransportInstance) PeekReadableBytes(numBytes uint32) ([]uint8, error) {
diff --git a/plc4go/internal/plc4go/spi/transports/udp/UdpTransport.go b/plc4go/internal/plc4go/spi/transports/udp/UdpTransport.go
index dc2b4e0..99a6e54 100644
--- a/plc4go/internal/plc4go/spi/transports/udp/UdpTransport.go
+++ b/plc4go/internal/plc4go/spi/transports/udp/UdpTransport.go
@@ -177,7 +177,7 @@ func (m *UdpTransportInstance) GetNumReadableBytes() (uint32, error) {
_, _ = m.reader.Peek(1)
return uint32(m.reader.Buffered()), nil
}
- return 0, errors.New("error getting number of available bytes from transport. No reader available")
+ return 0, nil
}
func (m *UdpTransportInstance) PeekReadableBytes(numBytes uint32) ([]uint8, error) {