Commit Graph
26 Commits
Author SHA1 Message Date
Julius Pfrommer 5bf6f0c3e7 refactor(pubsub): Remove the old direct-access API
The public Offset Table API should be used for realtime operations on
the NetworkMessages instead.
2025-01-19 22:33:50 +01:00
Julius Pfrommer f9109ddfa6 refactor(pubsub): Remove the last remnants of UA_ENABLE_PUBSUB_ENCRYPTION 2024-11-29 21:51:07 +01:00
Julius Pfrommer 3785ed5c4d Merge remote-tracking branch 'origin/1.4' into merge_14_master_24 2024-11-29 21:50:04 +01:00
Julius Pfrommer bfaec719ad Merge remote-tracking branch 'origin/1.4' into merge_14_master_24 2024-11-15 21:15:00 +01:00
Eugene Melekhov d4c5aaa2a7 fix(pubsub): Fix MQTT subscribe ReaderGroup config copying (#6808) (#6850) 2024-11-13 18:34:36 +01:00
Julius Pfrommer 450f8ac8d6 refactor(pubsub): Remove the unused "enabled" parameters in the config 2024-09-09 23:20:32 +02:00
Julius Pfrommer 8370f7a6bb refactor(examples): Simplify the PubSub component state handling in the examples 2024-09-09 23:20:32 +02:00
Julius Pfrommer f7d66be548 refactor(pubsub): Remove the UA_ENABLE_PUBSUB_MONITORING option and always enable 2024-09-09 23:20:32 +02:00
Julius Pfrommer 705801a55c refactor(examples): Use the NS0ID shorthand in the examples 2024-07-26 08:30:16 +02:00
Julius Pfrommer eab68cf716 refactor(pubsub): Always compile encryption for PubSub
This removes the UA_ENABLE_PUBSUB_ENCRYPTION option entirely.
Its not much code and the complexity gets reduced.
2024-07-20 11:42:05 +02:00
Julius Pfrommer 2b0d4890e7 refactor(pubsub): Use the same type for the PublisherId everywhere 2024-04-21 13:39:42 +02:00
Vasilij Strassheim 18e85b9136 fix(ex): fix json encoding in pubsub mqtt tutorial
Fix #5990 with additional TRANSPORT_PROFILE_URI and updated json enabling.

transportProfiles in ua_pubsub_eventloop do not have the used pubsub-mqtt
profile. Additional supported pubsub-mqtt-uadp and pubsub-mqtt-json
definitions will fix the examples.

Also json encoding is activated indirectly in the example with
UA_ENABLE_JSON_ENCODING, but at the same time the --json argument is
also offered for publish example while subscriber example doesn't have
such argument. This is inconsistent and confusing.

Now the same argument should activate the json encoding when the example
applications are called while uadp as still default/fallback.

Signed-off-by: Vasilij Strassheim <vasilij.strassheim@linutronix.de>
2023-11-16 13:19:50 +01:00
Julius Pfrommer 09317bcc00 Merge remote-tracking branch 'origin/1.4' 2023-11-14 17:39:04 +01:00
Julius Pfrommer 0271f50579 refactor(server): Only use logging-pointer instead of inline structure
We could not adjust all pointers when moving the config "into" the
server.
2023-11-10 08:38:53 +01:00
Gaurav Kumar Singh 5c979cd8c5 feat(pubsub) overhaul pubsub state machine, states, api, tests
* feat(pubsub): Add DSR state to pubsub-reduced namespace

* feat(pubsub) add preoperantiol-state for DataSetReaders

* feat(pubsub) DSR state representation added to information model

* feat(pubsub): Fix test to use pre-operational state

* feat(pubsub): Add state variable for Reader/WriterGroup and DataSetWriter

Signed-off-by: Gaurav Kumar Singh <gk.singh@be-services.com>

* feat(pubsub): Add Pre-Operational state for WG and DSW

Signed-off-by: Gaurav Kumar Singh <gk.singh@be-services.com>

* feat(pubsub) Revise state machine for Reader/WriterGroups based on proposal

- Add enableReader/WriterGroup API
- Add enableDataSetReader/Writer API
- Add automatic transitions from Pre-Operational to Operational
  based on connections and securitytoken configuration

* feat(pubsub) Add test cases for state changes

Signed-off-by: Gaurav Kumar Singh <gk.singh@be-services.com>

* feat(pubsub): Fix for pubsub tests to handle correct state changes

Signed-off-by: Gaurav Kumar Singh <gk.singh@be-services.com>

* feat(pubsub): Update examples to support enable APIs

* feat(pubsub): Update flow for key assignment via SKS

- Remove Operational APIs for Reader/WriterGroup
- Add API to ActivateKeys to channel
- Update SKS tests and Example application to use
the new API

Signed-off-by: Gaurav Kumar Singh <gk.singh@be-services.com>

* feat(pubsub): Add component interaction table for the puusub components

Signed-off-by: Gaurav Kumar Singh <gk.singh@be-services.com>

* fix(eventloop): Release lock before Shutdown
2023-07-28 10:01:14 +02:00
Julius Pfrommer fea29ebcd0 refactor(pubsub): Remove the unused SubscribingInterval from the ReaderGroup config 2023-07-27 00:11:41 +02:00
basyskom-dege 0f055942b7 feat(CI): Added support for arguments in the examples workflow (#5760)
* CI: Added support for arguments in the examples workflow

* Fixed memory leaks in examples. Add ApplicationUri

* Arguments and server/client for all examples. Small fixes

* outsource/blacklist some examples. Fix memory leak in example.

* Remove Shlex. Remove false UA_Client_delete

* Removed raw examples from ci. Fix leak in client.c and mqtt_publish

* Fix memory leak in mqtt subscriber
2023-07-02 02:58:40 +02:00
Julius Pfrommer b37c9af3fb fix(examples): Make tutorial_pubsub_mqtt_* build for MSVC 2023-06-16 18:52:25 +02:00
Julius Pfrommer 0841ce9f95 refactor(examples): Remove plugin/pubsub.h API from the examples 2023-06-16 18:52:25 +02:00
Julius Pfrommer dc9521f23b refactor(pubsub): Switch PubSub to EventLoop model 2023-06-13 16:58:55 +02:00
Julius Pfrommer 4b8ec01827 refactor(examples): Use UA_Server_runUntilInterrupt in examples 2023-01-15 17:34:17 +01:00
Julius Pfrommer 99890a71a0 refactor(pubsub): Move ua_pubsub_manager.h into ua_pubsub.h 2023-01-07 08:59:41 +01:00
Julius Pfrommer 9db33027db refactor(pubsub): Use UA_KeyValueMap instead of raw UA_KeyValuePair 2022-12-18 01:39:31 +01:00
Noel Graf 737f0562fc feat(pubsub): Adding payload encryption in mqtt publish example 2022-10-17 13:31:50 +02:00
Noel Graf 8563396d0d fix(pubsub): In the mqtt subscriber example, the messageReceiveTimout is set when pubsub monitoring is enabled, and the port has been changed. 2022-10-03 20:49:00 +02:00
Noel Graf f39c262234 feat(pubsub): Integrate MQTT Subscriber functionality and add an MQTT Subscriber example. (#5234) 2022-08-15 15:20:35 +02:00