This is an automated email from the ASF dual-hosted git repository.
sruehl pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git
from 1df10e192e fix(plc4go): set last loop time to avoid wait cycle cpu burn
new 552e5a8b02 feat(plc4go): unify timeout handling
new 3deac8bb5f feat(plc4go)!: remove deprecated WithContext indirections
new 750dff6481 test(plc4go): fixed issues with concurrency
new 26d654a0e5 refactor(plc4go): simplified timeout handling by utilizing
ctx
new 6a19f2f563 feat(plc4go)!: change signature of blocking close to accept
ctx and return err
new d041a702ef feat(plc4go): expire expectations on shutdown
new 1753bd4d24 test(plc4go): fix randomly failing suite
new 68e9b54b49 test(plc4go): fix unstable tests
new 128dd5c9ef feat(plc4go)!: simplify connect and close
new 2872c716f8 feat(plc4go)!: simplify cache
new 749920c4e6 feat(plc4go/spi): expectation cancellation
new d3001a0c4e fix(plc4go/cbus): ensure we don't block too long on
bufferfill
new 7cf418bdca chore(plc4go): upgrade go version
The 13 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
plc4go/Makefile | 13 +-
plc4go/internal/ads/Connection.go | 57 +-
plc4go/internal/ads/DiscoveryMessageCodec.go | 12 +-
plc4go/internal/ads/Driver.go | 25 +-
plc4go/internal/ads/Interactions.go | 209 +--
plc4go/internal/ads/MessageCodec.go | 46 +-
plc4go/internal/ads/Reader.go | 3 +-
plc4go/internal/ads/Writer.go | 3 +-
plc4go/internal/ads/model/Tag.go | 2 +-
.../bacnetip/ApplicationLayerMessageCodec.go | 39 +-
plc4go/internal/bacnetip/Connection.go | 36 +-
plc4go/internal/bacnetip/Driver.go | 21 +-
plc4go/internal/bacnetip/MessageCodec.go | 23 +-
plc4go/internal/bacnetip/Reader.go | 3 +-
.../bacgopes/appservice/appservice_ClientSSM.go | 3 +-
.../bacgopes/appservice/appservice_ServerSSM.go | 3 +-
.../bacnetip/bacgopes/udp/udp_UDPDirector.go | 3 +-
plc4go/internal/cbus/Browser.go | 16 +-
plc4go/internal/cbus/Browser_test.go | 82 +-
plc4go/internal/cbus/CBusMessageMapper.go | 3 +-
plc4go/internal/cbus/Connection.go | 304 ++--
plc4go/internal/cbus/Connection_test.go | 477 ++----
plc4go/internal/cbus/Driver.go | 19 +-
plc4go/internal/cbus/Driver_test.go | 115 +-
plc4go/internal/cbus/MessageCodec.go | 58 +-
plc4go/internal/cbus/MessageCodec_test.go | 240 ++-
plc4go/internal/cbus/Query_test.go | 4 +-
plc4go/internal/cbus/Reader.go | 181 +--
plc4go/internal/cbus/Reader_test.go | 71 +-
plc4go/internal/cbus/Subscriber.go | 3 +-
plc4go/internal/cbus/Tag_test.go | 24 +-
plc4go/internal/cbus/Writer.go | 5 +-
plc4go/internal/cbus/Writer_test.go | 18 +-
plc4go/internal/eip/Connection.go | 523 +++---
plc4go/internal/eip/Driver.go | 23 +-
plc4go/internal/eip/MessageCodec.go | 14 +-
plc4go/internal/eip/Reader.go | 81 +-
plc4go/internal/knxnetip/Browser.go | 35 +-
plc4go/internal/knxnetip/Connection.go | 353 ++--
.../knxnetip/ConnectionDriverSpecificOperations.go | 61 +-
.../knxnetip/ConnectionInternalOperations.go | 1074 ++++++------
plc4go/internal/knxnetip/Discoverer.go | 6 +-
plc4go/internal/knxnetip/Driver.go | 17 +-
plc4go/internal/knxnetip/MessageCodec.go | 16 +-
plc4go/internal/knxnetip/Reader.go | 19 +-
plc4go/internal/knxnetip/Subscriber.go | 4 +-
plc4go/internal/knxnetip/SubscriptionEvent.go | 3 +-
plc4go/internal/knxnetip/ValueDecoder.go | 3 +-
plc4go/internal/modbus/AsciiDriver.go | 15 +-
plc4go/internal/modbus/Connection.go | 58 +-
plc4go/internal/modbus/MessageCodec.go | 34 +-
plc4go/internal/modbus/Reader.go | 6 +-
plc4go/internal/modbus/RtuDriver.go | 15 +-
plc4go/internal/modbus/TagHandler.go | 23 +-
plc4go/internal/modbus/TcpDriver.go | 15 +-
plc4go/internal/modbus/Writer.go | 7 +-
plc4go/internal/opcua/Connection.go | 111 +-
plc4go/internal/opcua/Driver.go | 25 +-
plc4go/internal/opcua/MessageCodec.go | 39 +-
plc4go/internal/opcua/SecureChannel.go | 757 ++++-----
plc4go/internal/opcua/Subscriber.go | 11 +-
plc4go/internal/opcua/SubscriptionHandle.go | 6 +-
plc4go/internal/s7/Connection.go | 121 +-
plc4go/internal/s7/Driver.go | 23 +-
plc4go/internal/s7/MessageCodec.go | 12 +-
plc4go/internal/s7/Reader.go | 5 +-
plc4go/internal/s7/TagHandler.go | 3 +-
plc4go/internal/s7/Writer.go | 4 +-
plc4go/internal/simulated/Connection.go | 152 +-
plc4go/internal/simulated/Connection_test.go | 181 +--
plc4go/internal/simulated/Device.go | 3 +-
plc4go/internal/simulated/Driver.go | 11 +-
plc4go/internal/simulated/Driver_test.go | 25 +-
plc4go/internal/simulated/Reader_test.go | 3 +-
plc4go/internal/simulated/Writer_test.go | 3 +-
plc4go/pkg/api/PlcConnection.go | 11 +-
plc4go/pkg/api/PlcConnectionCloseResult.go | 28 -
plc4go/pkg/api/PlcConnectionConnectResult.go | 54 -
plc4go/pkg/api/PlcDriver.go | 9 +-
plc4go/pkg/api/PlcDriverManager.go | 34 +-
plc4go/pkg/api/PlcDriverManger_test.go | 152 +-
plc4go/pkg/api/cache/PlcConnectionCache.go | 271 ++-
plc4go/pkg/api/cache/PlcConnectionCache_test.go | 544 ++-----
plc4go/pkg/api/cache/common.go | 35 -
plc4go/pkg/api/cache/connectionContainer.go | 81 +-
plc4go/pkg/api/cache/connectionContainer_test.go | 34 +-
plc4go/pkg/api/cache/mocks_test.go | 342 +---
plc4go/pkg/api/cache/plcConnectionLease.go | 100 +-
plc4go/pkg/api/cache/plcConnectionLease_test.go | 727 +++------
plc4go/pkg/api/mocks_test.go | 762 ++-------
plc4go/pkg/api/model/mocks_test.go | 391 +----
plc4go/pkg/api/model/plc_browse.go | 13 +-
plc4go/pkg/api/model/plc_read.go | 4 +-
plc4go/pkg/api/model/plc_subscription.go | 4 +-
plc4go/pkg/api/model/plc_unsubscription.go | 3 +-
plc4go/pkg/api/model/plc_write.go | 6 +-
.../pkg/api/plcConnectionConnectResult_plc4xgen.go | 82 -
plc4go/pom.xml | 2 +-
plc4go/spi/MessageCodec.go | 18 +-
plc4go/spi/PlcDiscoverer.go | 4 +-
plc4go/spi/default/DefaultBrowser_test.go | 13 +-
plc4go/spi/default/DefaultCodec.go | 86 +-
plc4go/spi/default/DefaultCodec_test.go | 431 ++---
plc4go/spi/default/DefaultConnection.go | 76 +-
plc4go/spi/default/DefaultConnection_test.go | 479 +-----
plc4go/spi/default/DefaultDriver.go | 14 +-
plc4go/spi/default/DefaultDriver_test.go | 80 +-
.../spi/default/DefaultPlcConnectionCloseResult.go | 65 -
.../default/DefaultPlcConnectionConnectResult.go | 47 -
plc4go/spi/default/defaultCodec_plc4xgen.go | 45 +-
plc4go/spi/default/defaultConnection_plc4xgen.go | 4 -
plc4go/spi/default/defaultExpectation.go | 19 +-
.../defaultPlcConnectionCloseResult_plc4xgen.go | 122 --
.../defaultPlcConnectionConnectResult_plc4xgen.go | 94 --
plc4go/spi/default/mock_requirements.go | 5 -
plc4go/spi/default/mocks_test.go | 1719 +++++---------------
.../SingleItemRequestInterceptor_test.go | 27 +-
plc4go/spi/interceptors/mocks_test.go | 128 +-
plc4go/spi/mocks_test.go | 254 +--
plc4go/spi/model/DefaultPlcBrowseRequest.go | 12 +-
plc4go/spi/model/DefaultPlcBrowseRequest_test.go | 80 +-
plc4go/spi/model/DefaultPlcReadRequest.go | 6 +-
plc4go/spi/model/DefaultPlcReadRequest_test.go | 57 +-
plc4go/spi/model/DefaultPlcSubscriptionRequest.go | 6 +-
.../model/DefaultPlcSubscriptionRequest_test.go | 42 +-
.../spi/model/DefaultPlcUnsubscriptionRequest.go | 6 +-
plc4go/spi/model/DefaultPlcWriteRequest.go | 6 +-
plc4go/spi/model/DefaultPlcWriteRequest_test.go | 59 +-
plc4go/spi/pool/executor_test.go | 2 +-
plc4go/spi/pool/future_test.go | 2 +-
plc4go/spi/testutils/DriverTestRunner.go | 35 +-
plc4go/spi/testutils/ManualTestRunner.go | 11 +-
plc4go/spi/testutils/ParserSerializerTestRunner.go | 6 +-
plc4go/spi/testutils/TestUtils.go | 8 +-
plc4go/spi/testutils/mocks_test.go | 184 +--
plc4go/spi/tracer/Tracer.go | 2 +-
.../transactions/RequestTransactionManager_test.go | 2 +-
plc4go/spi/transactions/RequestTransaction_test.go | 2 +-
plc4go/spi/transports/TransportInstance.go | 18 +-
plc4go/spi/transports/mocks_test.go | 184 +--
plc4go/spi/transports/pcap/TransportInstance.go | 12 +-
.../spi/transports/pcap/TransportInstance_test.go | 6 +-
plc4go/spi/transports/serial/TransportInstance.go | 14 +-
.../transports/serial/TransportInstance_test.go | 8 +-
plc4go/spi/transports/tcp/Transport.go | 2 +
plc4go/spi/transports/tcp/TransportInstance.go | 21 +-
.../spi/transports/tcp/TransportInstance_test.go | 56 +-
plc4go/spi/transports/test/Transport.go | 13 +-
plc4go/spi/transports/test/TransportInstance.go | 200 ++-
.../spi/transports/test/TransportInstance_test.go | 97 +-
plc4go/spi/transports/test/Transport_test.go | 35 +-
.../test/transportInstanceDrivenExtendedReader.go | 72 +
plc4go/spi/transports/udp/Transport.go | 12 +-
plc4go/spi/transports/udp/TransportInstance.go | 57 +-
.../spi/transports/udp/TransportInstance_test.go | 395 ++---
plc4go/spi/transports/udp/Transport_test.go | 65 +-
.../utils/DefaultBufferedTransportInstance.go | 57 +-
.../utils/DefaultBufferedTransportInstance_test.go | 135 +-
plc4go/spi/transports/utils/mocks_test.go | 229 ++-
plc4go/spi/utils/ArrayContext_test.go | 14 +-
plc4go/spi/utils/IdGenerator.go | 12 +-
plc4go/spi/utils/IdGenerator_test.go | 2 +-
plc4go/spi/values/WriteBufferPlcValueBased_test.go | 2 +-
plc4go/tests/drivers/tests/ads_driver_test.go | 3 +-
plc4go/tests/drivers/tests/knxnetip_driver_test.go | 3 +-
.../drivers/tests/manual_bacnet_PcapTest_test.go | 9 +-
.../tests/drivers/tests/manual_cbus_driver_test.go | 24 +-
.../drivers/tests/manual_opcua_driver_test.go | 9 +-
plc4go/tests/drivers/tests/modbus_driver_test.go | 3 +-
plc4go/tests/drivers/tests/s7_driver_test.go | 3 +-
170 files changed, 5564 insertions(+), 10176 deletions(-)
delete mode 100644 plc4go/pkg/api/PlcConnectionCloseResult.go
delete mode 100644 plc4go/pkg/api/PlcConnectionConnectResult.go
delete mode 100644 plc4go/pkg/api/plcConnectionConnectResult_plc4xgen.go
delete mode 100644 plc4go/spi/default/DefaultPlcConnectionCloseResult.go
delete mode 100644 plc4go/spi/default/DefaultPlcConnectionConnectResult.go
delete mode 100644
plc4go/spi/default/defaultPlcConnectionCloseResult_plc4xgen.go
delete mode 100644
plc4go/spi/default/defaultPlcConnectionConnectResult_plc4xgen.go
create mode 100644
plc4go/spi/transports/test/transportInstanceDrivenExtendedReader.go
