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/08/01 19:18:11 UTC
[plc4x] 06/13: - Added new KnxManufacturers
This is an automated email from the ASF dual-hosted git repository.
cdutz pushed a commit to branch feature/profinet-chris
in repository https://gitbox.apache.org/repos/asf/plc4x.git
commit 52c28a0e24a3743940bda238e465a61b6962735c
Author: cdutz <ch...@c-ware.de>
AuthorDate: Sun Aug 1 19:50:52 2021 +0200
- Added new KnxManufacturers
---
plc4go/internal/plc4go/spi/transports/tcp/Transport.go | 4 ++--
plc4go/internal/plc4go/spi/transports/test/Transport.go | 2 +-
plc4go/internal/plc4go/spi/transports/udp/Transport.go | 4 ++--
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/plc4go/internal/plc4go/spi/transports/tcp/Transport.go b/plc4go/internal/plc4go/spi/transports/tcp/Transport.go
index 8de8272..41d0989 100644
--- a/plc4go/internal/plc4go/spi/transports/tcp/Transport.go
+++ b/plc4go/internal/plc4go/spi/transports/tcp/Transport.go
@@ -152,13 +152,13 @@ func (m *TransportInstance) GetNumReadableBytes() (uint32, error) {
if m.reader == nil {
return 0, nil
}
- peekChan := make (chan bool)
+ peekChan := make(chan bool)
go func() {
_, _ = m.reader.Peek(1)
peekChan <- true
}()
select {
- case <- peekChan:
+ case <-peekChan:
return uint32(m.reader.Buffered()), nil
case <-time.After(10 * time.Millisecond):
return 0, nil
diff --git a/plc4go/internal/plc4go/spi/transports/test/Transport.go b/plc4go/internal/plc4go/spi/transports/test/Transport.go
index 637e5c1..e613d1b 100644
--- a/plc4go/internal/plc4go/spi/transports/test/Transport.go
+++ b/plc4go/internal/plc4go/spi/transports/test/Transport.go
@@ -57,7 +57,7 @@ func (m Transport) CreateTransportInstance(transportUrl url.URL, options map[str
type TransportInstance struct {
readBuffer []byte
writeBuffer []byte
- connected bool
+ connected bool
transport *Transport
}
diff --git a/plc4go/internal/plc4go/spi/transports/udp/Transport.go b/plc4go/internal/plc4go/spi/transports/udp/Transport.go
index 6c09bbc..940b9e7 100644
--- a/plc4go/internal/plc4go/spi/transports/udp/Transport.go
+++ b/plc4go/internal/plc4go/spi/transports/udp/Transport.go
@@ -181,13 +181,13 @@ func (m *TransportInstance) GetNumReadableBytes() (uint32, error) {
if m.reader == nil {
return 0, nil
}
- peekChan := make (chan bool)
+ peekChan := make(chan bool)
go func() {
_, _ = m.reader.Peek(1)
peekChan <- true
}()
select {
- case <- peekChan:
+ case <-peekChan:
return uint32(m.reader.Buffered()), nil
case <-time.After(10 * time.Millisecond):
return 0, nil