Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merge 1.4 to master #6554

Merged
merged 52 commits into from
Jun 25, 2024
Merged
Changes from 1 commit
Commits
Show all changes
52 commits
Select commit Hold shift + click to select a range
f083d7a
fix(client): added missing channel state "UA_SECURECHANNELSTATE_OPN_S…
peschuster May 28, 2024
3bf2471
feat(test): Add a test for MonitoredItems on a DataSource with a fixe…
jpfr May 30, 2024
3f40576
fix(build): Correct path for schema files of external build
keba-estr May 31, 2024
8eb85bb
fix(nc): Correct setting of the namespaceIndex. Improve condition for…
NoelGraf Jun 3, 2024
4c148ac
fix(build): fix OpenSSL link flags in build output files
rickboks Jun 4, 2024
dc0c061
refactor(build): Use the SONAME version x.y property to disambiguate …
jpfr Jun 4, 2024
c18a462
refactor(build): Remove UA_PACK_DEBIAN - use the tools/prepare_packag…
jpfr Jun 4, 2024
68ed72e
feat(tests): Extend tests for writing int32 into an enum type
jpfr Jun 4, 2024
11c1a55
refactor(plugins): Make TCP port reuse the default
jpfr Jun 1, 2024
5ddf7ff
feat(server): Avoid malloc when writing "pointerfree" values of the s…
jpfr Jun 4, 2024
3888af3
fix(ns): Add ModelChangeEventType and ConditionType to support subscr…
NoelGraf Jun 5, 2024
069fffd
fix(arch): Fix build error with undefined UA_IPV6
keba-estr Jun 14, 2024
88dae21
fix(client): channel state set to CLOSING without closing underlying …
peschuster Jun 12, 2024
cd44415
test(client) Added test for connection termination when server sent a…
peschuster Jun 14, 2024
5ff50e2
fix(server): Directly write into the external data source if no callb…
jpfr Jun 15, 2024
de087eb
refactor(examples): Move outdated PubSub RT examples to the attic
jpfr Jun 6, 2024
21a6ec8
refactor(tests): Move incomplete ETF tests to the attic
jpfr Jun 15, 2024
caa1e7e
refactor(examples): Clean up server_pubsub_publisher_rt_level.c
jpfr Jun 6, 2024
5cecbde
refactor(examples): Clean up server_pubsub_subscriber_rt_level.c
jpfr Jun 10, 2024
345ed46
refactor(examples): Clean up server_pubsub_rt_field_information_model.c
jpfr Jun 12, 2024
cff036a
refactor(pubsub): Improve the documentation of UA_PubSubRTLevel
jpfr Jun 6, 2024
913ea88
refactor(pubsub): Use UA_PUBSUB_RT_DETERMINISTIC as the ORed combinat…
jpfr Jun 15, 2024
e4b7f42
feat(pubsub): Don't require the server-lock for RT-publishing when th…
jpfr Jun 6, 2024
5702d83
refactor(pubsub): Disentangle cases for the DataSet preparation
jpfr Jun 6, 2024
d0dd4a3
refactor(pubsub): Memset-zero the offset table fields to initialize
jpfr Jun 15, 2024
9aaf137
refactor(pubsub): Store the external value source in the offset table
jpfr Jun 15, 2024
6ab6a32
refactor(pubsub): Update UA_DataSetWriter_prepareDataSet to check for…
jpfr Jun 15, 2024
bf03702
refactor(pubsub): Cache the direct value pointer for the offset table…
jpfr Jun 15, 2024
b30b07d
refactor(pubsub): Cosmetic improvement in ua_pubsub_writergroup.c
jpfr Jun 15, 2024
381e3ad
refactor(pubsub): Explicit sampling in the RT publish path if direct …
jpfr Jun 15, 2024
f98d982
refactor(pubsub): Use the RT configuration as a bit-field
jpfr Jun 15, 2024
5e6841a
fix(pubsub): Use the external value source in the Reader
jpfr Jun 15, 2024
ab2054b
refactor(build): RT examples depend on sigset_t. Do not build on WIN32
jpfr Jun 15, 2024
f0c4533
fix(pubsub): Don't abort Reader with monitoring enabled for messageRe…
jpfr Jun 15, 2024
152e315
fix(pubsub): Don't overwrite the ReaderGroup external value configura…
jpfr Jun 16, 2024
2b76ea7
refactor(tests): Use the RT_DETERMINISTIC setting in check_pubsub_sub…
jpfr Jun 16, 2024
d463871
Merge branch 'publish_pubsub_rt' into merge_14_master_16
jpfr Jun 18, 2024
4f567ac
refactor(pubsub): Replace nested switch with linear if/else for the P…
jpfr Jun 22, 2024
9832cec
refactor(pubsub): Simplify PubSub monitoring handling
jpfr Jun 22, 2024
554369f
refactor(pubsub): Move StandaloneSubscribedDataSet definitions to ua_…
jpfr Jun 22, 2024
c253cd6
refactor(pubsub): Cleanup in ua_pubsub_dataset.c
jpfr Jun 22, 2024
5ae3272
refactor(pubsub): Make the reader connected to the StandaloneSubscrib…
jpfr Jun 22, 2024
7b2094f
refactor(pubsub): Simplifications in ua_pubsub_writer.c
jpfr Jun 22, 2024
dd0dc62
refactor(pubsub): Make the PublishedDataSet attached a Writer a direc…
jpfr Jun 22, 2024
0f61aca
feat(pubsub): Additional size checks for payloads
jpfr Jun 25, 2024
80bcf11
refactor(pubsub): Simplify the handling of payloads with raw content
jpfr Jun 25, 2024
f29aefc
refactor(pubsub): Simplify state handling of the ReaderGroup
jpfr Jun 25, 2024
3aec47a
refactor(pubsub): Remove the dependency on the DataSetMetaData during…
jpfr Jun 25, 2024
7cfea1f
refactor(pubsub): Simplify DataSetReader_processRaw
jpfr Jun 25, 2024
849367e
fix(pubsub): Cleanup allocations after raw decoding
jpfr Jun 25, 2024
018114e
refactor(pubsub): Remove dead code for mirror variables
jpfr Jun 25, 2024
9406efb
refactor(pubsub): Remove unneeded arguments in the DataSetMessage dec…
jpfr Jun 25, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
refactor(pubsub): Disentangle cases for the DataSet preparation
  • Loading branch information
jpfr committed Jun 17, 2024
commit 5702d83db8d86e70a6302e6e3cfffd4d703425bf
23 changes: 12 additions & 11 deletions src/pubsub/ua_pubsub_writer.c
Original file line number Diff line number Diff line change
Expand Up @@ -358,18 +358,9 @@ UA_DataSetWriter_unfreezeConfiguration(UA_Server *server,
UA_StatusCode
UA_DataSetWriter_prepareDataSet(UA_Server *server, UA_DataSetWriter *dsw,
UA_DataSetMessage *dsm) {
/* Find the dataset */
/* No PublishedDataSet defined -> Heartbeat messages only */
UA_StatusCode res = UA_STATUSCODE_GOOD;
UA_PublishedDataSet *pds =
UA_PublishedDataSet_findPDSbyId(server, dsw->connectedDataSet);
if(!pds) {
if(!UA_NodeId_isNull(&dsw->connectedDataSet)) {
UA_LOG_WARNING_WRITER(server->config.logging, dsw,
"PubSub-RT configuration fail: "
"PublishedDataSet not found");
return UA_STATUSCODE_BADINTERNALERROR;
}

if(UA_NodeId_isNull(&dsw->connectedDataSet)) {
res = UA_DataSetWriter_generateDataSetMessage(server, dsm, dsw);
if(res != UA_STATUSCODE_GOOD) {
UA_LOG_WARNING_WRITER(server->config.logging, dsw,
Expand All @@ -379,6 +370,16 @@ UA_DataSetWriter_prepareDataSet(UA_Server *server, UA_DataSetWriter *dsw,
return res;
}

/* Get the PublishedDataSet */
UA_PublishedDataSet *pds =
UA_PublishedDataSet_findPDSbyId(server, dsw->connectedDataSet);
if(!pds) {
UA_LOG_WARNING_WRITER(server->config.logging, dsw,
"PubSub-RT configuration fail: "
"PublishedDataSet not found");
return UA_STATUSCODE_BADINTERNALERROR;
}

if(pds->promotedFieldsCount > 0) {
UA_LOG_WARNING_WRITER(server->config.logging, dsw,
"PubSub-RT configuration fail: "
Expand Down