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 <[email protected]> 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) {
