This is an automated email from the ASF dual-hosted git repository.
cdutz pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git
The following commit(s) were added to refs/heads/develop by this push:
new c87455a - Made the Udp and Tcp transport not log an error in
GetNumReadableBytes
c87455a is described below
commit c87455abf4c1d2428ece8f98ea77caf5b3997b71
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) {
