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 2023/06/14 14:02:54 UTC
[plc4x] branch chore/profinet-phase-3 updated (fb50bd2703 -> 62933b6676)
This is an automated email from the ASF dual-hosted git repository.
cdutz pushed a change to branch chore/profinet-phase-3
in repository https://gitbox.apache.org/repos/asf/plc4x.git
from fb50bd2703 chore(plc4j/profinet-ng): - Minor work on the subscriptions
add 78ae3b6430 fix(plc4go): always supply stack when recovering
add 29efaa49b5 build(deps): bump iot-device-client from 2.1.5 to 2.2.0 (#981)
add a5901dcba1 build(deps): bump buildnumber-maven-plugin from 3.1.0 to 3.2.0 (#980)
add 9cf3b3435a chore(build): put test report in separate workflow
add 26a8179ad0 chore(build): fix java test report action name
add 9c2c05d8bc chore(build): fix report path
add 8544a45057 chore(build): fix report paths
add 1bf079bd41 chore(build): disable java mac/ubuntu reporting due to failure Error: RangeError: Maximum call stack size exceeded
add 8d59712f01 chore(build): disable java mac/ubuntu reporting due to failure Error: RangeError: Maximum call stack size exceeded
add 81273fc4f9 chore(build): rename workflow to align with others
add 524c2c836f refactor(plc4go): deduplicate package name out of struct names
add 41b82bd16f refactor(plc4go): general QC pass
add b744cc9afd test(plc4go/cbus): add tests for static helper
add 2925224e3c Fix/www (#984)
add b62c5af3d7 build(deps): bump guava from 32.0.0-jre to 32.0.1-jre (#983)
add 239e85a986 build(deps): bump nifi.version from 1.21.0 to 1.22.0 (#985)
add 4c0e1cb532 test(plc4go): hook in testing logger were not done yet
add 9dd16ed55a feat(plc4go): ensure right logger is used when creating a transport instance
add 66915585b2 test(plc4go): improve logging of driver test runner and test transport
add ec7fa0e36e chore(plc4go): update mockery
add 84be4cbb1f feat(plc4go): update to go 1.20.5
add 1b9f8b9fd9 chore(site): re-add deleted index.adoc
add f75dd21d3d Fix/www (#987)
add ee99a371eb refactor(plc4go/spi): improve code flow of read and write request
add 30aa44ce21 test(plc4go/cbus): add logging to hunt down randomly failing test
add 3f9249ca68 test(plc4go/cbus): log error on trace on all units or all attributes
add 11a11bd161 build(deps): bump ecj from 3.32.0 to 3.34.0 (#989)
add ff1810481f build(deps): bump asciidoctorj-diagram from 2.2.8 to 2.2.9 (#986)
add d7d54912ee refactor(plc4go/spi): split up request transaction into separate file
add ade510700a refactor(plc4go/spi): split up pool into multiple files
add caa9718473 feat(plc4go/spi): added more Stringer implementations
add 5422176096 feat(plc4go/cbus): added more Stringer implementations
add f347cfc383 feat(plc4go/gen): add support for chan and func fields
add 2931bd6df9 feat(plc4go/gen): added couple of missing features
add d06433b7b5 feat(plc4go/gen): added byte support
add 3aa66052aa refactor(plc4go): use generated Stringers instead of hand written ones
add 403d10cd97 Revert "build(deps): bump ecj from 3.32.0 to 3.34.0 (#989)" (#990)
add 434e286729 build(deps): bump logback.version from 1.4.7 to 1.4.8 (#992)
add 80e3e4f003 build(deps): bump golang.org/x/net from 0.10.0 to 0.11.0 in /plc4go (#994)
add 207332b8ae chore(site): add hint to install libpcap with nmap [skip ci]
add 7eb4d4a1db chore(build/plc4go): run a mvn compile before the actual mvn install on windows
add ea58f93655 chore(build/plc4go): output the long path property on windows
add 7615701e13 feat(plc4go): improve logging for subscription
add 6fa5bc147f feat(plc4go): improve logging on browse
add cccdf75826 feat(plc4go/cbus): indicate if we handle a subscription event
add cc50fa99a5 chore(plc4go): update mocks
add ed6d1acbb9 chore(build/plc4go): disable coverage under windows
add 33233da806 chore(build/plc4go): link upstream go issue
add b8c4bf24c8 feat(plc4go/spi): test transport should now properly output the url
add dfe1459f02 feat(plc4go/cbus): more log details on the connection process
add de1c69b3ff test(plc4go/cbus): trace workers on one flaky test
add a59ec19248 test(plc4go/cache): hook in correct logger
new 584ec413bf Merge remote-tracking branch 'origin/develop' into chore/profinet-phase-3
new 62933b6676 fix(plc4go): Made the Tracer synchronized
The 2 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:
.github/workflows/go-platform-test-report.yml | 41 ++
.github/workflows/go-platform.yml | 28 +-
.github/workflows/java-platform-test-report.yml | 42 ++
.github/workflows/java-platform.yml | 23 +-
plc4go/go.mod | 8 +-
plc4go/go.sum | 16 +-
plc4go/internal/ads/Browser.go | 5 +-
plc4go/internal/ads/Connection.go | 9 +-
plc4go/internal/ads/Discoverer.go | 3 +-
plc4go/internal/ads/Driver.go | 2 +-
plc4go/internal/ads/Interactions.go | 13 +-
plc4go/internal/ads/Reader.go | 5 +-
plc4go/internal/ads/Subscriber.go | 5 +-
plc4go/internal/ads/Writer.go | 5 +-
plc4go/internal/ads/mock_SymbolicPlcQuery_test.go | 11 +-
plc4go/internal/bacnetip/ApplicationModule.go | 2 +-
plc4go/internal/bacnetip/Connection.go | 9 +-
plc4go/internal/bacnetip/Discoverer.go | 4 +-
plc4go/internal/bacnetip/mock_BacNetPlcTag_test.go | 11 +-
.../bacnetip/mock_OneShotTaskRequirements_test.go | 11 +-
plc4go/internal/bacnetip/mock_PDUOption_test.go | 11 +-
.../mock_RecurringTaskRequirements_test.go | 11 +-
.../mock_SSMProcessingRequirements_test.go | 11 +-
.../bacnetip/mock_SSMSAPRequirements_test.go | 11 +-
.../mock_WhoIsIAmServicesRequirements_test.go | 11 +-
.../mock__ApplicationServiceElement_test.go | 11 +-
plc4go/internal/bacnetip/mock__BIPSAP_test.go | 11 +-
plc4go/internal/bacnetip/mock__Client_test.go | 11 +-
plc4go/internal/bacnetip/mock__IOCB_test.go | 11 +-
.../internal/bacnetip/mock__IOController_test.go | 11 +-
.../internal/bacnetip/mock__IOQController_test.go | 11 +-
plc4go/internal/bacnetip/mock__PDU_test.go | 11 +-
plc4go/internal/bacnetip/mock__Server_test.go | 11 +-
.../bacnetip/mock__ServiceAccessPoint_test.go | 11 +-
.../bacnetip/mock__TaskRequirements_test.go | 11 +-
plc4go/internal/bacnetip/mock_option_test.go | 11 +-
plc4go/internal/cbus/AlphaGenerator_plc4xgen.go | 61 ++
plc4go/internal/cbus/Browser.go | 39 +-
plc4go/internal/cbus/Browser_test.go | 14 +-
plc4go/internal/cbus/Configuration.go | 1 +
plc4go/internal/cbus/Configuration_plc4xgen.go | 105 ++++
plc4go/internal/cbus/Configuration_test.go | 68 ++
plc4go/internal/cbus/Connection.go | 85 ++-
plc4go/internal/cbus/Connection_plc4xgen.go | 149 +++++
plc4go/internal/cbus/Connection_test.go | 80 ++-
plc4go/internal/cbus/Discoverer.go | 7 +-
plc4go/internal/cbus/Driver.go | 4 +-
plc4go/internal/cbus/DriverContext.go | 1 +
plc4go/internal/cbus/DriverContext_plc4xgen.go | 65 ++
plc4go/internal/cbus/MessageCodec.go | 58 +-
plc4go/internal/cbus/MessageCodec_plc4xgen.go | 126 ++++
plc4go/internal/cbus/MessageCodec_test.go | 71 ++-
plc4go/internal/cbus/Reader.go | 3 +-
plc4go/internal/cbus/Subscriber.go | 85 +--
plc4go/internal/cbus/Subscriber_plc4xgen.go | 61 ++
plc4go/internal/cbus/Subscriber_test.go | 96 ++-
plc4go/internal/cbus/Writer.go | 3 +-
plc4go/internal/cbus/mock_CALGetStatusTag_test.go | 11 +-
plc4go/internal/cbus/mock_CALIdentifyTag_test.go | 11 +-
plc4go/internal/cbus/mock_CALRecallTag_test.go | 11 +-
plc4go/internal/cbus/mock_CalTag_test.go | 11 +-
.../cbus/mock_CommandAndArgumentsCount_test.go | 11 +-
plc4go/internal/cbus/mock_MMIMonitorTag_test.go | 11 +-
.../internal/cbus/mock_RequestTransaction_test.go | 11 +-
plc4go/internal/cbus/mock_SALMonitorTag_test.go | 11 +-
plc4go/internal/cbus/mock_SALTag_test.go | 11 +-
plc4go/internal/cbus/mock_StatusTag_test.go | 11 +-
plc4go/internal/cbus/mock_Tag_test.go | 11 +-
plc4go/internal/cbus/mock_UnitInfoQuery_test.go | 11 +-
plc4go/internal/cbus/mock_addressProvider_test.go | 11 +-
plc4go/internal/eip/Connection.go | 9 +-
plc4go/internal/eip/{EipDriver.go => Driver.go} | 2 +-
plc4go/internal/eip/Reader.go | 11 +-
plc4go/internal/eip/Tag.go | 4 +-
plc4go/internal/eip/Writer.go | 5 +-
plc4go/internal/eip/mock_EIPPlcTag_test.go | 407 ------------
plc4go/internal/{s7 => eip}/mock_PlcTag_test.go | 210 ++-----
plc4go/internal/knxnetip/Connection.go | 13 +-
.../knxnetip/ConnectionDriverSpecificOperations.go | 15 +-
plc4go/internal/knxnetip/ConnectionHelper.go | 3 +-
plc4go/internal/knxnetip/Discoverer.go | 5 +-
plc4go/internal/knxnetip/Reader.go | 3 +-
plc4go/internal/knxnetip/Subscriber.go | 3 +-
plc4go/internal/knxnetip/mock_DeviceTag_test.go | 11 +-
.../internal/knxnetip/mock_GroupAddressTag_test.go | 11 +-
plc4go/internal/knxnetip/mock_Tag_test.go | 11 +-
.../{ModbusAsciiDriver.go => AsciiDriver.go} | 13 +-
plc4go/internal/modbus/Connection.go | 7 +-
plc4go/internal/modbus/Reader.go | 7 +-
.../modbus/{ModbusRtuDriver.go => RtuDriver.go} | 13 +-
plc4go/internal/modbus/Tag.go | 4 +-
.../modbus/{ModbusTcpDriver.go => TcpDriver.go} | 13 +-
plc4go/internal/modbus/Writer.go | 2 +-
plc4go/internal/s7/Connection.go | 7 +-
plc4go/internal/s7/Driver.go | 2 +-
plc4go/internal/s7/Reader.go | 3 +-
plc4go/internal/s7/Writer.go | 3 +-
plc4go/internal/s7/mock_PlcTag_test.go | 11 +-
plc4go/internal/simulated/Connection.go | 11 +-
plc4go/internal/simulated/Device.go | 21 +-
plc4go/internal/simulated/Device_test.go | 30 +-
plc4go/internal/simulated/Reader.go | 7 +-
plc4go/internal/simulated/Reader_test.go | 8 +-
plc4go/internal/simulated/Subscriber.go | 4 +-
plc4go/internal/simulated/Tag.go | 6 +-
plc4go/internal/simulated/Tag_test.go | 2 +-
plc4go/internal/simulated/Writer.go | 7 +-
plc4go/internal/simulated/Writer_test.go | 14 +-
plc4go/internal/simulated/mock_Tag_test.go | 39 +-
plc4go/pkg/api/cache/PlcConnectionCache.go | 4 +-
plc4go/pkg/api/cache/PlcConnectionCache_test.go | 86 ++-
plc4go/pkg/api/cache/connectionContainer_test.go | 12 +-
.../mock_PlcConnectionCacheCloseResult_test.go | 11 +-
.../pkg/api/cache/mock_PlcConnectionCache_test.go | 11 +-
.../cache/mock_WithConnectionCacheOption_test.go | 11 +-
plc4go/pkg/api/cache/mock_connectionEvent_test.go | 11 +-
.../pkg/api/cache/mock_connectionListener_test.go | 11 +-
.../pkg/api/cache/mock_tracedPlcConnection_test.go | 23 +-
plc4go/pkg/api/cache/plcConnectionLease.go | 2 +-
plc4go/pkg/api/cache/plcConnectionLease_test.go | 73 ++-
plc4go/pkg/api/cache/tracedPlcConnection.go | 2 +-
plc4go/pkg/api/config/mock_WithOption_test.go | 11 +-
.../pkg/api/mock_PlcConnectionCloseResult_test.go | 11 +-
.../api/mock_PlcConnectionConnectResult_test.go | 11 +-
.../pkg/api/mock_PlcConnectionPingResult_test.go | 11 +-
plc4go/pkg/api/mock_PlcConnection_test.go | 11 +-
plc4go/pkg/api/mock_PlcDriverManager_test.go | 11 +-
plc4go/pkg/api/mock_PlcDriver_test.go | 11 +-
plc4go/pkg/api/mock_Transport_test.go | 11 +-
plc4go/pkg/api/mock_WithDiscoveryOption_test.go | 11 +-
plc4go/pkg/api/model/mock_ArrayInfo_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcBrowseItem_test.go | 11 +-
.../api/model/mock_PlcBrowseRequestBuilder_test.go | 11 +-
.../api/model/mock_PlcBrowseRequestResult_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcBrowseRequest_test.go | 11 +-
.../pkg/api/model/mock_PlcBrowseResponse_test.go | 11 +-
.../api/model/mock_PlcConnectionMetadata_test.go | 11 +-
.../api/model/mock_PlcConsumerRegistration_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcDiscoveryItem_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcMessage_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcQuery_test.go | 11 +-
.../api/model/mock_PlcReadRequestBuilder_test.go | 11 +-
.../api/model/mock_PlcReadRequestResult_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcReadRequest_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcReadResponse_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcRequest_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcResponse_test.go | 11 +-
.../mock_PlcSubscriptionEventConsumer_test.go | 11 +-
.../api/model/mock_PlcSubscriptionEvent_test.go | 11 +-
.../api/model/mock_PlcSubscriptionHandle_test.go | 11 +-
.../mock_PlcSubscriptionRequestBuilder_test.go | 11 +-
.../mock_PlcSubscriptionRequestResult_test.go | 11 +-
.../api/model/mock_PlcSubscriptionRequest_test.go | 11 +-
.../api/model/mock_PlcSubscriptionResponse_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcTag_test.go | 11 +-
.../mock_PlcUnsubscriptionRequestBuilder_test.go | 11 +-
.../mock_PlcUnsubscriptionRequestResult_test.go | 11 +-
.../model/mock_PlcUnsubscriptionRequest_test.go | 11 +-
.../model/mock_PlcUnsubscriptionResponse_test.go | 11 +-
.../api/model/mock_PlcWriteRequestBuilder_test.go | 11 +-
.../api/model/mock_PlcWriteRequestResult_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcWriteRequest_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcWriteResponse_test.go | 11 +-
plc4go/pkg/api/model/plc_response_code.go | 2 +-
plc4go/pkg/api/model/plc_response_code_test.go | 7 +-
plc4go/pkg/api/values/mock_PlcValue_test.go | 11 +-
plc4go/pkg/api/values/mock_RawPlcValue_test.go | 11 +-
plc4go/pom.xml | 38 +-
.../cbus/readwrite/model/StaticHelper_test.go | 300 ++++++++-
plc4go/spi/default/DefaultBrowser.go | 3 +-
plc4go/spi/default/DefaultCodec.go | 9 +-
plc4go/spi/default/DefaultCodec_test.go | 68 ++
plc4go/spi/default/DefaultConnection.go | 14 +-
plc4go/spi/default/DefaultConnection_test.go | 45 ++
.../defaultCodec_plc4xgen.go} | 50 +-
.../defaultConnection_plc4xgen.go} | 52 +-
.../spi/default/mock_CustomMessageHandler_test.go | 11 +-
.../mock_DefaultBrowserRequirements_test.go | 11 +-
plc4go/spi/default/mock_DefaultBrowser_test.go | 11 +-
.../default/mock_DefaultCodecRequirements_test.go | 11 +-
plc4go/spi/default/mock_DefaultCodec_test.go | 107 +++-
.../mock_DefaultConnectionRequirements_test.go | 11 +-
plc4go/spi/default/mock_DefaultConnection_test.go | 109 +++-
.../default/mock_DefaultDriverRequirements_test.go | 11 +-
plc4go/spi/default/mock_DefaultDriver_test.go | 11 +-
.../mock_DefaultPlcConnectionCloseResult_test.go | 11 +-
.../mock_DefaultPlcConnectionConnectResult_test.go | 11 +-
.../mock_DefaultPlcConnectionPingResult_test.go | 11 +-
plc4go/spi/{ => default}/mock_Expectation_test.go | 53 +-
plc4go/spi/default/mock_MessageCodec_test.go | 11 +-
plc4go/spi/default/mock_Message_test.go | 11 +-
.../mock_PlcConnectionConnectResult_test.go | 11 +-
plc4go/spi/default/mock_PlcConnection_test.go | 11 +-
plc4go/spi/default/mock_PlcQuery_test.go | 11 +-
plc4go/spi/default/mock_PlcTagHandler_test.go | 11 +-
plc4go/spi/default/mock_TransportInstance_test.go | 11 +-
plc4go/spi/default/mock_requirements.go | 5 +
plc4go/spi/default/testTransportInstance_test.go | 83 ---
.../interceptors/mock_PlcReadRequestResult_test.go | 11 +-
.../spi/interceptors/mock_PlcReadRequest_test.go | 11 +-
.../spi/interceptors/mock_PlcReadResponse_test.go | 11 +-
.../mock_PlcWriteRequestResult_test.go | 11 +-
.../spi/interceptors/mock_PlcWriteRequest_test.go | 11 +-
.../spi/interceptors/mock_PlcWriteResponse_test.go | 11 +-
.../mock_ReadRequestInterceptorExposer_test.go | 11 +-
.../mock_ReadRequestInterceptor_test.go | 11 +-
plc4go/spi/interceptors/mock_ReaderExposer_test.go | 11 +-
.../interceptors/mock_RequestInterceptor_test.go | 11 +-
.../mock_WriteRequestInterceptorExposer_test.go | 11 +-
.../mock_WriteRequestInterceptor_test.go | 11 +-
plc4go/spi/interceptors/mock_WriterExposer_test.go | 11 +-
.../interceptors/mock_readRequestFactory_test.go | 11 +-
.../interceptors/mock_readResponseFactory_test.go | 11 +-
.../interceptors/mock_writeRequestFactory_test.go | 11 +-
.../interceptors/mock_writeResponseFactory_test.go | 11 +-
plc4go/spi/mock_AcceptsMessage_test.go | 11 +-
plc4go/spi/mock_CompletableFuture_test.go | 11 +-
plc4go/spi/mock_CompletionFuture_test.go | 11 +-
plc4go/spi/mock_Expectation_test.go | 11 +-
plc4go/spi/mock_HandleError_test.go | 11 +-
plc4go/spi/mock_HandleMessage_test.go | 11 +-
plc4go/spi/mock_HandlerExposer_test.go | 11 +-
plc4go/spi/mock_MessageCodec_test.go | 11 +-
plc4go/spi/mock_Message_test.go | 11 +-
plc4go/spi/mock_PlcBrowser_test.go | 11 +-
plc4go/spi/mock_PlcDiscoverer_test.go | 11 +-
plc4go/spi/mock_PlcReader_test.go | 11 +-
plc4go/spi/mock_PlcSubscriber_test.go | 11 +-
plc4go/spi/mock_PlcTagHandler_test.go | 11 +-
plc4go/spi/mock_PlcValueHandler_test.go | 11 +-
plc4go/spi/mock_PlcWriter_test.go | 11 +-
plc4go/spi/mock_TransportAware_test.go | 11 +-
plc4go/spi/mock_TransportInstanceExposer_test.go | 11 +-
.../DefaultPlcBrowseRequestResult_plc4xgen.go | 3 +-
.../DefaultPlcConsumerRegistration_plc4xgen.go | 3 +-
plc4go/spi/model/DefaultPlcReadRequest.go | 14 +-
.../model/DefaultPlcReadRequestResult_plc4xgen.go | 3 +-
.../DefaultPlcSubscriptionEventItem_plc4xgen.go | 8 +-
...DefaultPlcSubscriptionRequestResult_plc4xgen.go | 3 +-
plc4go/spi/model/DefaultPlcTagRequest_test.go | 17 +-
...faultPlcUnsubscriptionRequestResult_plc4xgen.go | 3 +-
plc4go/spi/model/DefaultPlcWriteRequest.go | 13 +-
.../model/DefaultPlcWriteRequestResult_plc4xgen.go | 3 +-
...DefaultPlcSubscriptionEventRequirements_test.go | 11 +-
plc4go/spi/model/mock_PlcBrowseItem_test.go | 11 +-
plc4go/spi/model/mock_PlcBrowser_test.go | 11 +-
plc4go/spi/model/mock_PlcQuery_test.go | 11 +-
plc4go/spi/model/mock_PlcReader_test.go | 11 +-
plc4go/spi/model/mock_PlcSubscriber_test.go | 11 +-
plc4go/spi/model/mock_PlcTagHandler_test.go | 11 +-
plc4go/spi/model/mock_PlcTag_test.go | 11 +-
plc4go/spi/model/mock_PlcValueHandler_test.go | 11 +-
plc4go/spi/model/mock_PlcWriter_test.go | 11 +-
.../spi/model/mock_ReadRequestInterceptor_test.go | 11 +-
.../spi/model/mock_WriteRequestInterceptor_test.go | 11 +-
.../options/mock_DiscoveryOptionDeviceName_test.go | 11 +-
.../mock_DiscoveryOptionLocalAddress_test.go | 11 +-
.../mock_DiscoveryOptionProtocolSpecific_test.go | 11 +-
.../options/mock_DiscoveryOptionProtocol_test.go | 11 +-
.../mock_DiscoveryOptionRemoteAddress_test.go | 11 +-
.../options/mock_DiscoveryOptionTransport_test.go | 11 +-
.../spi/options/mock_WithDiscoveryOption_test.go | 11 +-
plc4go/spi/options/mock_WithOption_test.go | 11 +-
plc4go/spi/pool/WorkerPool.go | 394 +-----------
plc4go/spi/pool/WorkerPool_test.go | 689 ---------------------
plc4go/spi/pool/dynamicExecutor.go | 174 ++++++
plc4go/spi/pool/dynamicExecutor_plc4xgen.go | 73 +++
plc4go/spi/pool/dynamicExecutor_test.go | 223 +++++++
plc4go/spi/pool/executor.go | 130 ++++
.../executor_plc4xgen.go} | 55 +-
plc4go/spi/pool/executor_test.go | 478 ++++++++++++++
plc4go/spi/pool/future.go | 69 +++
.../future_plc4xgen.go} | 63 +-
plc4go/spi/pool/future_test.go | 196 ++++++
plc4go/spi/pool/mock_CompletionFuture_test.go | 11 +-
plc4go/spi/pool/mock_Executor_test.go | 11 +-
plc4go/spi/pool/mock_Runnable_test.go | 11 +-
.../cbus/DriverContext.go => spi/pool/workItem.go} | 14 +-
plc4go/spi/pool/workItem_plc4xgen.go | 68 ++
plc4go/spi/pool/workItem_test.go | 65 ++
plc4go/spi/pool/worker.go | 97 +++
plc4go/spi/pool/worker_plc4xgen.go | 82 +++
plc4go/spi/pool/worker_test.go | 258 ++++++++
plc4go/spi/testutils/DriverTestRunner.go | 35 +-
plc4go/spi/testutils/ParserSerializerTestRunner.go | 3 +-
.../mock_ConnectionConnectAwaiter_test.go | 11 +-
plc4go/spi/testutils/mock_Parser_test.go | 11 +-
.../testutils/mock_TestTransportInstance_test.go | 11 +-
.../spi/testutils/mock_WithTestCaseOption_test.go | 11 +-
plc4go/spi/testutils/mock_XmlParser_test.go | 11 +-
plc4go/spi/tracer/Tracer.go | 60 +-
plc4go/spi/tracer/Tracer_test.go | 36 +-
plc4go/spi/tracer/mock_Provider_test.go | 126 ++++
plc4go/spi/tracer/mock_TracerProvider_test.go | 127 ----
plc4go/spi/tracer/mock_Tracer_test.go | 360 +++++++++++
plc4go/spi/transactions/RequestTransaction.go | 145 +++++
.../spi/transactions/RequestTransactionManager.go | 132 +---
.../transactions/RequestTransactionManager_test.go | 402 +++---------
plc4go/spi/transactions/RequestTransaction_test.go | 324 ++++++++++
.../transactions/completedFuture.go} | 20 +-
.../spi/transactions/completedFuture_plc4xgen.go | 64 ++
plc4go/spi/transactions/completedFuture_test.go | 117 ++++
.../spi/transactions/mock_CompletionFuture_test.go | 11 +-
plc4go/spi/transactions/mock_Executor_test.go | 11 +-
.../mock_RequestTransactionManager_test.go | 11 +-
.../mock_RequestTransactionRunnable_test.go | 11 +-
.../transactions/mock_RequestTransaction_test.go | 11 +-
.../requestTransactionManager_plc4xgen.go} | 79 ++-
.../requestTransaction_plc4xgen.go} | 51 +-
.../spi/transports/mock_TransportInstance_test.go | 11 +-
plc4go/spi/transports/mock_Transport_test.go | 11 +-
plc4go/spi/transports/pcap/Transport.go | 3 +-
plc4go/spi/transports/test/Transport.go | 14 +-
.../utils/DefaultBufferedTransportInstance.go | 3 +-
...ltBufferedTransportInstanceRequirements_test.go | 11 +-
.../mock_DefaultBufferedTransportInstance_test.go | 11 +-
plc4go/spi/transports/utils/mock_Option_test.go | 11 +-
plc4go/spi/utils/Net.go | 5 +-
plc4go/spi/utils/ReadBufferJsonBased_test.go | 5 +-
plc4go/spi/utils/mock_AsciiBoxWriter_test.go | 11 +-
plc4go/spi/utils/mock_AsciiBoxer_test.go | 11 +-
plc4go/spi/utils/mock_ErrorIdentify_test.go | 11 +-
plc4go/spi/utils/mock_LengthAware_test.go | 11 +-
plc4go/spi/utils/mock_PlcValue_test.go | 11 +-
plc4go/spi/utils/mock_PositionAware_test.go | 11 +-
plc4go/spi/utils/mock_ReadBufferByteBased_test.go | 11 +-
plc4go/spi/utils/mock_ReadBuffer_test.go | 11 +-
plc4go/spi/utils/mock_Serializable_test.go | 11 +-
plc4go/spi/utils/mock_WithReaderArgs_test.go | 11 +-
plc4go/spi/utils/mock_WithReaderWriterArgs_test.go | 11 +-
plc4go/spi/utils/mock_WithWriterArgs_test.go | 11 +-
plc4go/spi/utils/mock_WriteBufferBoxBased_test.go | 11 +-
plc4go/spi/utils/mock_WriteBufferByteBased_test.go | 11 +-
plc4go/spi/utils/mock_WriteBufferJsonBased_test.go | 11 +-
plc4go/spi/utils/mock_WriteBufferXmlBased_test.go | 11 +-
plc4go/spi/utils/mock_WriteBuffer_test.go | 11 +-
plc4go/spi/values/mock_ArrayInfo_test.go | 11 +-
plc4go/spi/values/mock_PlcTag_test.go | 11 +-
.../values/mock_WriteBufferPlcValueBased_test.go | 11 +-
plc4go/tests/drivers/tests/abeth_driver_test.go | 4 +-
.../drivers/tests/abeth_parser_serializer_test.go | 2 +
plc4go/tests/drivers/tests/ads_driver_test.go | 4 +-
.../drivers/tests/ads_parser_serializer_test.go | 2 +
.../drivers/tests/bacnet_parser_serializer_test.go | 2 +
plc4go/tests/drivers/tests/df1_driver_test.go | 4 +-
.../drivers/tests/df1_parser_serializer_test.go | 2 +
plc4go/tests/drivers/tests/eip_driver_test.go | 4 +-
.../drivers/tests/eip_parser_serializer_test.go | 3 +
plc4go/tests/drivers/tests/firmata_driver_test.go | 5 +-
.../tests/firmata_parser_serializer_test.go | 2 +
plc4go/tests/drivers/tests/knxnetip_driver_test.go | 4 +-
.../tests/knxnetip_parser_serializer_test.go | 2 +
.../drivers/tests/manual_bacnet_PcapTest_test.go | 10 +-
plc4go/tests/drivers/tests/modbus_driver_test.go | 4 +-
.../drivers/tests/modbus_parser_serializer_test.go | 2 +
plc4go/tests/drivers/tests/s7_driver_test.go | 4 +-
.../drivers/tests/s7_parser_serializer_test.go | 2 +
plc4go/tools/plc4xgenerator/gen.go | 105 +++-
.../internal/common/mock_FilteredPackage_test.go | 11 +-
plc4j/examples/hello-cloud-azure/pom.xml | 2 +-
plc4j/integrations/apache-nifi/pom.xml | 2 +-
pom.xml | 8 +-
.../asciidoc/developers/preparing/windows.adoc | 4 +
src/site/asciidoc/images/iimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/image0.png | Bin 12311 -> 0 bytes
src/site/asciidoc/images/image01.png | Bin 12311 -> 0 bytes
src/site/asciidoc/images/image01x.png | Bin 12311 -> 0 bytes
src/site/asciidoc/images/image02.png | Bin 36284 -> 0 bytes
src/site/asciidoc/images/image03.png | Bin 36298 -> 0 bytes
src/site/asciidoc/images/image04.png | Bin 28682 -> 0 bytes
src/site/asciidoc/images/image05.png | Bin 28183 -> 0 bytes
src/site/asciidoc/images/image06.png | Bin 84508 -> 0 bytes
src/site/asciidoc/images/image07.png | Bin 12347 -> 0 bytes
src/site/asciidoc/images/image0X.png | Bin 36284 -> 0 bytes
src/site/asciidoc/images/imageimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/images/image01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/images/userimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/images/users/image01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/images/users/pimage01.png | Bin 11816 -> 0 bytes
.../asciidoc/images/images/users/primage01.png | Bin 11816 -> 0 bytes
.../asciidoc/images/images/users/proimage01.png | Bin 11816 -> 0 bytes
.../images/images/users/protocoimage01.png | Bin 11816 -> 0 bytes
.../images/images/users/protocols/image01.png | Bin 11816 -> 0 bytes
.../images/images/users/protocolsimage01.png | Bin 11816 -> 0 bytes
.../asciidoc/images/images/users/protoimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/images/usersimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/images/usimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/imagesimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/imagimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/imaimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/protocols-s7-osi.png | Bin 49183 -> 0 bytes
src/site/asciidoc/images/szlxy11.png | Bin 25943 -> 0 bytes
src/site/asciidoc/images/szlxy11demo.png | Bin 25943 -> 0 bytes
src/site/asciidoc/images/szlxy12.png | Bin 164597 -> 0 bytes
src/site/asciidoc/images/users/protocols/i.png | Bin 2327 -> 0 bytes
src/site/asciidoc/images/users/protocols/im.png | Bin 2327 -> 0 bytes
src/site/asciidoc/images/users/protocols/ima.png | Bin 2327 -> 0 bytes
src/site/asciidoc/images/users/protocols/imag.png | Bin 2327 -> 0 bytes
.../asciidoc/images/users/protocols/image0.png | Bin 34410 -> 0 bytes
.../asciidoc/images/users/protocols/image01.png | Bin 11816 -> 0 bytes
.../asciidoc/images/users/protocols/image02.png | Bin 34410 -> 0 bytes
.../asciidoc/images/users/protocols/image03.png | Bin 28738 -> 0 bytes
.../asciidoc/images/users/protocols/image04.png | Bin 28166 -> 0 bytes
.../asciidoc/images/users/protocols/image05.png | Bin 84472 -> 0 bytes
.../asciidoc/images/users/protocols/image0X.png | Bin 34410 -> 0 bytes
.../asciidoc/images/users/protocols/image0z.png | Bin 2331 -> 0 bytes
src/site/asciidoc/images/users/protocols/s.png | Bin 2327 -> 0 bytes
src/site/asciidoc/images/users/protocols/sz.png | Bin 2327 -> 0 bytes
src/site/asciidoc/images/users/protocols/szl.png | Bin 2327 -> 0 bytes
src/site/asciidoc/images/users/protocols/szlx.png | Bin 2327 -> 0 bytes
src/site/asciidoc/images/users/protocols/szlxy.png | Bin 39407 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy1.png | Bin 27419 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy11.png | Bin 25943 -> 0 bytes
.../images/users/protocols/szlxy11demo.png | Bin 25943 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy12.png | Bin 164597 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy13.png | Bin 55399 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy14.png | Bin 34683 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy15.png | Bin 27419 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy1C.png | Bin 21410 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy2.png | Bin 27419 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy22.png | Bin 325663 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy7.png | Bin 39407 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy74.png | Bin 39407 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy91.png | Bin 65120 -> 0 bytes
src/site/asciidoc/index.adoc | 14 +
src/site/asciidoc/users/protocols/s7.adoc | 24 +-
.../images/{users => }/protocols/mi_001.png | Bin
.../protocols => }/s7-tia-device-settings.png | Bin
.../{users/protocols => }/s7-tia-io-settings.png | Bin
.../images/{users/protocols => }/s7_banner.png | Bin
.../resources/images/{tutorials/s7 => }/s7_url.png | Bin
431 files changed, 6819 insertions(+), 4329 deletions(-)
create mode 100644 .github/workflows/go-platform-test-report.yml
create mode 100644 .github/workflows/java-platform-test-report.yml
create mode 100644 plc4go/internal/cbus/AlphaGenerator_plc4xgen.go
create mode 100644 plc4go/internal/cbus/Configuration_plc4xgen.go
create mode 100644 plc4go/internal/cbus/Connection_plc4xgen.go
create mode 100644 plc4go/internal/cbus/DriverContext_plc4xgen.go
create mode 100644 plc4go/internal/cbus/MessageCodec_plc4xgen.go
create mode 100644 plc4go/internal/cbus/Subscriber_plc4xgen.go
rename plc4go/internal/eip/{EipDriver.go => Driver.go} (98%)
delete mode 100644 plc4go/internal/eip/mock_EIPPlcTag_test.go
copy plc4go/internal/{s7 => eip}/mock_PlcTag_test.go (58%)
rename plc4go/internal/modbus/{ModbusAsciiDriver.go => AsciiDriver.go} (89%)
rename plc4go/internal/modbus/{ModbusRtuDriver.go => RtuDriver.go} (89%)
rename plc4go/internal/modbus/{ModbusTcpDriver.go => TcpDriver.go} (89%)
copy plc4go/spi/{model/DefaultPlcConsumerRegistration_plc4xgen.go => default/defaultCodec_plc4xgen.go} (58%)
copy plc4go/spi/{model/DefaultPlcReadRequestResult_plc4xgen.go => default/defaultConnection_plc4xgen.go} (55%)
copy plc4go/spi/{ => default}/mock_Expectation_test.go (85%)
delete mode 100644 plc4go/spi/default/testTransportInstance_test.go
create mode 100644 plc4go/spi/pool/dynamicExecutor.go
create mode 100644 plc4go/spi/pool/dynamicExecutor_plc4xgen.go
create mode 100644 plc4go/spi/pool/dynamicExecutor_test.go
create mode 100644 plc4go/spi/pool/executor.go
copy plc4go/spi/{model/DefaultPlcConsumerRegistration_plc4xgen.go => pool/executor_plc4xgen.go} (59%)
create mode 100644 plc4go/spi/pool/executor_test.go
create mode 100644 plc4go/spi/pool/future.go
copy plc4go/spi/{model/DefaultPlcBrowseRequestResult_plc4xgen.go => pool/future_plc4xgen.go} (50%)
create mode 100644 plc4go/spi/pool/future_test.go
copy plc4go/{internal/cbus/DriverContext.go => spi/pool/workItem.go} (80%)
create mode 100644 plc4go/spi/pool/workItem_plc4xgen.go
create mode 100644 plc4go/spi/pool/workItem_test.go
create mode 100644 plc4go/spi/pool/worker.go
create mode 100644 plc4go/spi/pool/worker_plc4xgen.go
create mode 100644 plc4go/spi/pool/worker_test.go
create mode 100644 plc4go/spi/tracer/mock_Provider_test.go
delete mode 100644 plc4go/spi/tracer/mock_TracerProvider_test.go
create mode 100644 plc4go/spi/tracer/mock_Tracer_test.go
create mode 100644 plc4go/spi/transactions/RequestTransaction.go
create mode 100644 plc4go/spi/transactions/RequestTransaction_test.go
copy plc4go/{pkg/api/cache/tracedPlcConnection.go => spi/transactions/completedFuture.go} (73%)
create mode 100644 plc4go/spi/transactions/completedFuture_plc4xgen.go
create mode 100644 plc4go/spi/transactions/completedFuture_test.go
copy plc4go/spi/{model/DefaultPlcConsumerRegistration_plc4xgen.go => transactions/requestTransactionManager_plc4xgen.go} (58%)
copy plc4go/spi/{model/DefaultPlcReadRequestResult_plc4xgen.go => transactions/requestTransaction_plc4xgen.go} (50%)
delete mode 100644 src/site/asciidoc/images/iimage01.png
delete mode 100644 src/site/asciidoc/images/image0.png
delete mode 100644 src/site/asciidoc/images/image01.png
delete mode 100644 src/site/asciidoc/images/image01x.png
delete mode 100644 src/site/asciidoc/images/image02.png
delete mode 100644 src/site/asciidoc/images/image03.png
delete mode 100644 src/site/asciidoc/images/image04.png
delete mode 100644 src/site/asciidoc/images/image05.png
delete mode 100644 src/site/asciidoc/images/image06.png
delete mode 100644 src/site/asciidoc/images/image07.png
delete mode 100644 src/site/asciidoc/images/image0X.png
delete mode 100644 src/site/asciidoc/images/imageimage01.png
delete mode 100644 src/site/asciidoc/images/images/image01.png
delete mode 100644 src/site/asciidoc/images/images/userimage01.png
delete mode 100644 src/site/asciidoc/images/images/users/image01.png
delete mode 100644 src/site/asciidoc/images/images/users/pimage01.png
delete mode 100644 src/site/asciidoc/images/images/users/primage01.png
delete mode 100644 src/site/asciidoc/images/images/users/proimage01.png
delete mode 100644 src/site/asciidoc/images/images/users/protocoimage01.png
delete mode 100644 src/site/asciidoc/images/images/users/protocols/image01.png
delete mode 100644 src/site/asciidoc/images/images/users/protocolsimage01.png
delete mode 100644 src/site/asciidoc/images/images/users/protoimage01.png
delete mode 100644 src/site/asciidoc/images/images/usersimage01.png
delete mode 100644 src/site/asciidoc/images/images/usimage01.png
delete mode 100644 src/site/asciidoc/images/imagesimage01.png
delete mode 100644 src/site/asciidoc/images/imagimage01.png
delete mode 100644 src/site/asciidoc/images/imaimage01.png
delete mode 100644 src/site/asciidoc/images/protocols-s7-osi.png
delete mode 100644 src/site/asciidoc/images/szlxy11.png
delete mode 100644 src/site/asciidoc/images/szlxy11demo.png
delete mode 100644 src/site/asciidoc/images/szlxy12.png
delete mode 100644 src/site/asciidoc/images/users/protocols/i.png
delete mode 100644 src/site/asciidoc/images/users/protocols/im.png
delete mode 100644 src/site/asciidoc/images/users/protocols/ima.png
delete mode 100644 src/site/asciidoc/images/users/protocols/imag.png
delete mode 100644 src/site/asciidoc/images/users/protocols/image0.png
delete mode 100644 src/site/asciidoc/images/users/protocols/image01.png
delete mode 100644 src/site/asciidoc/images/users/protocols/image02.png
delete mode 100644 src/site/asciidoc/images/users/protocols/image03.png
delete mode 100644 src/site/asciidoc/images/users/protocols/image04.png
delete mode 100644 src/site/asciidoc/images/users/protocols/image05.png
delete mode 100644 src/site/asciidoc/images/users/protocols/image0X.png
delete mode 100644 src/site/asciidoc/images/users/protocols/image0z.png
delete mode 100644 src/site/asciidoc/images/users/protocols/s.png
delete mode 100644 src/site/asciidoc/images/users/protocols/sz.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szl.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlx.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlxy.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlxy1.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlxy11.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlxy11demo.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlxy12.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlxy13.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlxy14.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlxy15.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlxy1C.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlxy2.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlxy22.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlxy7.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlxy74.png
delete mode 100644 src/site/asciidoc/images/users/protocols/szlxy91.png
mode change 100755 => 100644 src/site/asciidoc/users/protocols/s7.adoc
copy src/site/resources/images/{users => }/protocols/mi_001.png (100%)
copy src/site/resources/images/{users/protocols => }/s7-tia-device-settings.png (100%)
copy src/site/resources/images/{users/protocols => }/s7-tia-io-settings.png (100%)
copy src/site/resources/images/{users/protocols => }/s7_banner.png (100%)
copy src/site/resources/images/{tutorials/s7 => }/s7_url.png (100%)
[plc4x] 02/02: fix(plc4go): Made the Tracer synchronized
Posted by cd...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
cdutz pushed a commit to branch chore/profinet-phase-3
in repository https://gitbox.apache.org/repos/asf/plc4x.git
commit 62933b66767b1c93327f98b3ee4f2b9e4fc29a41
Author: Christofer Dutz <cd...@apache.org>
AuthorDate: Wed Jun 14 16:02:39 2023 +0200
fix(plc4go): Made the Tracer synchronized
---
plc4go/pkg/api/cache/PlcConnectionCache_test.go | 4 ++++
plc4go/spi/tracer/Tracer.go | 15 ++++++++++++++-
2 files changed, 18 insertions(+), 1 deletion(-)
diff --git a/plc4go/pkg/api/cache/PlcConnectionCache_test.go b/plc4go/pkg/api/cache/PlcConnectionCache_test.go
index b367d65e8e..fa49225a36 100644
--- a/plc4go/pkg/api/cache/PlcConnectionCache_test.go
+++ b/plc4go/pkg/api/cache/PlcConnectionCache_test.go
@@ -456,6 +456,8 @@ func TestPlcConnectionCache_ReturningConnectionWithPingError(t *testing.T) {
t.Errorf("Expected %d connections in the cache but got %d", 0, len(cache.connections))
}
+ // In the connection string, we tell the driver to return an error with
+ // the given message on executing a ping operation.
connectionResultChan := cache.GetConnection("simulated://1.2.3.4:42?pingError=hurz&traceEnabled=true")
select {
case connectResult := <-connectionResultChan:
@@ -484,6 +486,8 @@ func TestPlcConnectionCache_ReturningConnectionWithPingError(t *testing.T) {
if traces[3].Operation+"-"+traces[3].Message != "ping-error: hurz" {
t.Errorf("Expected '%s' as fourth trace message, but got '%s'", "ping-error: hurz", traces[3])
}
+ } else {
+ t.Errorf("Expected a result, but got nil")
}
}
case <-time.After(20 * time.Second):
diff --git a/plc4go/spi/tracer/Tracer.go b/plc4go/spi/tracer/Tracer.go
index 29009c9a66..a2c026efd7 100644
--- a/plc4go/spi/tracer/Tracer.go
+++ b/plc4go/spi/tracer/Tracer.go
@@ -21,6 +21,7 @@ package tracer
import (
"fmt"
+ "sync"
"time"
"github.com/apache/plc4x/plc4go/spi/options"
@@ -64,6 +65,7 @@ func NewTracer(connectionId string, _options ...options.WithOption) Tracer {
type tracer struct {
connectionId string
traceEntries []TraceEntry
+ m sync.Mutex
log zerolog.Logger
}
@@ -77,14 +79,20 @@ func (t *tracer) SetConnectionId(connectionId string) {
}
func (t *tracer) ResetTraces() {
+ t.m.Lock()
t.traceEntries = []TraceEntry{}
+ t.m.Unlock()
}
func (t *tracer) GetTraces() []TraceEntry {
- return t.traceEntries
+ t.m.Lock()
+ entries := t.traceEntries
+ t.m.Unlock()
+ return entries
}
func (t *tracer) AddTrace(operation string, message string) {
+ t.m.Lock()
t.traceEntries = append(t.traceEntries, TraceEntry{
Timestamp: time.Now(),
ConnectionId: t.connectionId,
@@ -92,9 +100,11 @@ func (t *tracer) AddTrace(operation string, message string) {
Operation: operation,
Message: message,
})
+ t.m.Unlock()
}
func (t *tracer) AddTransactionalStartTrace(operation string, message string) string {
+ t.m.Lock()
transactionId := utils.GenerateId(t.log, 4)
t.traceEntries = append(t.traceEntries, TraceEntry{
Timestamp: time.Now(),
@@ -103,10 +113,12 @@ func (t *tracer) AddTransactionalStartTrace(operation string, message string) st
Operation: operation,
Message: message,
})
+ t.m.Unlock()
return transactionId
}
func (t *tracer) AddTransactionalTrace(transactionId string, operation string, message string) {
+ t.m.Lock()
t.traceEntries = append(t.traceEntries, TraceEntry{
Timestamp: time.Now(),
ConnectionId: t.connectionId,
@@ -114,6 +126,7 @@ func (t *tracer) AddTransactionalTrace(transactionId string, operation string, m
Operation: operation,
Message: message,
})
+ t.m.Unlock()
}
func (t *tracer) FilterTraces(traces []TraceEntry, connectionIdFilter string, transactionIdFilter string, operationFilter string, messageFilter string) []TraceEntry {
[plc4x] 01/02: Merge remote-tracking branch 'origin/develop' into chore/profinet-phase-3
Posted by cd...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
cdutz pushed a commit to branch chore/profinet-phase-3
in repository https://gitbox.apache.org/repos/asf/plc4x.git
commit 584ec413bf32165cf860ae64001b2ebea2212d32
Merge: fb50bd2703 a59ec19248
Author: Christofer Dutz <cd...@apache.org>
AuthorDate: Wed Jun 14 13:43:22 2023 +0200
Merge remote-tracking branch 'origin/develop' into chore/profinet-phase-3
.github/workflows/go-platform-test-report.yml | 41 ++
.github/workflows/go-platform.yml | 28 +-
.github/workflows/java-platform-test-report.yml | 42 ++
.github/workflows/java-platform.yml | 23 +-
plc4go/go.mod | 8 +-
plc4go/go.sum | 16 +-
plc4go/internal/ads/Browser.go | 5 +-
plc4go/internal/ads/Connection.go | 9 +-
plc4go/internal/ads/Discoverer.go | 3 +-
plc4go/internal/ads/Driver.go | 2 +-
plc4go/internal/ads/Interactions.go | 13 +-
plc4go/internal/ads/Reader.go | 5 +-
plc4go/internal/ads/Subscriber.go | 5 +-
plc4go/internal/ads/Writer.go | 5 +-
plc4go/internal/ads/mock_SymbolicPlcQuery_test.go | 11 +-
plc4go/internal/bacnetip/ApplicationModule.go | 2 +-
plc4go/internal/bacnetip/Connection.go | 9 +-
plc4go/internal/bacnetip/Discoverer.go | 4 +-
plc4go/internal/bacnetip/mock_BacNetPlcTag_test.go | 11 +-
.../bacnetip/mock_OneShotTaskRequirements_test.go | 11 +-
plc4go/internal/bacnetip/mock_PDUOption_test.go | 11 +-
.../mock_RecurringTaskRequirements_test.go | 11 +-
.../mock_SSMProcessingRequirements_test.go | 11 +-
.../bacnetip/mock_SSMSAPRequirements_test.go | 11 +-
.../mock_WhoIsIAmServicesRequirements_test.go | 11 +-
.../mock__ApplicationServiceElement_test.go | 11 +-
plc4go/internal/bacnetip/mock__BIPSAP_test.go | 11 +-
plc4go/internal/bacnetip/mock__Client_test.go | 11 +-
plc4go/internal/bacnetip/mock__IOCB_test.go | 11 +-
.../internal/bacnetip/mock__IOController_test.go | 11 +-
.../internal/bacnetip/mock__IOQController_test.go | 11 +-
plc4go/internal/bacnetip/mock__PDU_test.go | 11 +-
plc4go/internal/bacnetip/mock__Server_test.go | 11 +-
.../bacnetip/mock__ServiceAccessPoint_test.go | 11 +-
.../bacnetip/mock__TaskRequirements_test.go | 11 +-
plc4go/internal/bacnetip/mock_option_test.go | 11 +-
plc4go/internal/cbus/AlphaGenerator_plc4xgen.go | 61 ++
plc4go/internal/cbus/Browser.go | 39 +-
plc4go/internal/cbus/Browser_test.go | 14 +-
plc4go/internal/cbus/Configuration.go | 1 +
plc4go/internal/cbus/Configuration_plc4xgen.go | 105 ++++
plc4go/internal/cbus/Configuration_test.go | 68 ++
plc4go/internal/cbus/Connection.go | 85 ++-
plc4go/internal/cbus/Connection_plc4xgen.go | 149 +++++
plc4go/internal/cbus/Connection_test.go | 80 ++-
plc4go/internal/cbus/Discoverer.go | 7 +-
plc4go/internal/cbus/Driver.go | 4 +-
plc4go/internal/cbus/DriverContext.go | 1 +
plc4go/internal/cbus/DriverContext_plc4xgen.go | 65 ++
plc4go/internal/cbus/MessageCodec.go | 58 +-
plc4go/internal/cbus/MessageCodec_plc4xgen.go | 126 ++++
plc4go/internal/cbus/MessageCodec_test.go | 71 ++-
plc4go/internal/cbus/Reader.go | 3 +-
plc4go/internal/cbus/Subscriber.go | 85 +--
plc4go/internal/cbus/Subscriber_plc4xgen.go | 61 ++
plc4go/internal/cbus/Subscriber_test.go | 96 ++-
plc4go/internal/cbus/Writer.go | 3 +-
plc4go/internal/cbus/mock_CALGetStatusTag_test.go | 11 +-
plc4go/internal/cbus/mock_CALIdentifyTag_test.go | 11 +-
plc4go/internal/cbus/mock_CALRecallTag_test.go | 11 +-
plc4go/internal/cbus/mock_CalTag_test.go | 11 +-
.../cbus/mock_CommandAndArgumentsCount_test.go | 11 +-
plc4go/internal/cbus/mock_MMIMonitorTag_test.go | 11 +-
.../internal/cbus/mock_RequestTransaction_test.go | 11 +-
plc4go/internal/cbus/mock_SALMonitorTag_test.go | 11 +-
plc4go/internal/cbus/mock_SALTag_test.go | 11 +-
plc4go/internal/cbus/mock_StatusTag_test.go | 11 +-
plc4go/internal/cbus/mock_Tag_test.go | 11 +-
plc4go/internal/cbus/mock_UnitInfoQuery_test.go | 11 +-
plc4go/internal/cbus/mock_addressProvider_test.go | 11 +-
plc4go/internal/eip/Connection.go | 9 +-
plc4go/internal/eip/{EipDriver.go => Driver.go} | 2 +-
plc4go/internal/eip/Reader.go | 11 +-
plc4go/internal/eip/Tag.go | 4 +-
plc4go/internal/eip/Writer.go | 5 +-
plc4go/internal/eip/mock_EIPPlcTag_test.go | 407 ------------
plc4go/internal/{s7 => eip}/mock_PlcTag_test.go | 210 ++-----
plc4go/internal/knxnetip/Connection.go | 13 +-
.../knxnetip/ConnectionDriverSpecificOperations.go | 15 +-
plc4go/internal/knxnetip/ConnectionHelper.go | 3 +-
plc4go/internal/knxnetip/Discoverer.go | 5 +-
plc4go/internal/knxnetip/Reader.go | 3 +-
plc4go/internal/knxnetip/Subscriber.go | 3 +-
plc4go/internal/knxnetip/mock_DeviceTag_test.go | 11 +-
.../internal/knxnetip/mock_GroupAddressTag_test.go | 11 +-
plc4go/internal/knxnetip/mock_Tag_test.go | 11 +-
.../{ModbusAsciiDriver.go => AsciiDriver.go} | 13 +-
plc4go/internal/modbus/Connection.go | 7 +-
plc4go/internal/modbus/Reader.go | 7 +-
.../modbus/{ModbusRtuDriver.go => RtuDriver.go} | 13 +-
plc4go/internal/modbus/Tag.go | 4 +-
.../modbus/{ModbusTcpDriver.go => TcpDriver.go} | 13 +-
plc4go/internal/modbus/Writer.go | 2 +-
plc4go/internal/s7/Connection.go | 7 +-
plc4go/internal/s7/Driver.go | 2 +-
plc4go/internal/s7/Reader.go | 3 +-
plc4go/internal/s7/Writer.go | 3 +-
plc4go/internal/s7/mock_PlcTag_test.go | 11 +-
plc4go/internal/simulated/Connection.go | 11 +-
plc4go/internal/simulated/Device.go | 21 +-
plc4go/internal/simulated/Device_test.go | 30 +-
plc4go/internal/simulated/Reader.go | 7 +-
plc4go/internal/simulated/Reader_test.go | 8 +-
plc4go/internal/simulated/Subscriber.go | 4 +-
plc4go/internal/simulated/Tag.go | 6 +-
plc4go/internal/simulated/Tag_test.go | 2 +-
plc4go/internal/simulated/Writer.go | 7 +-
plc4go/internal/simulated/Writer_test.go | 14 +-
plc4go/internal/simulated/mock_Tag_test.go | 39 +-
plc4go/pkg/api/cache/PlcConnectionCache.go | 4 +-
plc4go/pkg/api/cache/PlcConnectionCache_test.go | 82 ++-
plc4go/pkg/api/cache/connectionContainer_test.go | 12 +-
.../mock_PlcConnectionCacheCloseResult_test.go | 11 +-
.../pkg/api/cache/mock_PlcConnectionCache_test.go | 11 +-
.../cache/mock_WithConnectionCacheOption_test.go | 11 +-
plc4go/pkg/api/cache/mock_connectionEvent_test.go | 11 +-
.../pkg/api/cache/mock_connectionListener_test.go | 11 +-
.../pkg/api/cache/mock_tracedPlcConnection_test.go | 23 +-
plc4go/pkg/api/cache/plcConnectionLease.go | 2 +-
plc4go/pkg/api/cache/plcConnectionLease_test.go | 73 ++-
plc4go/pkg/api/cache/tracedPlcConnection.go | 2 +-
plc4go/pkg/api/config/mock_WithOption_test.go | 11 +-
.../pkg/api/mock_PlcConnectionCloseResult_test.go | 11 +-
.../api/mock_PlcConnectionConnectResult_test.go | 11 +-
.../pkg/api/mock_PlcConnectionPingResult_test.go | 11 +-
plc4go/pkg/api/mock_PlcConnection_test.go | 11 +-
plc4go/pkg/api/mock_PlcDriverManager_test.go | 11 +-
plc4go/pkg/api/mock_PlcDriver_test.go | 11 +-
plc4go/pkg/api/mock_Transport_test.go | 11 +-
plc4go/pkg/api/mock_WithDiscoveryOption_test.go | 11 +-
plc4go/pkg/api/model/mock_ArrayInfo_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcBrowseItem_test.go | 11 +-
.../api/model/mock_PlcBrowseRequestBuilder_test.go | 11 +-
.../api/model/mock_PlcBrowseRequestResult_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcBrowseRequest_test.go | 11 +-
.../pkg/api/model/mock_PlcBrowseResponse_test.go | 11 +-
.../api/model/mock_PlcConnectionMetadata_test.go | 11 +-
.../api/model/mock_PlcConsumerRegistration_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcDiscoveryItem_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcMessage_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcQuery_test.go | 11 +-
.../api/model/mock_PlcReadRequestBuilder_test.go | 11 +-
.../api/model/mock_PlcReadRequestResult_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcReadRequest_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcReadResponse_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcRequest_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcResponse_test.go | 11 +-
.../mock_PlcSubscriptionEventConsumer_test.go | 11 +-
.../api/model/mock_PlcSubscriptionEvent_test.go | 11 +-
.../api/model/mock_PlcSubscriptionHandle_test.go | 11 +-
.../mock_PlcSubscriptionRequestBuilder_test.go | 11 +-
.../mock_PlcSubscriptionRequestResult_test.go | 11 +-
.../api/model/mock_PlcSubscriptionRequest_test.go | 11 +-
.../api/model/mock_PlcSubscriptionResponse_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcTag_test.go | 11 +-
.../mock_PlcUnsubscriptionRequestBuilder_test.go | 11 +-
.../mock_PlcUnsubscriptionRequestResult_test.go | 11 +-
.../model/mock_PlcUnsubscriptionRequest_test.go | 11 +-
.../model/mock_PlcUnsubscriptionResponse_test.go | 11 +-
.../api/model/mock_PlcWriteRequestBuilder_test.go | 11 +-
.../api/model/mock_PlcWriteRequestResult_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcWriteRequest_test.go | 11 +-
plc4go/pkg/api/model/mock_PlcWriteResponse_test.go | 11 +-
plc4go/pkg/api/model/plc_response_code.go | 2 +-
plc4go/pkg/api/model/plc_response_code_test.go | 7 +-
plc4go/pkg/api/values/mock_PlcValue_test.go | 11 +-
plc4go/pkg/api/values/mock_RawPlcValue_test.go | 11 +-
plc4go/pom.xml | 38 +-
.../cbus/readwrite/model/StaticHelper_test.go | 300 ++++++++-
plc4go/spi/default/DefaultBrowser.go | 3 +-
plc4go/spi/default/DefaultCodec.go | 9 +-
plc4go/spi/default/DefaultCodec_test.go | 68 ++
plc4go/spi/default/DefaultConnection.go | 14 +-
plc4go/spi/default/DefaultConnection_test.go | 45 ++
.../defaultCodec_plc4xgen.go} | 50 +-
.../defaultConnection_plc4xgen.go} | 52 +-
.../spi/default/mock_CustomMessageHandler_test.go | 11 +-
.../mock_DefaultBrowserRequirements_test.go | 11 +-
plc4go/spi/default/mock_DefaultBrowser_test.go | 11 +-
.../default/mock_DefaultCodecRequirements_test.go | 11 +-
plc4go/spi/default/mock_DefaultCodec_test.go | 107 +++-
.../mock_DefaultConnectionRequirements_test.go | 11 +-
plc4go/spi/default/mock_DefaultConnection_test.go | 109 +++-
.../default/mock_DefaultDriverRequirements_test.go | 11 +-
plc4go/spi/default/mock_DefaultDriver_test.go | 11 +-
.../mock_DefaultPlcConnectionCloseResult_test.go | 11 +-
.../mock_DefaultPlcConnectionConnectResult_test.go | 11 +-
.../mock_DefaultPlcConnectionPingResult_test.go | 11 +-
plc4go/spi/{ => default}/mock_Expectation_test.go | 53 +-
plc4go/spi/default/mock_MessageCodec_test.go | 11 +-
plc4go/spi/default/mock_Message_test.go | 11 +-
.../mock_PlcConnectionConnectResult_test.go | 11 +-
plc4go/spi/default/mock_PlcConnection_test.go | 11 +-
plc4go/spi/default/mock_PlcQuery_test.go | 11 +-
plc4go/spi/default/mock_PlcTagHandler_test.go | 11 +-
plc4go/spi/default/mock_TransportInstance_test.go | 11 +-
plc4go/spi/default/mock_requirements.go | 5 +
plc4go/spi/default/testTransportInstance_test.go | 83 ---
.../interceptors/mock_PlcReadRequestResult_test.go | 11 +-
.../spi/interceptors/mock_PlcReadRequest_test.go | 11 +-
.../spi/interceptors/mock_PlcReadResponse_test.go | 11 +-
.../mock_PlcWriteRequestResult_test.go | 11 +-
.../spi/interceptors/mock_PlcWriteRequest_test.go | 11 +-
.../spi/interceptors/mock_PlcWriteResponse_test.go | 11 +-
.../mock_ReadRequestInterceptorExposer_test.go | 11 +-
.../mock_ReadRequestInterceptor_test.go | 11 +-
plc4go/spi/interceptors/mock_ReaderExposer_test.go | 11 +-
.../interceptors/mock_RequestInterceptor_test.go | 11 +-
.../mock_WriteRequestInterceptorExposer_test.go | 11 +-
.../mock_WriteRequestInterceptor_test.go | 11 +-
plc4go/spi/interceptors/mock_WriterExposer_test.go | 11 +-
.../interceptors/mock_readRequestFactory_test.go | 11 +-
.../interceptors/mock_readResponseFactory_test.go | 11 +-
.../interceptors/mock_writeRequestFactory_test.go | 11 +-
.../interceptors/mock_writeResponseFactory_test.go | 11 +-
plc4go/spi/mock_AcceptsMessage_test.go | 11 +-
plc4go/spi/mock_CompletableFuture_test.go | 11 +-
plc4go/spi/mock_CompletionFuture_test.go | 11 +-
plc4go/spi/mock_Expectation_test.go | 11 +-
plc4go/spi/mock_HandleError_test.go | 11 +-
plc4go/spi/mock_HandleMessage_test.go | 11 +-
plc4go/spi/mock_HandlerExposer_test.go | 11 +-
plc4go/spi/mock_MessageCodec_test.go | 11 +-
plc4go/spi/mock_Message_test.go | 11 +-
plc4go/spi/mock_PlcBrowser_test.go | 11 +-
plc4go/spi/mock_PlcDiscoverer_test.go | 11 +-
plc4go/spi/mock_PlcReader_test.go | 11 +-
plc4go/spi/mock_PlcSubscriber_test.go | 11 +-
plc4go/spi/mock_PlcTagHandler_test.go | 11 +-
plc4go/spi/mock_PlcValueHandler_test.go | 11 +-
plc4go/spi/mock_PlcWriter_test.go | 11 +-
plc4go/spi/mock_TransportAware_test.go | 11 +-
plc4go/spi/mock_TransportInstanceExposer_test.go | 11 +-
.../DefaultPlcBrowseRequestResult_plc4xgen.go | 3 +-
.../DefaultPlcConsumerRegistration_plc4xgen.go | 3 +-
plc4go/spi/model/DefaultPlcReadRequest.go | 14 +-
.../model/DefaultPlcReadRequestResult_plc4xgen.go | 3 +-
.../DefaultPlcSubscriptionEventItem_plc4xgen.go | 8 +-
...DefaultPlcSubscriptionRequestResult_plc4xgen.go | 3 +-
plc4go/spi/model/DefaultPlcTagRequest_test.go | 17 +-
...faultPlcUnsubscriptionRequestResult_plc4xgen.go | 3 +-
plc4go/spi/model/DefaultPlcWriteRequest.go | 13 +-
.../model/DefaultPlcWriteRequestResult_plc4xgen.go | 3 +-
...DefaultPlcSubscriptionEventRequirements_test.go | 11 +-
plc4go/spi/model/mock_PlcBrowseItem_test.go | 11 +-
plc4go/spi/model/mock_PlcBrowser_test.go | 11 +-
plc4go/spi/model/mock_PlcQuery_test.go | 11 +-
plc4go/spi/model/mock_PlcReader_test.go | 11 +-
plc4go/spi/model/mock_PlcSubscriber_test.go | 11 +-
plc4go/spi/model/mock_PlcTagHandler_test.go | 11 +-
plc4go/spi/model/mock_PlcTag_test.go | 11 +-
plc4go/spi/model/mock_PlcValueHandler_test.go | 11 +-
plc4go/spi/model/mock_PlcWriter_test.go | 11 +-
.../spi/model/mock_ReadRequestInterceptor_test.go | 11 +-
.../spi/model/mock_WriteRequestInterceptor_test.go | 11 +-
.../options/mock_DiscoveryOptionDeviceName_test.go | 11 +-
.../mock_DiscoveryOptionLocalAddress_test.go | 11 +-
.../mock_DiscoveryOptionProtocolSpecific_test.go | 11 +-
.../options/mock_DiscoveryOptionProtocol_test.go | 11 +-
.../mock_DiscoveryOptionRemoteAddress_test.go | 11 +-
.../options/mock_DiscoveryOptionTransport_test.go | 11 +-
.../spi/options/mock_WithDiscoveryOption_test.go | 11 +-
plc4go/spi/options/mock_WithOption_test.go | 11 +-
plc4go/spi/pool/WorkerPool.go | 394 +-----------
plc4go/spi/pool/WorkerPool_test.go | 689 ---------------------
plc4go/spi/pool/dynamicExecutor.go | 174 ++++++
plc4go/spi/pool/dynamicExecutor_plc4xgen.go | 73 +++
plc4go/spi/pool/dynamicExecutor_test.go | 223 +++++++
plc4go/spi/pool/executor.go | 130 ++++
.../executor_plc4xgen.go} | 55 +-
plc4go/spi/pool/executor_test.go | 478 ++++++++++++++
plc4go/spi/pool/future.go | 69 +++
.../future_plc4xgen.go} | 63 +-
plc4go/spi/pool/future_test.go | 196 ++++++
plc4go/spi/pool/mock_CompletionFuture_test.go | 11 +-
plc4go/spi/pool/mock_Executor_test.go | 11 +-
plc4go/spi/pool/mock_Runnable_test.go | 11 +-
.../cbus/DriverContext.go => spi/pool/workItem.go} | 14 +-
plc4go/spi/pool/workItem_plc4xgen.go | 68 ++
plc4go/spi/pool/workItem_test.go | 65 ++
plc4go/spi/pool/worker.go | 97 +++
plc4go/spi/pool/worker_plc4xgen.go | 82 +++
plc4go/spi/pool/worker_test.go | 258 ++++++++
plc4go/spi/testutils/DriverTestRunner.go | 35 +-
plc4go/spi/testutils/ParserSerializerTestRunner.go | 3 +-
.../mock_ConnectionConnectAwaiter_test.go | 11 +-
plc4go/spi/testutils/mock_Parser_test.go | 11 +-
.../testutils/mock_TestTransportInstance_test.go | 11 +-
.../spi/testutils/mock_WithTestCaseOption_test.go | 11 +-
plc4go/spi/testutils/mock_XmlParser_test.go | 11 +-
plc4go/spi/tracer/Tracer.go | 45 +-
plc4go/spi/tracer/Tracer_test.go | 36 +-
plc4go/spi/tracer/mock_Provider_test.go | 126 ++++
plc4go/spi/tracer/mock_TracerProvider_test.go | 127 ----
plc4go/spi/tracer/mock_Tracer_test.go | 360 +++++++++++
plc4go/spi/transactions/RequestTransaction.go | 145 +++++
.../spi/transactions/RequestTransactionManager.go | 132 +---
.../transactions/RequestTransactionManager_test.go | 402 +++---------
plc4go/spi/transactions/RequestTransaction_test.go | 324 ++++++++++
.../transactions/completedFuture.go} | 20 +-
.../spi/transactions/completedFuture_plc4xgen.go | 64 ++
plc4go/spi/transactions/completedFuture_test.go | 117 ++++
.../spi/transactions/mock_CompletionFuture_test.go | 11 +-
plc4go/spi/transactions/mock_Executor_test.go | 11 +-
.../mock_RequestTransactionManager_test.go | 11 +-
.../mock_RequestTransactionRunnable_test.go | 11 +-
.../transactions/mock_RequestTransaction_test.go | 11 +-
.../requestTransactionManager_plc4xgen.go} | 79 ++-
.../requestTransaction_plc4xgen.go} | 51 +-
.../spi/transports/mock_TransportInstance_test.go | 11 +-
plc4go/spi/transports/mock_Transport_test.go | 11 +-
plc4go/spi/transports/pcap/Transport.go | 3 +-
plc4go/spi/transports/test/Transport.go | 14 +-
.../utils/DefaultBufferedTransportInstance.go | 3 +-
...ltBufferedTransportInstanceRequirements_test.go | 11 +-
.../mock_DefaultBufferedTransportInstance_test.go | 11 +-
plc4go/spi/transports/utils/mock_Option_test.go | 11 +-
plc4go/spi/utils/Net.go | 5 +-
plc4go/spi/utils/ReadBufferJsonBased_test.go | 5 +-
plc4go/spi/utils/mock_AsciiBoxWriter_test.go | 11 +-
plc4go/spi/utils/mock_AsciiBoxer_test.go | 11 +-
plc4go/spi/utils/mock_ErrorIdentify_test.go | 11 +-
plc4go/spi/utils/mock_LengthAware_test.go | 11 +-
plc4go/spi/utils/mock_PlcValue_test.go | 11 +-
plc4go/spi/utils/mock_PositionAware_test.go | 11 +-
plc4go/spi/utils/mock_ReadBufferByteBased_test.go | 11 +-
plc4go/spi/utils/mock_ReadBuffer_test.go | 11 +-
plc4go/spi/utils/mock_Serializable_test.go | 11 +-
plc4go/spi/utils/mock_WithReaderArgs_test.go | 11 +-
plc4go/spi/utils/mock_WithReaderWriterArgs_test.go | 11 +-
plc4go/spi/utils/mock_WithWriterArgs_test.go | 11 +-
plc4go/spi/utils/mock_WriteBufferBoxBased_test.go | 11 +-
plc4go/spi/utils/mock_WriteBufferByteBased_test.go | 11 +-
plc4go/spi/utils/mock_WriteBufferJsonBased_test.go | 11 +-
plc4go/spi/utils/mock_WriteBufferXmlBased_test.go | 11 +-
plc4go/spi/utils/mock_WriteBuffer_test.go | 11 +-
plc4go/spi/values/mock_ArrayInfo_test.go | 11 +-
plc4go/spi/values/mock_PlcTag_test.go | 11 +-
.../values/mock_WriteBufferPlcValueBased_test.go | 11 +-
plc4go/tests/drivers/tests/abeth_driver_test.go | 4 +-
.../drivers/tests/abeth_parser_serializer_test.go | 2 +
plc4go/tests/drivers/tests/ads_driver_test.go | 4 +-
.../drivers/tests/ads_parser_serializer_test.go | 2 +
.../drivers/tests/bacnet_parser_serializer_test.go | 2 +
plc4go/tests/drivers/tests/df1_driver_test.go | 4 +-
.../drivers/tests/df1_parser_serializer_test.go | 2 +
plc4go/tests/drivers/tests/eip_driver_test.go | 4 +-
.../drivers/tests/eip_parser_serializer_test.go | 3 +
plc4go/tests/drivers/tests/firmata_driver_test.go | 5 +-
.../tests/firmata_parser_serializer_test.go | 2 +
plc4go/tests/drivers/tests/knxnetip_driver_test.go | 4 +-
.../tests/knxnetip_parser_serializer_test.go | 2 +
.../drivers/tests/manual_bacnet_PcapTest_test.go | 10 +-
plc4go/tests/drivers/tests/modbus_driver_test.go | 4 +-
.../drivers/tests/modbus_parser_serializer_test.go | 2 +
plc4go/tests/drivers/tests/s7_driver_test.go | 4 +-
.../drivers/tests/s7_parser_serializer_test.go | 2 +
plc4go/tools/plc4xgenerator/gen.go | 105 +++-
.../internal/common/mock_FilteredPackage_test.go | 11 +-
plc4j/examples/hello-cloud-azure/pom.xml | 2 +-
plc4j/integrations/apache-nifi/pom.xml | 2 +-
pom.xml | 8 +-
.../asciidoc/developers/preparing/windows.adoc | 4 +
src/site/asciidoc/images/iimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/image0.png | Bin 12311 -> 0 bytes
src/site/asciidoc/images/image01.png | Bin 12311 -> 0 bytes
src/site/asciidoc/images/image01x.png | Bin 12311 -> 0 bytes
src/site/asciidoc/images/image02.png | Bin 36284 -> 0 bytes
src/site/asciidoc/images/image03.png | Bin 36298 -> 0 bytes
src/site/asciidoc/images/image04.png | Bin 28682 -> 0 bytes
src/site/asciidoc/images/image05.png | Bin 28183 -> 0 bytes
src/site/asciidoc/images/image06.png | Bin 84508 -> 0 bytes
src/site/asciidoc/images/image07.png | Bin 12347 -> 0 bytes
src/site/asciidoc/images/image0X.png | Bin 36284 -> 0 bytes
src/site/asciidoc/images/imageimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/images/image01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/images/userimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/images/users/image01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/images/users/pimage01.png | Bin 11816 -> 0 bytes
.../asciidoc/images/images/users/primage01.png | Bin 11816 -> 0 bytes
.../asciidoc/images/images/users/proimage01.png | Bin 11816 -> 0 bytes
.../images/images/users/protocoimage01.png | Bin 11816 -> 0 bytes
.../images/images/users/protocols/image01.png | Bin 11816 -> 0 bytes
.../images/images/users/protocolsimage01.png | Bin 11816 -> 0 bytes
.../asciidoc/images/images/users/protoimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/images/usersimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/images/usimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/imagesimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/imagimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/imaimage01.png | Bin 11816 -> 0 bytes
src/site/asciidoc/images/protocols-s7-osi.png | Bin 49183 -> 0 bytes
src/site/asciidoc/images/szlxy11.png | Bin 25943 -> 0 bytes
src/site/asciidoc/images/szlxy11demo.png | Bin 25943 -> 0 bytes
src/site/asciidoc/images/szlxy12.png | Bin 164597 -> 0 bytes
src/site/asciidoc/images/users/protocols/i.png | Bin 2327 -> 0 bytes
src/site/asciidoc/images/users/protocols/im.png | Bin 2327 -> 0 bytes
src/site/asciidoc/images/users/protocols/ima.png | Bin 2327 -> 0 bytes
src/site/asciidoc/images/users/protocols/imag.png | Bin 2327 -> 0 bytes
.../asciidoc/images/users/protocols/image0.png | Bin 34410 -> 0 bytes
.../asciidoc/images/users/protocols/image01.png | Bin 11816 -> 0 bytes
.../asciidoc/images/users/protocols/image02.png | Bin 34410 -> 0 bytes
.../asciidoc/images/users/protocols/image03.png | Bin 28738 -> 0 bytes
.../asciidoc/images/users/protocols/image04.png | Bin 28166 -> 0 bytes
.../asciidoc/images/users/protocols/image05.png | Bin 84472 -> 0 bytes
.../asciidoc/images/users/protocols/image0X.png | Bin 34410 -> 0 bytes
.../asciidoc/images/users/protocols/image0z.png | Bin 2331 -> 0 bytes
src/site/asciidoc/images/users/protocols/s.png | Bin 2327 -> 0 bytes
src/site/asciidoc/images/users/protocols/sz.png | Bin 2327 -> 0 bytes
src/site/asciidoc/images/users/protocols/szl.png | Bin 2327 -> 0 bytes
src/site/asciidoc/images/users/protocols/szlx.png | Bin 2327 -> 0 bytes
src/site/asciidoc/images/users/protocols/szlxy.png | Bin 39407 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy1.png | Bin 27419 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy11.png | Bin 25943 -> 0 bytes
.../images/users/protocols/szlxy11demo.png | Bin 25943 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy12.png | Bin 164597 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy13.png | Bin 55399 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy14.png | Bin 34683 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy15.png | Bin 27419 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy1C.png | Bin 21410 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy2.png | Bin 27419 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy22.png | Bin 325663 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy7.png | Bin 39407 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy74.png | Bin 39407 -> 0 bytes
.../asciidoc/images/users/protocols/szlxy91.png | Bin 65120 -> 0 bytes
src/site/asciidoc/index.adoc | 14 +
src/site/asciidoc/users/protocols/s7.adoc | 24 +-
src/site/resources/images/protocols/mi_001.png | Bin 0 -> 10574 bytes
.../resources/images/s7-tia-device-settings.png | Bin 0 -> 391398 bytes
src/site/resources/images/s7-tia-io-settings.png | Bin 0 -> 42175 bytes
src/site/resources/images/s7_banner.png | Bin 0 -> 42137 bytes
src/site/resources/images/s7_url.png | Bin 0 -> 10248 bytes
431 files changed, 6801 insertions(+), 4328 deletions(-)